From f52f2c2828047c2f30d30fc1fe2b54d8db146d49 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期四, 25 二月 2021 15:56:35 +0800 Subject: [PATCH] update --- src/socket/bus_server_socket.h | 11 ++++++----- 1 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/socket/bus_server_socket.h b/src/socket/bus_server_socket.h index 1a83d0e..956271b 100644 --- a/src/socket/bus_server_socket.h +++ b/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, size_t head_len, 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 _proxy_pub( char *topic, void *buf, size_t size, int key); + 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); -- Gitblit v1.8.0