src/socket/shm_socket.h
@@ -49,10 +49,10 @@ // 本地key int key; bool force_bind; int mutex; shm_connection_status_t status; SHMQueue<shm_msg_t> *queue; SHMQueue<shm_msg_t> *remoteQueue; pthread_mutex_t mutex; shm_connection_status_t status; SHMQueue<shm_msg_t> *queue; //self queue SHMQueue<shm_msg_t> *remoteQueue; // peer queue LockFreeQueue<shm_msg_t, DM_Allocator> *messageQueue; LockFreeQueue<shm_msg_t, DM_Allocator> *acceptQueue; std::map<int, shm_socket_t* > *clientSocketMap;