三个没有回收的信号

wangzhengquan

2020-12-22 b90ba316b54db321d3e8aaac7df93b46d80b9d9c

 test_net_socket/test_net_mod_socket.c

@@ -33,9 +33,33 @@

void * client;

void *proxy_server_handler(void *sockt) {
  pthread_detach(pthread_self());
  
  char action[512];
  while ( true) {
    printf("Input action: Close?\n");
    if(scanf("%s",action) < 1) {
      printf("Invalide action\n");
      continue;
    }

    if(strcmp(action, "close") == 0) {
      net_mod_server_socket_close(sockt);
      break;
    } else {
      printf("Invalide action\n");
    }
  }  
}

void start_net_proxy(int port) {
  pthread_t tid;
  printf("Start net proxy\n");
   void *serverSocket  = net_mod_server_socket_open(port);

   // 创建一个线程,可以关闭server
  pthread_create(&tid, NULL, proxy_server_handler, serverSocket);
   if(net_mod_server_socket_start(serverSocket) != 0) {
      err_exit(errno, "net_mod_server_socket_start");
   }
@@ -83,7 +107,7 @@
  void * server_socket = bus_server_socket_wrapper_open();
  pthread_t tid;
  // 创建一个线程,可以关闭bus
  pthread_create(&tid, NULL, bus_handler, server_socket);
  // pthread_create(&tid, NULL, bus_handler, server_socket);
  if(bus_server_socket_wrapper_start_bus(server_socket) != 0) {
    printf("start bus failed\n");
    exit(1);
@@ -432,6 +456,9 @@

  }

  printf("==========end========\n");
  shm_mm_wrapper_destroy();

}