Method ProcessMessages

src/net_processing.cpp:5165–5245

}

bool PeerManagerImpl::ProcessMessages(CNode& node, std::atomic<bool>& interruptMsgProc)
{
    AssertLockNotHeld(m_tx_download_mutex);
    AssertLockHeld(g_msgproc_mutex);

    PeerRef maybe_peer{GetPeerRef(node.GetId())};
    if (maybe_peer == nullptr) return false;
    Peer& peer{*maybe_peer};

    // For outbound connections, ensure that the initial VERSION message
    // has been sent first before processing any incoming messages
    if (!node.IsInboundConn() && !peer.m_outbound_version_message_sent) return false;

    {
        LOCK(peer.m_getdata_requests_mutex);
        if (!peer.m_getdata_requests.empty()) {
            ProcessGetData(node, peer, interruptMsgProc);
        }
    }

    const bool processed_orphan = ProcessOrphanTx(peer);

    if (node.fDisconnect)
        return false;

    if (processed_orphan) return true;

    // this maintains the order of responses
    // and prevents m_getdata_requests to grow unbounded
    {
        LOCK(peer.m_getdata_requests_mutex);
        if (!peer.m_getdata_requests.empty()) return true;
    }

    // Don't bother if send buffer is too full to respond anyway
    if (node.fPauseSend) return false;

    auto poll_result{node.PollMessage()};
    if (!poll_result) {
        // No message to process
        return false;
    }

    CNetMessage& msg{poll_result->first};
    bool fMoreWork = poll_result->second;

    TRACEPOINT(net, inbound_message,
        node.GetId(),
        node.m_addr_name.c_str(),
        node.ConnectionTypeAsString().c_str(),
        msg.m_type.c_str(),
        msg.m_recv.size(),
        msg.m_recv.data()
    );

    if (m_opts.capture_messages) {
        CaptureMessage(node.addr, msg.m_type, MakeUCharSpan(msg.m_recv), /*is_incoming=*/true);
    }