start_connect()

void MayaFlux::Core::TCPBackend::start_connect ( ConnectionState &  conn )

private

Initiate async_connect for an outbound endpoint.

On success: transitions to OPEN, starts receive chain. On failure: transitions to ERROR or RECONNECTING.

Definition at line 343 of file TCPBackend.cpp.

{
    asio::error_code ec;
    auto addr = asio::ip::make_address(conn.info.remote_address, ec);
    if (ec) {
        MF_ERROR(Journal::Component::Core, Journal::Context::NetworkBackend,
            "Invalid remote address '{}': {}", conn.info.remote_address, ec.message());
        transition_state(conn.info, EndpointState::ERROR);
        return;
    }
 
    asio::ip::tcp::endpoint target(addr, conn.info.remote_port);
 
    conn.socket.async_connect(
        target,
        [this, ep_id = conn.info.id](const asio::error_code& connect_ec) {
            std::shared_lock lock(m_connections_mutex);
            auto it = m_connections.find(ep_id);
            if (it == m_connections.end()) {
                return;
            }
 
            auto& c = *it->second;
 
            if (connect_ec) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "TCP connect failed for endpoint {}: {}",
                    ep_id, connect_ec.message());
 
                if (m_config.auto_reconnect) {
                    transition_state(c.info, EndpointState::RECONNECTING);
                    schedule_reconnect(c);
                } else {
                    transition_state(c.info, EndpointState::ERROR);
                }
                return;
            }
 
            transition_state(c.info, EndpointState::OPEN);
            start_receive_chain(c);
 
            MF_INFO(Journal::Component::Core, Journal::Context::NetworkBackend,
                "TCP endpoint {} connected to {}:{}",
                ep_id, c.info.remote_address, c.info.remote_port);
        });
}

References MayaFlux::Journal::Core, MayaFlux::Core::EndpointInfo::id, MayaFlux::Core::TCPBackend::ConnectionState::info, MF_ERROR, MF_INFO, MF_WARN, MayaFlux::Journal::NetworkBackend, MayaFlux::Core::EndpointInfo::remote_address, MayaFlux::Core::EndpointInfo::remote_port, and MayaFlux::Core::TCPBackend::ConnectionState::socket.

Referenced by open_endpoint().

Here is the caller graph for this function: