main.cc

Go to the documentation of this file.

/*
 * SWC-DB© Copyright since 2019 Alex Kashirin <kashirin.alex@gmail.com>
 * License details at <https://github.com/kashirin-alex/swc-db/#license>
 */
 
 
#include "swcdb/manager/Settings.h"
#include "swcdb/core/comm/SerializedServer.h"
#include "swcdb/manager/AppContext.h"
 
 
namespace SWC {
 
 
namespace Manager {
 
 
 
SWC_SHOULD_NOT_INLINE
Comm::server::SerializedServer::Ptr make_service() {
  AppContext::Ptr app_ctx(new AppContext());
  Comm::server::SerializedServer::Ptr srv(
    new Comm::server::SerializedServer(
      *Env::Config::settings(),
      "MANAGER",
      Env::Config::settings()->get_bool("swc.mngr.concurrency.relative"),
      Env::Config::settings()->get_i32("swc.mngr.reactors"),
      Env::Config::settings()->get_i32("swc.mngr.workers"),
      Env::Config::settings()->get_i16("swc.mngr.port"),
      app_ctx
    )
  );
  app_ctx->set_srv(srv);
  return srv;
}
 
SWC_SHOULD_NOT_INLINE
int exiting() {
  SWC_LOG(LOG_INFO, "Exit");
  SWC_CAN_QUICK_EXIT(EXIT_SUCCESS);
 
  Env::Config::reset();
 
  std::this_thread::sleep_for(std::chrono::seconds(1));
  return 0;
}
 
SWC_SHOULD_NOT_INLINE
int run() {
  SWC_TRY_OR_LOG("",
    make_service()->run();
    return exiting();
  );
  return 1;
}
 
 
 
}} // namespace SWC::Manager
 
 
 
int main(int argc, char** argv) {
  SWC::Env::Config::init(argc, argv, &SWC::Config::init_app_options, nullptr);
  SWC::Env::Config::settings()->init_process(true, "swc.mngr.port");
  return SWC::Manager::run();
}