schedule_reconnect()

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

private

Schedule a reconnect attempt after the configured interval.

Definition at line 565 of file TCPBackend.cpp.

{
    if (!conn.reconnect_timer) {
        conn.reconnect_timer = std::make_unique<asio::steady_timer>(m_context);
    }
 
    conn.reconnect_timer->expires_after(
        std::chrono::milliseconds(m_config.reconnect_interval_ms));
 
    conn.reconnect_timer->async_wait(
        [this, ep_id = conn.info.id](const asio::error_code& ec) {
            if (ec == asio::error::operation_aborted) {
                return;
            }
 
            std::shared_lock lock(m_connections_mutex);
            auto it = m_connections.find(ep_id);
            if (it == m_connections.end()) {
                return;
            }
 
            auto& c = *it->second;
 
            c.socket = asio::ip::tcp::socket(m_context);
 
            MF_DEBUG(Journal::Component::Core, Journal::Context::NetworkBackend,
                "TCP endpoint {} attempting reconnect to {}:{}",
                ep_id, c.info.remote_address, c.info.remote_port);
 
            start_connect(c);
        });
}

References MayaFlux::Journal::Core, MayaFlux::Core::EndpointInfo::id, MayaFlux::Core::TCPBackend::ConnectionState::info, MF_DEBUG, MayaFlux::Journal::NetworkBackend, and MayaFlux::Core::TCPBackend::ConnectionState::reconnect_timer.