on_connection_error()

void MayaFlux::Core::TCPBackend::on_connection_error ( ConnectionState &  conn, const asio::error_code &  ec  )

private

Handle a connection error (read/write failure).

Transitions to ERROR. If auto_reconnect and outbound, schedules reconnect via steady_timer.

Definition at line 541 of file TCPBackend.cpp.

{
    if (ec == asio::error::operation_aborted) {
        return;
    }
 
    if (ec == asio::error::eof) {
        MF_INFO(Journal::Component::Core, Journal::Context::NetworkBackend,
            "TCP endpoint {} peer disconnected", conn.info.id);
    } else {
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "TCP endpoint {} error: {}", conn.info.id, ec.message());
    }
 
    asio::error_code close_ec;
    if (!conn.socket.close(close_ec)) {
        MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
            "Error closing TCP socket for endpoint {}: {}", conn.info.id, close_ec.message());
    }
 
    if (conn.is_outbound && m_config.auto_reconnect) {
        transition_state(conn.info, EndpointState::RECONNECTING);
        schedule_reconnect(conn);
    } else {
        transition_state(conn.info, EndpointState::ERROR);
    }
}

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