rpc_thread_pool.cpp

Go to the documentation of this file.

#include "api/transport/rpc_thread_pool.hpp"

#include <fmt/format.h>
#include <soralog/util.hpp>

namespace kagome::api {

  RpcThreadPool::RpcThreadPool(std::shared_ptr<Context> context,
                               const Configuration &configuration)
      : context_(std::move(context)), config_(configuration) {
    BOOST_ASSERT(context_);
  }

  void RpcThreadPool::start() {
    threads_.reserve(config_.max_thread_number);
    // Create a pool of threads to run all of the io_contexts.
    for (std::size_t i = 0; i < config_.min_thread_number; ++i) {
      auto thread = std::make_shared<std::thread>([context = context_,
                                                   rpc_thread_number = i + 1] {
        soralog::util::setThreadName(fmt::format("rpc.{}", rpc_thread_number));
        context->run();
      });
      thread->detach();
      threads_.emplace_back(std::move(thread));
    }
    SL_DEBUG(logger_, "Thread pool started");
  }

  void RpcThreadPool::stop() {
    context_->stop();
    SL_DEBUG(logger_, "Thread pool stopped");
  }

}  // namespace kagome::api