update

wangzhengquan

2021-01-08 1e29d9ab6047c765c9cab7d79f6baf7e96eea7fd

 src/socket/net_mod_socket_wrapper.cpp

@@ -148,16 +148,16 @@
 */
int  net_mod_socket_sub(void * _socket, void *topic, int size) {
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->sub((char *)topic,  size,  BUS_KEY);
   return sockt->sockt->sub((char *)topic,  size,  SHM_BUS_KEY);
}
// 超时返回。 @sec 秒 ， @nsec 纳秒
int  net_mod_socket_sub_timeout(void * _socket, void *topic, int size, int sec, int nsec){
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->sub_timeout((char *)topic,  size,  BUS_KEY, sec, nsec);
   return sockt->sockt->sub_timeout((char *)topic,  size,  SHM_BUS_KEY, sec, nsec);
}
int  net_mod_socket_sub_nowait(void * _socket, void *topic, int size){
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->sub_nowait((char *)topic,  size,  BUS_KEY);
   return sockt->sockt->sub_nowait((char *)topic,  size,  SHM_BUS_KEY);
}


@@ -169,16 +169,16 @@
 */
int  net_mod_socket_desub(void * _socket, void *topic, int size) {
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->desub((char *)topic,  size,  BUS_KEY);
   return sockt->sockt->desub((char *)topic,  size,  SHM_BUS_KEY);
}
// 超时返回。 @sec 秒 ， @nsec 纳秒
int  net_mod_socket_desub_timeout(void * _socket, void *topic, int size, int sec, int nsec) {
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->desub_timeout((char *)topic,  size,  BUS_KEY, sec, nsec);
   return sockt->sockt->desub_timeout((char *)topic,  size,  SHM_BUS_KEY, sec, nsec);
}
int  net_mod_socket_desub_nowait(void * _socket, void *topic, int size){
   net_mod_socket_t *sockt = (net_mod_socket_t *)_socket;
   return sockt->sockt->desub_nowait((char *)topic,  size,  BUS_KEY);
   return sockt->sockt->desub_nowait((char *)topic,  size,  SHM_BUS_KEY);
}