wangzhengquan
2020-07-20 37989e0300c20cd65a4d4a3c49eeaea2122ddf9e
queue/shm_socket.c
@@ -112,10 +112,10 @@
   socket->queue = new SHMQueue<shm_msg_t>(socket->port, 16);
   socket->acceptQueue = new LockFreeQueue<shm_msg_t, DM_Allocator>(16);
   socket->clientSocketMap = new std::map<int, shm_socket_t* >;
   socket->status = SHM_CONN_LISTEN;
   pthread_create(&(socket->dispatch_thread), NULL, _server_run_msg_rev , (void *)socket);
   socket->status = SHM_CONN_LISTEN;
   return 0;
}