update

wangzhengquan

2021-02-03 7910fd0802b3d8d71d5f90af5c93cb6b23ea48d3

update

 src/socket/shm_socket.cpp

@@ -208,6 +208,7 @@
}



// 短连接方式接受
int shm_recvfrom(shm_socket_t *sockt, void **buf, int *size, int *key,  const struct timespec *timeout,  int flag) {
  int rv;
@@ -409,5 +410,6 @@
                    const int send_size, const int send_key, void **recv_buf,
                    int *recv_size,  const struct timespec *timeout,  int flags) {

  return  _shm_sendandrecv_thread_local(socket, send_buf, send_size, send_key,recv_buf, recv_size, timeout,  flags);
  struct timespec tm = {10, 0};
  return  _shm_sendandrecv_thread_local(socket, send_buf, send_size, send_key,recv_buf, recv_size, &tm, flags);
}