update

wangzhengquan

2021-02-25 f52f2c2828047c2f30d30fc1fe2b54d8db146d49

 src/socket/bus_server_socket.h

@@ -3,7 +3,7 @@
#include "usg_common.h"
#include "shm_socket.h"
#include "shm_allocator.h"
#include "mem_pool.h"
#include "shm_mm.h"
#include "hashtable.h"
#include "sem_util.h"
#include "logger_factory.h"
@@ -27,11 +27,12 @@
   SHMTopicSubMap *topic_sub_map;

private:
   int  destroy();
   void _proxy_sub( char *topic, int key);
   void _proxy_pub( char *topic, void *buf, size_t size, int key);
   void *run_pubsub_proxy();
   int parse_pubsub_topic(char *str, size_t size, char **_action, char **_topic, size_t *head_len );
 
   void *_run_proxy_();
   // int parse_pubsub_topic(char *str, size_t size, char **_action, char **_topic, size_t *head_len );
  	
   void _proxy_desub( char *topic, int key);
   void _proxy_desub_all(int key);