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