| | |
| | | |
| | | SHMQueue<shm_msg_t> *_attach_remote_queue(int port); |
| | | |
| | | |
| | | |
| | | size_t shm_socket_remove_keys(int keys[], size_t length) { |
| | | return SHMQueue<shm_msg_t>::remove_queues(keys, length); |
| | | } |
| | | |
| | | shm_socket_t *shm_open_socket(shm_socket_type_t socket_type) { |
| | | shm_socket_t *socket = (shm_socket_t *)calloc(1, sizeof(shm_socket_t)); |
| | | socket->socket_type = socket_type; |
| | |
| | | SHMQueue<shm_msg_t> *remoteQueue; |
| | | if ((remoteQueue = _attach_remote_queue(port)) == NULL) { |
| | | err_msg(0, "shm_sendto failed, the other end has been closed, or has not been opened!"); |
| | | return SHM_SOCKET_CONN_FAILED; |
| | | return SHM_SOCKET_ECONNFAILED; |
| | | } |
| | | |
| | | shm_msg_t dest; |