upate

wangzhengquan

2021-03-12 24678070d451711a03a69ca3a7aa6e695efeff28

upate

 src/socket/shm_socket.cpp

@@ -46,7 +46,7 @@


  if (tmp_ptr == NULL || tmp_ptr == (void *)1  ) {
    queue = new LockFreeQueue<shm_packet_t>(16);
    queue = new LockFreeQueue<shm_packet_t>(1024);
    hashtable_put(hashtable, key, (void *)queue);
    hashtable_unlock(hashtable);
    return queue;
@@ -600,6 +600,10 @@

  sendpak->key = sockt->key;
  rv = remoteQueue->push(*sendpak, timeout, flag);

  if(rv != 0) {
    mm_free(sendpak->buf);
  }
  if(rv == ETIMEDOUT) {
    return EBUS_TIMEOUT;
  }