update

wangzhengquan

2020-12-21 8b0a8c644f19e97606dfb06a865f56dbad15f95e

 test_net_socket/test_net_mod_socket.c

@@ -55,9 +55,35 @@
}


void *bus_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) {
      bus_server_socket_wrapper_close(sockt);
      break;
    } else {
      printf("Invalide action\n");
    }
  }
  
}



void start_bus_server() {
  printf("Start bus server\n");
  void * server_socket = bus_server_socket_wrapper_open();
  pthread_t tid;
  // 创建一个线程,可以关闭bus
  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);
@@ -177,11 +203,6 @@

  
}


 



void *_run_sendandrecv_(void *arg) {
  Targ *targ = (Targ *)arg;
@@ -349,6 +370,10 @@

 // port = atoi(argv[2]);
    
  if(opt.fun == NULL) {
    usage(argv[0]);
    exit(1);
  }

   if (strcmp("start_net_proxy", opt.fun) == 0 ) {
    if(opt.port == 0) {
@@ -359,10 +384,7 @@
    
  }
  else if (strcmp("start_bus_server", opt.fun) == 0) {
    if(opt.key == 0) {
      usage(argv[0]);
      exit(1);
    }
     
    start_bus_server();
  }
  else if (strcmp("start_reply", opt.fun) == 0) {