re-structure the communication work flow.

Fu Juntang

2021-08-30 b861de29176891657cc96631ddbfb4ea9e114a42

 src/socket/bus_server_socket_wrapper.cpp

@@ -7,7 +7,6 @@
 * 创建
 */
void * bus_server_socket_wrapper_open() {
   logger->debug("===bus_server_socket_wrapper_open\n");
   BusServerSocket *sockt = new BusServerSocket;
   return (void *)sockt;
}
@@ -19,7 +18,6 @@

   BusServerSocket *sockt = (BusServerSocket *)_socket;
   delete sockt;
   logger->debug("===bus_server_socket_wrapper_close\n");
}

int bus_server_socket_wrapper_stop(void *_socket) {
@@ -35,7 +33,7 @@
   int ret;
   BusServerSocket *sockt = (BusServerSocket *)_socket;

   if( (ret = sockt->force_bind(SHM_BUS_KEY)) == 0) {
   if( (ret = sockt->bind(SHM_BUS_KEY)) == 0) {
      return sockt->start();
   } else {
      logger->error("start bus failed");