sycronized

wangzhengquan

2020-07-23 6da3e92dab82554db8492d2bd7981ecd9ef3fd65

 src/socket/shm_socket.c

@@ -287,7 +287,7 @@
   }

   shm_msg_t src;
//logger.debug("shm_recvfrom pop before");
// printf("shm_recvfrom pop before");
   if (socket->queue->pop(src)) {
      void * _buf = malloc(src.size);
      memcpy(_buf, src.buf, src.size);
@@ -295,7 +295,7 @@
      *size = src.size;
      *port = src.port;
      mm_free(src.buf);
//logger.debug("shm_recvfrom pop after");
// printf("shm_recvfrom pop after");
      return 0;
   } else {
      return -1;
@@ -327,7 +327,7 @@
   if( iter !=  socket->clientSocketMap->end() ) {
      socket->clientSocketMap->erase(iter);
   }
   //free((void *)client_socket);
   free((void *)client_socket);

}