/*
|
* =====================================================================================
|
*
|
* Filename: center_main.cc
|
*
|
* Description:
|
*
|
* Version: 1.0
|
* Created: 2021年04月13日 16时16分26秒
|
* Revision: none
|
* Compiler: gcc
|
*
|
* Author: Li Chao (), lichao@aiotlink.com
|
* Organization:
|
*
|
* =====================================================================================
|
*/
|
#include "app_arg.h"
|
#include "box.h"
|
#include "center.h"
|
#include "defs.h"
|
#include "signalhandle.h"
|
#include <chrono>
|
#include <thread>
|
using namespace std::chrono_literals;
|
|
int center_main(int argc, const char *argv[])
|
{
|
AppArg args(argc, argv);
|
if (args.Has("remove")) {
|
BHomeShm().Remove();
|
return 0;
|
}
|
|
bool run = true;
|
auto showStatus = [&]() {
|
auto init = BHomeShm().get_free_memory();
|
uint64_t idx = 0;
|
while (run) {
|
std::this_thread::sleep_for(1s);
|
printf("%8d shared memory: avail : %ld / %ld\n", ++idx, BHomeShm().get_free_memory(), init);
|
}
|
};
|
std::thread t(showStatus);
|
|
BHCenter center(BHomeShm());
|
center.Start();
|
printf("center started ...\n");
|
WaitForSignals({SIGINT, SIGTERM});
|
run = false;
|
t.join();
|
return 0;
|
}
|
|
namespace
|
{
|
static bool install = BoxInstall("bhshmq_center", center_main, "bhome center program.");
|
}
|
