Ignore:
Timestamp:
08/31/21 16:15:03 (5 months ago)
Author:
Sanahuja Guillaume
Message:

update buffering

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/lib/FlairCore/src/unexported/ui_com.h

    r440 r441  
    4343  ssize_t Receive(char *buf, ssize_t buf_size);
    4444  void AddSendData(const flair::gui::SendData *obj);
    45   void UpdateSendData(const flair::gui::SendData *obj);
     45  void UpdateSendData(const flair::gui::SendData *obj);//must be called with mutex locked
    4646  void RemoveSendData(const flair::gui::SendData *obj);
    4747  void UpdateDataToSendSize(void);
     
    5353  ssize_t send_size;
    5454  char *send_buffer;
    55   std::vector<const flair::gui::SendData *> data_to_send;
    56   std::vector<flair::core::Time> resume_time;
     55  std::vector<const flair::gui::SendData *> datasToSend;
     56  std::vector<flair::core::Time> resumeTimes;
    5757  flair::core::Mutex *send_mutex;
    5858  UDTSOCKET socket_fd;
     
    6262  //private part, called to effectively send to udt
    6363  void SendNRT(char *buf, ssize_t size,int ttl);
    64   void PushDatasToSend(const flair::gui::SendData *data_to_send);
     64  void PushDatasToSend(const flair::gui::SendData *dataToSend);
    6565  typedef struct {
    6666    char* buf;
    67     ssize_t size;
     67    size_t actual_size;
     68    size_t final_size;
    6869    uint16_t period;
    6970    uint16_t nb_buffering;
    7071  } PushedData_t;
    71   std::vector<PushedData_t> PushedDatas;
     72  std::vector<PushedData_t> pushedDatas;
    7273
    7374  static int compressBuffer(char *in, ssize_t in_size, char **out,
Note: See TracChangeset for help on using the changeset viewer.