| | |
| | | |
| | | }; |
| | | |
| | | enum shm_msg_type_t |
| | | enum shm_packet_type_t |
| | | { |
| | | SHM_SOCKET_OPEN = 1, |
| | | SHM_SOCKET_OPEN_REPLY = 2, |
| | |
| | | |
| | | }; |
| | | |
| | | typedef struct shm_msg_t { |
| | | typedef struct shm_packet_t { |
| | | int key; |
| | | shm_msg_type_t type; |
| | | shm_packet_type_t type; |
| | | size_t size; |
| | | void * buf; |
| | | |
| | | } shm_msg_t; |
| | | } shm_packet_t; |
| | | |
| | | |
| | | |
| | |
| | | bool force_bind; |
| | | pthread_mutex_t mutex; |
| | | |
| | | LockFreeQueue<shm_msg_t> *queue; //self queue |
| | | LockFreeQueue<shm_msg_t> *remoteQueue; // peer queue |
| | | // shm_connection_status_t status; |
| | | // LockFreeQueue<shm_msg_t, DM_Allocator> *messageQueue; |
| | | // LockFreeQueue<shm_msg_t, DM_Allocator> *acceptQueue; |
| | | // std::map<int, shm_socket_t* > *clientSocketMap; |
| | | // pthread_t dispatch_thread; |
| | | LockFreeQueue<shm_packet_t> *queue; //self queue |
| | | LockFreeQueue<shm_packet_t> *remoteQueue; // peer queue |
| | | |
| | | |
| | | } shm_socket_t; |
| | | |