update

wangzhengquan

2021-03-01 98d6460918ee7918fa591e12ed0698b14e539c9d

 src/socket/shm_socket.cpp

@@ -52,7 +52,7 @@
    return queue;
  } else if(force) {
    hashtable_unlock(hashtable);
    return (LockFreeQueue<shm_packet_t> *) queue;
    return (LockFreeQueue<shm_packet_t> *) tmp_ptr;
  }
  
  hashtable_unlock(hashtable);
@@ -292,7 +292,7 @@
{
  int rv;

  logger->debug("%d destroy threadlocal socket\n", pthread_self()); 
  logger->debug("%lu destroy threadlocal socket\n", pthread_self()); 

  if(tmp_socket == NULL)
    return;
@@ -325,7 +325,7 @@
                    const int send_size, const int key, void **recv_buf,
                    int *recv_size,  const struct timespec *timeout,  int flags) {

  int rv, tryn = 6;
  int rv, tryn = 16;
  shm_packet_t sendpak;
  shm_packet_t recvpak;
  std::map<std::string, shm_packet_t>::iterator recvbufIter;