| | |
| | | |
| | | LockFreeQueue<shm_packet_t> *queue; //self queue |
| | | LockFreeQueue<shm_packet_t> *remoteQueue; // peer queue |
| | | std::map<std::string, shm_packet_t> recvbuf; |
| | | |
| | | std::map<std::string, shm_packet_t> recvbuf; // for uuid |
| | | std::map<int, shm_packet_t> recvbuf2; //for thread local |
| | | |
| | | } shm_socket_t; |
| | | |
| | |
| | | size_t shm_socket_remove_keys(int keys[], size_t length); |
| | | size_t shm_socket_remove_keys_exclude(int keys[], size_t length); |
| | | |
| | | shm_socket_t *shm_open_socket(shm_socket_type_t socket_type); |
| | | shm_socket_t *shm_socket_open(shm_socket_type_t socket_type); |
| | | |
| | | |
| | | int shm_close_socket(shm_socket_t * socket) ; |
| | | int shm_socket_close(shm_socket_t * sockt) ; |
| | | |
| | | int shm_socket_stop(shm_socket_t *sockt); |
| | | int shm_socket_stop(shm_socket_t * sockt); |
| | | |
| | | |
| | | int shm_socket_bind(shm_socket_t * socket, int key) ; |