From 72851db66655912cb9c92300a80985fb9797d168 Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期二, 01 六月 2021 16:25:23 +0800
Subject: [PATCH] remove AtomicQueue, not used.

---
 box/center_main.cc |   16 +++++++++++++---
 1 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/box/center_main.cc b/box/center_main.cc
index 232b943..e7715f8 100644
--- a/box/center_main.cc
+++ b/box/center_main.cc
@@ -92,7 +92,7 @@
 		return 0;
 	}
 
-	ns_log::AddLog("/tmp/bhshmq_center.log");
+	ns_log::AddLog(BHLogDir() + "bhshmq_center.log");
 	auto lvl = args.Get("log", "info");
 	if (strcasecmp(lvl.c_str(), "trace") == 0) { ns_log::ResetLogLevel(ns_log::LogLevel::trace); }
 	if (strcasecmp(lvl.c_str(), "debug") == 0) { ns_log::ResetLogLevel(ns_log::LogLevel::debug); }
@@ -102,11 +102,19 @@
 	if (strcasecmp(lvl.c_str(), "fatal") == 0) { ns_log::ResetLogLevel(ns_log::LogLevel::fatal); }
 
 	auto &shm = BHomeShm();
+	if (!CenterInit(shm)) {
+		auto msg = "init memory error.";
+		LOG_FATAL() << msg;
+		printf("%s\n", msg);
+		exit(0);
+	}
 	GlobalInit(shm);
 
 	InstanceFlag inst(shm, kCenterRunningFlag);
 	if (!inst.TryStartAsFirstInstance()) {
-		LOG_INFO() << "another instance is running, exit.";
+		auto msg = "another instance is running, exit.";
+		LOG_INFO() << msg;
+		printf("%s\n", msg);
 		return 0;
 	}
 
@@ -117,7 +125,9 @@
 	BHCenter center(shm);
 	center.Start();
 
-	LOG_INFO() << "center started ...";
+	auto msg = "center started ...";
+	LOG_INFO() << msg;
+	printf("%s\n", msg);
 	WaitForSignals({SIGINT, SIGTERM});
 	center.Stop();
 	LOG_INFO() << "center stopped.";

--
Gitblit v1.8.0