From 27d8bc7cad4a8f68c2da3efbb77f45ec70ae40e6 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期三, 05 一月 2022 14:11:39 +0800
Subject: [PATCH] pb.go MsgQueryProcReply add subLocalTopics and subNetTopics
---
test_net_socket/test_bus_stop.cpp | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/test_net_socket/test_bus_stop.cpp b/test_net_socket/test_bus_stop.cpp
index a1c20ec..d40f0d7 100644
--- a/test_net_socket/test_bus_stop.cpp
+++ b/test_net_socket/test_bus_stop.cpp
@@ -2,14 +2,14 @@
#include "net_mod_socket_wrapper.h"
#include "bus_server_socket_wrapper.h"
-#include "shm_mm_wraper.h"
+#include "shm_mm_wrapper.h"
#include "usg_common.h"
#include <getopt.h>
static void * server_sockt;
-static void sigint_handler(int sig) {
- bus_server_socket_wrapper_close(server_sockt);
+static void stop_bus_handler(int sig) {
+ bus_server_socket_wrapper_stop(server_sockt);
}
static void *_start_bus_(void *arg) {
@@ -20,14 +20,17 @@
if(bus_server_socket_wrapper_start_bus(server_sockt) != 0) {
printf("start bus failed\n");
}
- printf("============_start_bus_ end\n" );
+
+ bus_server_socket_wrapper_close(server_sockt);
+ printf("============bus stopted\n" );
}
int main() {
pthread_t tid;
char action[512];
- signal(SIGINT, sigint_handler);
+ signal(SIGINT, stop_bus_handler);
+ signal(SIGTERM, stop_bus_handler);
shm_mm_wrapper_init(512);
server_sockt = bus_server_socket_wrapper_open();
pthread_create(&tid, NULL, _start_bus_, NULL);
--
Gitblit v1.8.0