pb.go MsgQueryProcReply add subLocalTopics and subNetTopics

liuxiaolong

2022-01-05 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6

 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);

};