three 信号量

wangzhengquan

2020-12-22 28f9f739fad7944f64f7df2b8af046f57d50eb8b

 test_net_socket/test_net_mod_socket.c

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

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);
      shm_mm_wrapper_destroy();
      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");
   }
@@ -432,6 +457,9 @@

  }

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

}