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