update

wangzhengquan

2021-01-25 c46be6db32872bfd7c4010b43526b5e6bc0fa6a5

 src/socket/shm_mod_socket.h

@@ -31,10 +31,10 @@

private:
    
   int _sub_( char *topic, int size, int key, struct timespec *timeout, int flags);
   int _pub_( char *topic, int topic_size, void *content, int content_size, int key, struct timespec *timeout, int flags);
   int _sub_( char *topic, int size, int key, const struct timespec *timeouts,  int flags);
   int _pub_( char *topic, int topic_size, void *content, int content_size, int key, const struct timespec *timeouts,  int flags);

   int  _desub_( char *topic, int size, int key, struct timespec *timeout, int flags);
   int  _desub_( char *topic, int size, int key, const struct timespec *timeouts, int flags);


   static int get_bus_sendbuf(bus_head_t &request_head, void *topic_buf, int topic_size, void *content_buf, int content_size, void **retbuf);
@@ -80,7 +80,7 @@
   */
   int recvfrom(void **buf, int *size, int *key);
   // 接受信息超时返回。 @sec 秒 ， @nsec 纳秒
   int recvfrom_timeout(void **buf, int *size, int *key,  struct timespec *timeout);
   int recvfrom_timeout(void **buf, int *size, int *key,  const struct timespec *timeout);
   int recvfrom_nowait(void **buf, int *size, int *key);

   /**
@@ -90,13 +90,13 @@
   */
   int sendandrecv(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size) ;
   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int sendandrecv_timeout(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size,  struct timespec *timeout) ;
   int sendandrecv_timeout(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size, const struct timespec *timeout) ;
   int sendandrecv_nowait(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size) ;


   int sendandrecv_unsafe(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size) ;
   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int sendandrecv_unsafe_timeout(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size,  struct timespec *timeout) ;
   int sendandrecv_unsafe_timeout(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size, const  struct timespec *timeout) ;
   int sendandrecv_unsafe_nowait(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size) ;

   /**
@@ -107,7 +107,7 @@
    */
   int  sub(char *topic, int size, int key);
   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int  sub_timeout(char *topic, int size, int key,  struct timespec *timeout);
   int  sub_timeout(char *topic, int size, int key,  const struct timespec *timeout);
   int  sub_nowait(char *topic, int size, int key);


@@ -119,7 +119,7 @@
    */
   int desub( char *topic, int size, int key);
   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int desub_timeout(char *topic, int size, int key, struct timespec *timeout);
   int desub_timeout(char *topic, int size, int key, const struct timespec *timeout);
   int desub_nowait(char *topic, int size, int key) ;

   /**
@@ -130,7 +130,7 @@
    */
   int  pub(char *topic, int topic_size, void *content, int content_size, int key);
   //  超时返回。 @sec 秒 ， @nsec 纳秒
   int  pub_timeout(char *topic, int topic_size, void *content, int content_size, int key,  struct timespec *timeout);
   int  pub_timeout(char *topic, int topic_size, void *content, int content_size, int key, const  struct timespec *timeout);
   int  pub_nowait(char *topic, int topic_size, void *content, int content_size, int key);