| | |
| | | SHM_MSG_NOWAIT = 2 |
| | | }; |
| | | |
| | | |
| | | |
| | | enum shm_socket_error_type_t { |
| | | SHM_SOCKET_ECONNFAILED = 1, |
| | | SHM_SOCKET_ETIMEOUT = 2 |
| | | }; |
| | | |
| | | enum shm_connection_status_t { |
| | | SHM_CONN_CLOSED=1, |
| | | SHM_CONN_LISTEN=2, |
| | |
| | | // 本地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; |