diff options
author | John Newbery <john@johnnewbery.com> | 2020-06-21 20:25:11 -0400 |
---|---|---|
committer | John Newbery <john@johnnewbery.com> | 2020-12-20 10:03:38 +0000 |
commit | 184557e8e03f76ff18dacdb32c12692d8578691f (patch) | |
tree | fc4538c59e456ac7a7b9e71474354b65bc7f9fe0 /src/net_processing.cpp | |
parent | c853ef002ee7074b6e20eb8f58138c8293846424 (diff) | |
download | bitcoin-184557e8e03f76ff18dacdb32c12692d8578691f.tar.xz |
[net processing] Move hashContinue to net processing
Also rename to m_continuation_block to better communicate meaning.
Diffstat (limited to 'src/net_processing.cpp')
-rw-r--r-- | src/net_processing.cpp | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/net_processing.cpp b/src/net_processing.cpp index 8dafd98d76..4b0bc2bcd2 100644 --- a/src/net_processing.cpp +++ b/src/net_processing.cpp @@ -1475,7 +1475,7 @@ static void RelayAddress(const CNode& originator, connman.ForEachNodeThen(std::move(sortfunc), std::move(pushfunc)); } -void static ProcessGetBlockData(CNode& pfrom, const CChainParams& chainparams, const CInv& inv, CConnman& connman) +void static ProcessGetBlockData(CNode& pfrom, Peer& peer, const CChainParams& chainparams, const CInv& inv, CConnman& connman) { bool send = false; std::shared_ptr<const CBlock> a_recent_block; @@ -1616,15 +1616,14 @@ void static ProcessGetBlockData(CNode& pfrom, const CChainParams& chainparams, c } // Trigger the peer node to send a getblocks request for the next batch of inventory - if (inv.hash == pfrom.hashContinue) - { + if (inv.hash == peer.m_continuation_block) { // Send immediately. This must send even if redundant, // and we want it right after the last block so they don't // wait for other stuff first. std::vector<CInv> vInv; vInv.push_back(CInv(MSG_BLOCK, ::ChainActive().Tip()->GetBlockHash())); connman.PushMessage(&pfrom, msgMaker.Make(NetMsgType::INV, vInv)); - pfrom.hashContinue.SetNull(); + peer.m_continuation_block.SetNull(); } } } @@ -1724,7 +1723,7 @@ void static ProcessGetData(CNode& pfrom, Peer& peer, const CChainParams& chainpa if (it != peer.m_getdata_requests.end() && !pfrom.fPauseSend) { const CInv &inv = *it++; if (inv.IsGenBlkMsg()) { - ProcessGetBlockData(pfrom, chainparams, inv, connman); + ProcessGetBlockData(pfrom, peer, chainparams, inv, connman); } // else: If the first item on the queue is an unknown type, we erase it // and continue processing the queue on the next call. @@ -2805,7 +2804,7 @@ void PeerManager::ProcessMessage(CNode& pfrom, const std::string& msg_type, CDat // When this block is requested, we'll send an inv that'll // trigger the peer to getblocks the next batch of inventory. LogPrint(BCLog::NET, " getblocks stopping at limit %d %s\n", pindex->nHeight, pindex->GetBlockHash().ToString()); - pfrom.hashContinue = pindex->GetBlockHash(); + peer->m_continuation_block = pindex->GetBlockHash(); break; } } |