pub_sub finished

wangzhengquan

2020-07-17 5e3e6719f7d7922decdc16d2313baf2e94210750

 queue/shm_socket.c

@@ -308,6 +308,10 @@

int shm_send(shm_socket_t *socket, void *buf, int size) {
   // hashtable_t *hashtable = mm_get_hashtable();
   if(socket->remoteQueue == NULL) {
      err_msg(errno, "当前客户端无连接!");
      return -1;
   }
   shm_msg_t dest;
   dest.type=SHM_COMMON_MSG;
   dest.port = socket->port;