Method InactivityCheck

src/net.cpp:2034–2085

}

bool CConnman::InactivityCheck(const CNode& node, NodeClock::time_point now) const
{
    // Tests that see disconnects after using mocktime can start nodes with a
    // large timeout. For example, -peertimeout=999999999.
    const auto last_send{node.m_last_send.load()};
    const auto last_recv{node.m_last_recv.load()};

    if (!ShouldRunInactivityChecks(node, now)) return false;

    bool has_received{last_recv > NodeClock::epoch};
    bool has_sent{last_send > NodeClock::epoch};

    if (!has_received || !has_sent) {
        std::string has_never;
        if (!has_received) has_never += ", never received from peer";
        if (!has_sent) has_never += ", never sent to peer";
        LogDebug(BCLog::NET,
            "socket no message in first %i seconds%s, %s",
            count_seconds(m_peer_connect_timeout),
            has_never,
            node.DisconnectMsg()
        );
        return true;
    }

    if (now > last_send + TIMEOUT_INTERVAL) {
        LogDebug(BCLog::NET,
            "socket sending timeout: %is, %s", Ticks<std::chrono::seconds>(now - last_send),
            node.DisconnectMsg()
        );
        return true;
    }

    if (now > last_recv + TIMEOUT_INTERVAL) {
        LogDebug(BCLog::NET,
            "socket receive timeout: %is, %s", Ticks<std::chrono::seconds>(now - last_recv),
            node.DisconnectMsg()
        );
        return true;
    }

    if (!node.fSuccessfullyConnected) {
        if (node.m_transport->GetInfo().transport_type == TransportProtocolType::DETECTING) {
            LogDebug(BCLog::NET, "V2 handshake timeout, %s", node.DisconnectMsg());
        } else {
            LogDebug(BCLog::NET, "version handshake timeout, %s", node.DisconnectMsg());
        }
        return true;
    }

    return false;
}

Sock::EventsPerSock CConnman::GenerateWaitSockets(std::span<CNode* const> nodes)
{