Method LoadProcConfig

src/plugin/bus/src/AFCBusModule.cpp:49–85

}

bool AFCBusModule::LoadProcConfig()
{
    AFXml xml_doc(PROC_CONFIG_FILE_PATH);

    auto root_node = xml_doc.GetRootNode();
    ARK_ASSERT_RET_VAL(root_node.IsValid(), false);

    for (auto proc_node = root_node.FindNode("proc"); proc_node.IsValid(); proc_node.NextNode())
    {
        std::string bus_name = proc_node.GetString("busid");
        std::string endpoint_server = proc_node.GetString("endpoint_server");
        std::string endpoint_intranet = proc_node.GetString("endpoint_intranet");
        uint32_t max_connection = proc_node.GetUint32("max_connection");
        uint8_t thread_num = static_cast<uint8_t>(proc_node.GetUint32("thread_num"));

        AFBusAddr bus_addr;
        ARK_ASSERT_CONTINUE(bus_addr.FromString(bus_name));

        // just load self process configuration
        if (bus_addr.bus_id != GetSelfBusID())
        {
            continue;
        }

        app_config_.self_proc.bus_id = bus_addr.bus_id;
        app_config_.self_proc.thread_num = thread_num;
        app_config_.self_proc.max_connection = max_connection;

        std::error_code ec;
        app_config_.self_proc.server_ep = AFEndpoint::FromString(endpoint_server, ec);
        app_config_.self_proc.intranet_ep = AFEndpoint::FromString(endpoint_intranet, ec);

        break;
    }

    return true;
}

bool AFCBusModule::LoadBusRelationConfig()
{