三个没有回收的信号

wangzhengquan

2020-12-22 b90ba316b54db321d3e8aaac7df93b46d80b9d9c

 src/socket/bus_server_socket_wrapper.c

@@ -8,7 +8,7 @@
 */
void * bus_server_socket_wrapper_open() {
   
   NetModSocket *sockt = new NetModSocket;
   BusServerSocket *sockt = new BusServerSocket;
   return (void *)sockt;
}

@@ -16,7 +16,8 @@
 * 关闭
 */
void bus_server_socket_wrapper_close(void *_socket) {
   NetModSocket *sockt = (NetModSocket *)_socket;
   printf("bus_server_socket_wrapper_close\n");
   BusServerSocket *sockt = (BusServerSocket *)_socket;
   delete sockt;
}

@@ -27,10 +28,10 @@
*/
int  bus_server_socket_wrapper_start_bus(void * _socket) {
   int ret;
   NetModSocket *sockt = (NetModSocket *)_socket;
   BusServerSocket *sockt = (BusServerSocket *)_socket;

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