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; }