Method CreateServer

src/plugin/net/src/AFCNetServiceManagerModule.cpp:168–193

}

ananas::Future<std::pair<bool, std::string>> AFCNetServiceManagerModule::CreateServer(
    const AFHeadLength head_len /* = AFHeadLength::SS_HEAD_LENGTH*/)
{
    ananas::Promise<std::pair<bool, std::string>> promise;

    const AFProcConfig& self_proc = m_pBusModule->GetSelfProc();

    auto pServer = std::make_shared<AFCNetServerService>(GetPluginManager());
    bool ret =
        pServer->Start(head_len, self_proc.bus_id, self_proc.server_ep, self_proc.thread_num, self_proc.max_connection);
    if (ret)
    {
        ARK_LOG_INFO("Start net server successful, url = {}", self_proc.server_ep.ToString());
    }
    else
    {
        ARK_LOG_ERROR("Cannot start server net, url = {}", self_proc.server_ep.ToString());
        promise.SetValue(std::make_pair(false, std::string()));
        return promise.GetFuture();
    }

    server_services_.insert(m_pBusModule->GetSelfBusID(), pServer);

    // Register self to service discovery center(consul)
    return RegisterToConsul(m_pBusModule->GetSelfBusID());
}

std::shared_ptr<AFINetServerService> AFCNetServiceManagerModule::GetSelfNetServer()
{