fujuntang
2021-11-10 c479ef57baaaa28964fc3ec8d80ff99dffa7d49f
src/socket/bus_server_socket.h
@@ -8,6 +8,7 @@
#include "sem_util.h"
#include "logger_factory.h"
#include "key_def.h"
#include "msg_mgr.h"
#include "socket_def.h"
#include <set>
@@ -23,7 +24,7 @@
  int data;
  int data_fix;
  int count;
  _LinkNode *next; 
} LinkNode;
@@ -62,6 +63,7 @@
  // pthread_t recv_thread;
  // <主题, 订阅者>
   SHMTopicSubMap *topic_sub_map;
  recvbuf_data recvBuf_data;
private:
   int  destroy();
@@ -121,7 +123,9 @@
    */
   int get_key() ;
  void _data_remove(int val1, int val2);
  void _data_remove(int val);
  void buf_data_set(int data, int val);
  void buf_data_remove(int data);
};