src/socket/shm_socket.c
@@ -302,6 +302,19 @@ } } int shm_sendandrecv(shm_socket_t *socket, const void *send_buf, const int send_size, const int send_port, void **recv_buf, int *recv_size) { int recv_port; int rv; shm_socket_t *tmp_socket = shm_open_socket(SHM_SOCKET_DGRAM); if (shm_sendto(tmp_socket, send_buf, send_size, send_port) == 0) { rv = shm_recvfrom(tmp_socket, recv_buf, recv_size, &recv_port); shm_close_socket(tmp_socket); return rv; } return -1; } /** * 绑定key到队列,但是并不会创建队列。如果没有对应指定key的队列提示错误并退出