update

wangzhengquan

2021-01-27 251bbc8b0ebd9a91d34f81186d9284f6e669b4db

 src/socket/shm_socket.cpp

@@ -384,9 +384,6 @@
  }
}

int shm_recvfrom2(shm_socket_t *socket, void **buf, int *size, int *key,  const struct timespec *timeout,  int flag) {
  return 501;
}

// 短连接方式接受
int shm_recvfrom(shm_socket_t *sokt, void **buf, int *size, int *key,  const struct timespec *timeout,  int flag) {
@@ -423,9 +420,7 @@

  shm_msg_t src;
 
printf ("====== before ======\n");
  rv = sokt->queue->pop(src, timeout, flag);
printf ("====== after ======\n %d", rv);

  if (rv == 0) {
    if(buf != NULL) {