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]);