From 2561a007b8d8999a4750046d0cfb3b1ad5af50ac Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期二, 09 四月 2024 15:29:32 +0800
Subject: [PATCH] test for perf
---
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