fix from 3.1 first commit

fujuntang

2021-08-11 68d23225a38a35f1325eb39fa4ed5a005d5de473

 src/socket/shm_mod_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"
@@ -11,7 +11,7 @@
#include <set>
#include "socket_def.h"

#define BUS_HEAD_SIZE (64 + 2 * sizeof(uint32_t))
#define BUS_HEAD_SIZE sizeof(bus_head_t)
class BusServerSocket;

struct bus_head_t
@@ -33,10 +33,11 @@
    
    

   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);
   // static size_t remove_keys(int keys[], size_t length);
   // static size_t remove_keys_exclude(int keys[], size_t length);

  // bus header 编码为网络传输的字节
  static void * encode_bus_head(bus_head_t & bushead);
@@ -47,6 +48,7 @@
   ShmModSocket();
   ~ShmModSocket();
    
   int stop();
   /**
    * 绑定端口到socket, 如果不绑定则系统自动分配一个
    * @return 0 成功， 其他值 失败的错误码
@@ -87,9 +89,10 @@
    const struct timespec *timeout = NULL, int flag = 0);


   // 超时返回。 @sec 秒 ， @nsec 纳秒
   int sendandrecv_unsafe(const void *send_buf, const int send_size, const int key, void **recv_buf, int *recv_size,
    const  struct timespec *timeout = NULL, int flag = 0) ;
   /**
    * 
    */
  int recvandsend( recvandsend_callback_fn callback, const struct timespec *timeout = NULL , int flag = 0, void * user_data = NULL);

   /**
    * 订阅指定主题
@@ -98,7 +101,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 +111,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 +120,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);


   /**