wangzhengquan
2021-01-26 0cb4f2b1acb16c1ee1bd86a40116300ea2e2cdaa
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) {