Method start

libcaf_io/caf/io/middleman.cpp:336–426

}

void middleman::start() {
  auto lg = log::io::trace("");
  // Consider using net::middleman for prometheus if caf-net is available.
  if (auto prom = get_if<config_value::dictionary>(
        &system().config(), "caf.middleman.prometheus-http")) {
    auto ptr = std::make_unique<prometheus_scraping>(system());
    if (auto port = ptr->start(*prom)) {
      CAF_ASSERT(*port != 0);
      prometheus_scraping_port_ = *port;
      background_tasks_.emplace_back(std::move(ptr));
    }
  }
  // Launch backend.
  backend_supervisor_ = backend().make_supervisor();
  CAF_ASSERT(backend_supervisor_ != nullptr);
  detail::latch sync{1};
  auto run_backend = [this, sync_ptr{&sync}] {
    auto lg = log::io::trace("");
    backend().thread_id(std::this_thread::get_id());
    sync_ptr->count_down();
    backend().run();
  };
  thread_ = system().launch_thread("caf.io.mpx", thread_owner::system,
                                   run_backend);
  sync.wait();
  // Spawn utility actors.
  auto basp = named_broker<basp_broker>("BASP");
  manager_ = make_middleman_actor(system(), basp);
}

void middleman::stop() {
  auto lg = log::io::trace("");
  backend().dispatch([this] {
    auto lg = log::io::trace("");
    // managers_ will be modified while we are stopping each manager,
    // because each manager will call remove(...)
    for (auto& kvp : named_brokers_) {
      auto& hdl = kvp.second;
      auto ptr = actor_cast<broker*>(hdl);
      if (!ptr->getf(abstract_actor::is_terminated_flag)) {
        ptr->context(&backend());
        ptr->quit();
        ptr->finalize();
      }
    }
  });
  backend_supervisor_.reset();
  if (thread_.joinable())
    thread_.join();
  named_brokers_.clear();
  scoped_actor self{system(), true};
  self->send_exit(manager_, exit_reason::kill);
  if (!get_or(config(), "caf.middleman.attach-utility-actors", false))
    self->wait_for(manager_);
  destroy(manager_);
  background_tasks_.clear();
}