wangzhengquan
2021-02-03 f1ae0552e2d50ce6f87a0bad2f31b8e2ec617bb7
src/socket/shm_mod_socket.h
@@ -33,7 +33,7 @@
    
    
   static int get_bus_sendbuf(bus_head_t &request_head, void *topic_buf, int topic_size, void *content_buf, int content_size, void **retbuf);
   static int get_bus_sendbuf(bus_head_t &request_head, const void *topic_buf, int topic_size, const void *content_buf, int content_size, void **retbuf);
public:
   static size_t remove_keys(int keys[], size_t length);
@@ -98,7 +98,7 @@
    * @key 总线端口
    * @flag BUS_TIMEOUT_FLAG  BUS_NOWAIT_FLAG
    */
   int  sub(char *topic, int size, int key,  const struct timespec *timeout = NULL, int flag = 0);
   int  sub(const char *topic, int size, int key,  const struct timespec *timeout = NULL, int flag = 0);
    /**
@@ -108,7 +108,7 @@
    * @key 总线端口
    * @flag BUS_TIMEOUT_FLAG  BUS_NOWAIT_FLAG
    */
   int desub(char *topic, int size, int key, const struct timespec *timeout = NULL, int flag = 0);
   int desub(const char *topic, int size, int key, const struct timespec *timeout = NULL, int flag = 0);
   /**
    * 发布主题
@@ -117,7 +117,7 @@
    * @key 总线端口
    * @flag BUS_TIMEOUT_FLAG  BUS_NOWAIT_FLAG
    */
   int  pub(char *topic, int topic_size, void *content, int content_size, int key, const  struct timespec *timeout = NULL, int flag = 0);
   int  pub(const char *topic, int topic_size, const void *content, int content_size, int key, const  struct timespec *timeout = NULL, int flag = 0);
   /**