Changeset 441 in flair-src for trunk/lib/FlairCore/src/unexported

Timestamp:

08/31/21 16:15:03 (3 years ago)

Author:

Sanahuja Guillaume

Message:

update buffering

File:

• trunk/lib/FlairCore/src/unexported/ui_com.h (modified) (3 diffs)

trunk/lib/FlairCore/src/unexported/ui_com.h

@@ -43 +43 @@
   ssize_t Receive(char *buf, ssize_t buf_size);
   void AddSendData(const flair::gui::SendData *obj);
-  void UpdateSendData(const flair::gui::SendData *obj);
+  void UpdateSendData(const flair::gui::SendData *obj);//must be called with mutex locked
   void RemoveSendData(const flair::gui::SendData *obj);
   void UpdateDataToSendSize(void);
@@ -53 +53 @@
   ssize_t send_size;
   char *send_buffer;
-  std::vector<const flair::gui::SendData *> data_to_send;
-  std::vector<flair::core::Time> resume_time;
+  std::vector<const flair::gui::SendData *> datasToSend;
+  std::vector<flair::core::Time> resumeTimes;
   flair::core::Mutex *send_mutex;
   UDTSOCKET socket_fd;
@@ -62 +62 @@
   //private part, called to effectively send to udt
   void SendNRT(char *buf, ssize_t size,int ttl);
-  void PushDatasToSend(const flair::gui::SendData *data_to_send);
+  void PushDatasToSend(const flair::gui::SendData *dataToSend);
   typedef struct {
     char* buf;
-    ssize_t size;
+    size_t actual_size;
+    size_t final_size;
     uint16_t period;
     uint16_t nb_buffering;
   } PushedData_t;
-  std::vector<PushedData_t> PushedDatas;
+  std::vector<PushedData_t> pushedDatas;
 
   static int compressBuffer(char *in, ssize_t in_size, char **out,