Method SendMessages

src/net_processing.cpp:5816–6324

}

bool PeerManagerImpl::SendMessages(CNode& node)
{
    AssertLockNotHeld(m_tx_download_mutex);
    AssertLockHeld(g_msgproc_mutex);

    PeerRef maybe_peer{GetPeerRef(node.GetId())};
    if (!maybe_peer) return false;
    Peer& peer{*maybe_peer};
    const Consensus::Params& consensusParams = m_chainparams.GetConsensus();

    // We must call MaybeDiscourageAndDisconnect first, to ensure that we'll
    // disconnect misbehaving peers even before the version handshake is complete.
    if (MaybeDiscourageAndDisconnect(node, peer)) return true;

    // Initiate version handshake for outbound connections
    if (!node.IsInboundConn() && !peer.m_outbound_version_message_sent) {
        PushNodeVersion(node, peer);
        peer.m_outbound_version_message_sent = true;
    }

    // Don't send anything until the version handshake is complete
    if (!node.fSuccessfullyConnected || node.fDisconnect)
        return true;

    const auto now{NodeClock::now()};
    const auto current_time{GetTime<std::chrono::microseconds>()};

    // The logic below does not apply to private broadcast peers, so skip it.
    // Also in CConnman::PushMessage() we make sure that unwanted messages are
    // not sent. This here is just an optimization.
    if (node.IsPrivateBroadcastConn()) {
        if (node.m_connected + PRIVATE_BROADCAST_MAX_CONNECTION_LIFETIME < now) {
            LogDebug(BCLog::PRIVBROADCAST, "Disconnecting: did not complete the transaction send within %d seconds, %s",
                     count_seconds(PRIVATE_BROADCAST_MAX_CONNECTION_LIFETIME), node.LogPeer());
            node.fDisconnect = true;
        }
        return true;
    }

    if (node.IsAddrFetchConn() && now - node.m_connected > 10 * AVG_ADDRESS_BROADCAST_INTERVAL) {
        LogDebug(BCLog::NET, "addrfetch connection timeout, %s", node.DisconnectMsg());
        node.fDisconnect = true;
        return true;
    }

    MaybeSendPing(node, peer, now);

    // MaybeSendPing may have marked peer for disconnection
    if (node.fDisconnect) return true;

    MaybeSendAddr(node, peer, current_time);

    MaybeSendSendHeaders(node, peer);

    {
        LOCK(cs_main);

        CNodeState &state = *State(node.GetId());