| | |
| | | shm_socket_type_t socket_type; |
| | | // 本地port |
| | | int port; |
| | | bool force_bind; |
| | | shm_connection_status_t status; |
| | | SHMQueue<shm_msg_t> *queue; |
| | | SHMQueue<shm_msg_t> *remoteQueue; |
| | |
| | | |
| | | int shm_socket_bind(shm_socket_t * socket, int port) ; |
| | | |
| | | int shm_socket_force_bind(shm_socket_t * socket, int port) ; |
| | | |
| | | |
| | | int shm_listen(shm_socket_t * socket) ; |
| | | |
| | | shm_socket_t* shm_accept(shm_socket_t* socket); |
| | |
| | | |
| | | int shm_recv(shm_socket_t * socket, void **buf, int *size) ; |
| | | |
| | | int shm_sendto(shm_socket_t *socket, const void *buf, const int size, const int port); |
| | | int shm_sendto(shm_socket_t *socket, const void *buf, const int size, const int port, const struct timespec * timeout = NULL); |
| | | |
| | | int shm_recvfrom(shm_socket_t *socket, void **buf, int *size, int *port); |
| | | |