--no commit message

Maria Jorba Brosa
1 parent b4b1b5c4
Showing 1 changed file with 55 additions and 48 deletions
Project/applications/smartcities/main2.c
@@ -29,7 +29,7 @@ void initLibwismart(void)
 uint8_t connected=0;
 uint8_t timeout=0;
 uint8_t retries=0;
-uint8_t total_sensors=0;
+uint8_t first_sensor=0;
  
 void init_registry(void)
 {
@@ -86,55 +86,62 @@ void init_registry(void)
  
 }
  
-void send_data(char** buffers[j], uint32_t ind[], uint32_t sizes[j], uint8_t sensors[]);
+void send_data(char** buffers[j], uint32_t ind[], uint32_t sizes[j], uint8_t* sensors);
 {
     int j;
-    for(j=0;j<total_sensors;j++)
-    {
-        printf(" enviant buffer %d\r\n",j);
-        
-        // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
-        int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
-
-        if(ok==JSON_COMM_ERROR)
+    for(j=0;j<TOTAL_SENSORS;j++)
+    {   
+        if(sensors[i]!=0)
         {
-            printf("wismart is not connected\r\n");
-        }
-        else if( ok==JSON_OTHER_ERROR){
-            printf("some error ocurred\r\n");
-        }
-        else if(ok ==JSON_POST_OK){
-            printf(" send OK \r\n");
+            printf(" enviant buffer %d\r\n",j);
+            
+            // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
+            int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
+
+            if(ok==JSON_COMM_ERROR)
+            {
+                printf("wismart is not connected\r\n");
+            }
+            else if( ok==JSON_OTHER_ERROR){
+                printf("some error ocurred\r\n");
+            }
+            else if(ok ==JSON_POST_OK){
+                printf(" send OK \r\n");
+            }
         }
     }
 }
  
-void put_buffers(char** buffers,uint32_t ind[],uint32_t sizes[],char** cooked){
+void put_buffers(char** buffers,uint32_t ind[],uint32_t sizes[],char** cooked, uint8_t* sensors){
     int i;
-    for(i=0;i<total_sensors;i++){
-        put_message(cooked[i], buffers[i] ,&ind[i],&sizes[i]);
-        chHeapFree(cooked[i]);
+    for(i=0;i<TOTAL_SENSORS;i++){
+        if(sensors[i]!=0){
+            put_message(cooked[i], buffers[i] ,&ind[i],&sizes[i]);
+            chHeapFree(cooked[i]);
+        }
     }
  
 }
-char** timestamp_datas(char* value[],unsigned long timestamp){
+char** timestamp_datas(char* value[],unsigned long timestamp, uint8_t* sensors){
  
     char** cooked_data;
     Date t=getDate(timestamp);
     int i;
-    for(i=0;i<total_sensors;i++){
-        cooked_data[i]=timestamp_data(value[i], t);
-        chHeapFree(value[i]);
+    for(i=0;i<TOTAL_SENSORS;i++){
+        if(sensors[i]!=0){
+            cooked_data[i]=timestamp_data(value[i], t);
+            chHeapFree(value[i]);
+        }
     }
     return cooked_data;
 }
  
-void sensor_scan(){
-    I2C_scan(sensors);
+void first_sens(uint8_t* sensors){
     int i;
-    for(i=0;i<TOTAL_SENSORS;i++){
+    for(i=0;i<TOTAL_SENSORS:i++){
         if(sensors[i]!=0){
-            total_sensors++;
+            first_sensor=i;
+            break;
         }
     }
 }
@@ -151,10 +158,8 @@ int main(void)
  
     //Escanea los sensores -> retorna un vector con las direcciones en cada posición del vector, si la posición del vector retorna un cero -> no existe el sensor
     uint8_t sensors[TOTAL_SENSORS];
-    sensor_scan();
-    char* valueSensors[total_sensors];
+    char* valueSensors[TOTAL_SENSORS];
     I2C_scan(sensors);
-
     //conectar wifi
     //unsigned int time = getNTPTime();
     unsigned int time = getSecsSince1900();
@@ -231,7 +236,7 @@ int main(void)
             printf("--------------hard limit-------------\r\n");
  
             // fem servir 085 de prova, però haurem de fer servir sensor_id[0]
-            while( send(buffers[0],&ind[0],&sizes[0], mod.ID, sensors[j]) != JSON_POST_OK )
+            while( send(buffers[first_sensor],&ind[first_sensor],&sizes[first_sensor], mod.ID, sensors[first_sensor]) != JSON_POST_OK )
             {
                 // El servidor no ens sap dir si tenim permisos o no sense registrar una mostra.
                 // Intentem enviar un buffer sencer, a veure si ja podem buidar.
@@ -241,22 +246,24 @@ int main(void)
                 chThdSleepMilliseconds(HARD_LIMIT_WAIT_TIME);
             }
             int j;
-            for(j=1;j<total_sensors;j++)
-            {
-                printf(" enviant buffer %d\r\n",j);
-                
-                // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
-                int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
-                if(ok==JSON_COMM_ERROR)
-                {
-                    printf("wismart is not connected\r\n");
-                }
-                else if( ok==JSON_OTHER_ERROR){
-                    printf("some error ocurred\r\n");
-                }
-                else if(ok ==JSON_POST_OK){
-                    printf(" send OK \r\n");
+            for(j=1;j<TOTAL_SENSORS;j++)
+            {   
+                if(sensors[j]!=0){   
+                    printf(" enviant buffer %d\r\n",j);
+                    // fem servir 085 de prova, però haurem de fer servir sensor_id[j]
+                    int ok=send(buffers[j],&ind[j],&sizes[j], mod.ID, sensors[j]);
+                    if(ok==JSON_COMM_ERROR)
+                    {
+                        printf("wismart is not connected\r\n");
+                    }
+                    else if( ok==JSON_OTHER_ERROR){
+                        printf("some error ocurred\r\n");
+                    }
+                    else if(ok ==JSON_POST_OK){
+                        printf(" send OK \r\n");
+                    } 
                 }
+                
             }
         }
         time += getElapsedTime(delay);