update

wangzhengquan

2021-02-02 cb85aa8a8d02a3d6dc16e3f32e78da9e70f9c7f5

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


   /**