Retropex/bitcoin
1
0
Fork 0
mirror of https://github.com/Retropex/bitcoin.git synced 2025-05-15 12:40:41 +02:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

[net processing] Clarify UpdatedBlockTip()

Browse Source
This commit is contained in:
John Newbery 2020-12-11 10:40:19 +00:00
parent 94d2cc35be
commit f6360088de
1 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/net_processing.cpp
View File

@ -1296,28 +1296,30 @@ void PeerManager::UpdatedBlockTip(const CBlockIndex *pindexNew, const CBlockInde
m_connman.SetBestHeight(pindexNew->nHeight); m_connman.SetBestHeight(pindexNew->nHeight);
SetServiceFlagsIBDCache(!fInitialDownload); SetServiceFlagsIBDCache(!fInitialDownload);
// Relay inventory, but don't relay old inventory during initial block download. // Don't relay inventory during initial block download.
if (!fInitialDownload) { if (fInitialDownload) return;
// Find the hashes of all blocks that weren't previously in the best chain.
std::vector<uint256> vHashes; // Find the hashes of all blocks that weren't previously in the best chain.
const CBlockIndex *pindexToAnnounce = pindexNew; std::vector<uint256> vHashes;
while (pindexToAnnounce != pindexFork) { const CBlockIndex *pindexToAnnounce = pindexNew;
vHashes.push_back(pindexToAnnounce->GetBlockHash()); while (pindexToAnnounce != pindexFork) {
pindexToAnnounce = pindexToAnnounce->pprev; vHashes.push_back(pindexToAnnounce->GetBlockHash());
if (vHashes.size() == MAX_BLOCKS_TO_ANNOUNCE) { pindexToAnnounce = pindexToAnnounce->pprev;
// Limit announcements in case of a huge reorganization. if (vHashes.size() == MAX_BLOCKS_TO_ANNOUNCE) {
// Rely on the peer's synchronization mechanism in that case. // Limit announcements in case of a huge reorganization.
break; // Rely on the peer's synchronization mechanism in that case.
} break;
} }
m_connman.ForEachNode([&vHashes](CNode* pnode) {
LOCK(pnode->cs_inventory);
for (const uint256& hash : reverse_iterate(vHashes)) {
pnode->vBlockHashesToAnnounce.push_back(hash);
}
});
m_connman.WakeMessageHandler();
} }
// Relay to all peers
m_connman.ForEachNode([&vHashes](CNode* pnode) {
LOCK(pnode->cs_inventory);
for (const uint256& hash : reverse_iterate(vHashes)) {
pnode->vBlockHashesToAnnounce.push_back(hash);
}
});
m_connman.WakeMessageHandler();
} }
/** /**