From c479ef57baaaa28964fc3ec8d80ff99dffa7d49f Mon Sep 17 00:00:00 2001 From: fujuntang <fujuntang@smartai.com> Date: 星期三, 10 十一月 2021 09:49:29 +0800 Subject: [PATCH] Fix the system hang issue when the app is killed contantly. --- src/bus_proxy_start.cpp | 15 ++++++++++----- 1 files changed, 10 insertions(+), 5 deletions(-) diff --git a/src/bus_proxy_start.cpp b/src/bus_proxy_start.cpp index c3104a9..6029e6e 100644 --- a/src/bus_proxy_start.cpp +++ b/src/bus_proxy_start.cpp @@ -10,6 +10,8 @@ #include <errno.h> #include <getopt.h> #include <stdlib.h> +#include "proc_def.h" +#include "msg_mgr.h" using namespace std; @@ -44,9 +46,6 @@ return NULL; } - - - void *svr_start(void *skptr) { int port = *(int *)skptr; @@ -105,7 +104,7 @@ } } - sleep(10); + sleep(WT_INT); } return NULL; @@ -151,6 +150,10 @@ } } +#if defined(MSG_HANDLER) + msg_init(); +#endif + if (gShm_size == -1) { gShm_size = SHM_RES_SIZE; } @@ -169,7 +172,9 @@ if (gBusServer_stat >= 0) { pthread_create(&tids[1], NULL, svr_start, (void *)&gPort); - pthread_create(&tids[0], NULL, check_start, NULL); + pthread_create(&tids[2], NULL, check_start, NULL); + + //pthread_create(&tids[3], NULL, sem_msg_handler, NULL); } for (i = 0; i< TOTAL_THREADS; i++) { -- Gitblit v1.8.0