wangzhengquan
2020-07-23 46963c736e76cc0e23e361d7a59bbf95da3e8419
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的队列提示错误并退出