Method Initialize

src/plugins/net_plugin/net_plugin.cc:99–266

}

bool NetPlugin::Initialize(runtime::core::AimRTCore* core_ptr) noexcept {
  try {
    core_ptr_ = core_ptr;

    YAML::Node plugin_options_node = core_ptr_->GetPluginManager().GetPluginOptionsNode(Name());

    if (plugin_options_node && !plugin_options_node.IsNull()) {
      options_ = plugin_options_node.as<Options>();
    }

    init_flag_ = true;

    asio_executor_ptr_ = std::make_shared<aimrt::common::net::AsioExecutor>(options_.thread_num);

    core_ptr_->RegisterHookFunc(runtime::core::AimRTCore::State::kPostInitLog,
                                [this] { SetPluginLogger(); });

    // http
    http_cli_pool_ptr_ = std::make_shared<aimrt::common::net::AsioHttpClientPool>(asio_executor_ptr_->IO());

    core_ptr_->RegisterHookFunc(
        runtime::core::AimRTCore::State::kPreStart,
        [this] {
          http_cli_pool_ptr_->SetLogger(WrapAimRTLoggerRef(GetLogger()));
          http_cli_pool_ptr_->Initialize(aimrt::common::net::AsioHttpClientPool::Options{});
          http_cli_pool_ptr_->Start();
        });

    core_ptr_->RegisterHookFunc(
        runtime::core::AimRTCore::State::kPostShutdown,
        [this] {
          http_cli_pool_ptr_->Shutdown();
        });

    core_ptr_->RegisterHookFunc(runtime::core::AimRTCore::State::kPreInitRpc,
                                [this] { RegisterHttpRpcBackend(); });

    core_ptr_->RegisterHookFunc(runtime::core::AimRTCore::State::kPreInitChannel,
                                [this] { RegisterHttpChannelBackend(); });

    if (options_.http_options) {
      http_svr_ptr_ = std::make_shared<aimrt::common::net::AsioHttpServer>(asio_executor_ptr_->IO());
      core_ptr_->RegisterHookFunc(
          runtime::core::AimRTCore::State::kPreStart,
          [this] {
            http_svr_ptr_->SetLogger(WrapAimRTLoggerRef(GetLogger()));
            http_svr_ptr_->Initialize(aimrt::common::net::AsioHttpServer::Options{
                .ep = {boost::asio::ip::make_address_v4(options_.http_options->listen_ip),
                       options_.http_options->listen_port}});
            http_svr_ptr_->Start();
          });
      core_ptr_->RegisterHookFunc(
          runtime::core::AimRTCore::State::kPostShutdown,
          [this] {
            http_svr_ptr_->Shutdown();
          });
    }