test_net_socket/test_net_mod_socket.cpp
@@ -75,6 +75,11 @@ } } void start_resycle() { shm_mm_wrapper_start_resycle(); } // 打印接受到的订阅消息 void *print_sub_msg(void *sockt) { pthread_detach(pthread_self()); @@ -602,6 +607,9 @@ test_net_pub(opt.publist); } else if (strcmp("start_resycle", opt.fun) == 0) { start_resycle(); } else { usage(argv[0]); @@ -610,7 +618,7 @@ } printf("==========end========\n"); shm_mm_wrapper_destroy(); // shm_mm_wrapper_destroy(); }