wangzhengquan
2020-10-19 af85260254bacac40a68d4f5f61950523beb3a27
src/socket/shm_mod_socket.h
@@ -14,7 +14,7 @@
#define TOPIC_LIDENTIFIER "{"
#define TOPIC_RIDENTIFIER "}"
static Logger logger = LoggerFactory::getLogger();
static Logger *logger = LoggerFactory::getLogger();
#define BUS_MAP_KEY 1
//typedef std::basic_string<char, std::char_traits<char>, SHM_STL_Allocator<char> > SHMString;
typedef std::set<int,  std::less<int>, SHM_STL_Allocator<int> > SHMKeySet;
@@ -62,7 +62,6 @@
   ShmModSocket();
   ~ShmModSocket();
    
   /**
    * 绑定端口到socket, 如果不绑定则系统自动分配一个
    * @return 0 成功, 其他值 失败的错误码
@@ -105,6 +104,11 @@
   int sendandrecv_timeout(const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size,  struct timespec *timeout) ;
   int sendandrecv_nowait(const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) ;
   int sendandrecv_unsafe(const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) ;
   // 超时返回。 @sec 秒 , @nsec 纳秒
   int sendandrecv_unsafe_timeout(const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size,  struct timespec *timeout) ;
   int sendandrecv_unsafe_nowait(const void *send_buf, const int send_size, const int port, void **recv_buf, int *recv_size) ;
   /**
    * 启动bus