restructure

wangzhengquan

2021-01-21 2c65db46500207f8445aa4baa53bfbb6602e0e18

 src/socket/shm_socket.cpp

@@ -383,10 +383,8 @@

  if (rv == 0) {
    // printf("shm_sendto push after\n");
    delete remoteQueue;
    return 0;
  } else {
    delete remoteQueue;
    mm_free(dest.buf);
    if(rv > EBUS_BASE) {
      // bus_errno = EBUS_TIMEOUT;
@@ -725,10 +723,7 @@
    socket->queue = NULL;
  }

  if (socket->remoteQueue != NULL) {
    delete socket->remoteQueue;
    socket->remoteQueue = NULL;
  }
  

  if (socket->messageQueue != NULL) {
    delete socket->messageQueue;
@@ -747,7 +742,6 @@
      client_socket = iter->second;

      client_socket->remoteQueue->push_timeout(close_msg, &timeout);
      delete client_socket->remoteQueue;
      client_socket->remoteQueue = NULL;

      delete client_socket->messageQueue;