From 9b9220321e647b381a999f67cad12345334b2cbe Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期四, 06 八月 2020 13:06:23 +0800 Subject: [PATCH] update --- src/socket/include/dmod_socket.h | 11 ++++++++++- 1 files changed, 10 insertions(+), 1 deletions(-) diff --git a/src/socket/include/dmod_socket.h b/src/socket/include/dmod_socket.h index 0998b1d..8eb0fbf 100644 --- a/src/socket/include/dmod_socket.h +++ b/src/socket/include/dmod_socket.h @@ -38,6 +38,7 @@ // pthread_t recv_thread; // <涓婚锛� 璁㈤槄鑰�> SHMTopicSubMap *topic_sub_map; + std::set<int> *bus_set; private: inline int _recvfrom_(void **buf, int *size, int *port, struct timespec *timeout, int flags); @@ -49,8 +50,14 @@ int _pub_( void *topic, int topic_size, void *content, int content_size, int port, struct timespec *timeout, int flags); void _proxy_desub( char *topic, int port); + void _proxy_desub_all(int port); int _desub_( void *topic, int size, int port, struct timespec *timeout, int flags); - static void foreach_subscripters(std::function<void(SHMKeySet *, SHMKeySet::iterator)> cb) ; + + static void foreach_subscripters(std::function<void(SHMKeySet *, SHMKeySet::iterator)> cb); + static bool include_in_keys(int key, int keys[], size_t length); + static size_t remove_subscripters(int keys[], size_t length) ; +public: + static size_t remove_keys(int keys[], size_t length); public: DModSocket(); ~DModSocket(); @@ -145,6 +152,8 @@ * 鑾峰彇soket绔彛鍙� */ int get_port() ; + + }; #endif \ No newline at end of file -- Gitblit v1.8.0