Method ProcessAddConnection

src/plugin/net/src/AFCNetClientService.cpp:266–301

}

void AFCNetClientService::ProcessAddConnection()
{
    for (auto& iter : tmp_connections_)
    {
        const AFConnectionData& connection_data = iter;
        std::shared_ptr<AFConnectionData> target_connection_data =
            real_connections_.find_value(connection_data.server_bus_id_);
        if (target_connection_data != nullptr)
        {
            continue;
        }
        // add new server
        target_connection_data = std::make_shared<AFConnectionData>();

        *target_connection_data = connection_data;
        target_connection_data->last_active_time_ = m_pPluginManager->GetNowTime();

        // based on protocol to create a new client
        target_connection_data->net_client_ = CreateNet(target_connection_data->endpoint_.proto());
        int ret = target_connection_data->net_client_->StartClient(target_connection_data->head_len_,
            target_connection_data->server_bus_id_, target_connection_data->endpoint_.GetIP(),
            target_connection_data->endpoint_.GetPort());
        if (!ret)
        {
            target_connection_data->net_state_ = AFConnectionData::RECONNECT;
        }
        else
        {
            target_connection_data->net_state_ = AFConnectionData::CONNECTING;
        }

        real_connections_.insert(target_connection_data->server_bus_id_, target_connection_data);
    }

    tmp_connections_.clear();
}

void AFCNetClientService::OnNetMsg(const AFNetMsg* msg)
{