Changeset 443 in flair-src for trunk/tools/FlairGCS/src/ConnectionLayout.cpp

Timestamp:

Sep 9, 2021, 5:06:34 PM (3 years ago)

Author:

Sanahuja Guillaume

Message:

update buffering (gcs part)

File:

• trunk/tools/FlairGCS/src/ConnectionLayout.cpp (modified) (2 diffs)

trunk/tools/FlairGCS/src/ConnectionLayout.cpp

@@ -48 +48 @@
   }
   case DATA_BIG_ENDIAN: {
-    // for(int i=0;i<size;i++) fprintf(stderr,"%x ",buf[i]);
-    // fprintf(stderr,"\n");
     uint16_t period;
     memcpy(&period, &buf[1], sizeof(uint16_t));
     period = qFromBigEndian(period);
-    drawDatas(&buf[3], size - 3, period, true);
+    drawDatas(&buf[3], size - 3, period, 1,true);
     break;
   }
   case DATA_LITTLE_ENDIAN: {
-    // for(int i=0;i<size;i++) fprintf(stderr,"%x ",buf[i]);
-    // fprintf(stderr,"\n");
     uint16_t period;
     memcpy(&period, &buf[1], sizeof(uint16_t));
-    // fprintf(stderr,"recu %i period %i\n",size,period);
-    drawDatas(&buf[3], size - 3, period);
+    drawDatas(&buf[3], size - 3, period,1);
+    break;
+  }
+  case MULTIPLE_DATA_LITTLE_ENDIAN: {
+    uint16_t period;
+    uint16_t nb_buffering;
+    memcpy(&period, buf+sizeof(char), sizeof(uint16_t));
+    memcpy(&nb_buffering,buf+sizeof(char)+sizeof(uint16_t), sizeof(uint16_t));
+    fprintf(stderr,"recu %i, period %i, nb_buff %i\n",size,period,nb_buffering);
+    drawDatas(buf+sizeof(char)+sizeof(uint16_t)+sizeof(uint16_t), size - sizeof(char)+sizeof(uint16_t)+sizeof(uint16_t), period, nb_buffering);
     break;
   }
@@ -111 +115 @@
 QString ConnectionLayout::getName() { return name; }
 
-void ConnectionLayout::drawDatas(char *buf, int buf_size, uint16_t period,
-                                 bool big_endian) {
-  for (int i = 0; i < dataremotes.count(); i++) {
-    dataremotes.at(i)->BufEvent(&buf, &buf_size, period, big_endian);
-  }
+void ConnectionLayout::drawDatas(char *buf, int buf_size, uint16_t period,uint16_t nb_buffering, bool big_endian) {
+    for (int i = 0; i < nb_buffering; i++) {
+        for (int j = 0; j < dataremotes.count(); j++) {
+            dataremotes.at(j)->BufEvent(&buf, &buf_size, period, nb_buffering, big_endian);
+        }
+    }
 }