Function PushGetBlocksOnCondition

src/main.cpp:2074–2104

}

void PushGetBlocksOnCondition(CNode *pNode, CBlockIndex *pIndexBegin, uint256 hashEnd) {
    // Ask this guy to fill in what we're missing
    AssertLockHeld(cs_main);
    // Filter out duplicate requests
    if (pIndexBegin == pNode->pIndexLastGetBlocksBegin && hashEnd == pNode->hashLastGetBlocksEnd) {
        LogPrint(BCLog::NET, "filter the same GetLocator from peer %s\n", pNode->addr.ToString());
        static CBloomFilter filter(5000, 0.0001, 0, BLOOM_UPDATE_NONE);
        static uint32_t count = 0;
        string key            = to_string(pNode->id) + ":" + to_string((GetTime() / 2));
        if (!filter.contains(vector<uint8_t>(key.begin(), key.end()))) {
            filter.insert(vector<uint8_t>(key.begin(), key.end()));
            ++count;
            pNode->pIndexLastGetBlocksBegin = pIndexBegin;
            pNode->hashLastGetBlocksEnd     = hashEnd;
            CBlockLocator blockLocator      = chainActive.GetLocator(pIndexBegin);
            pNode->PushMessage(NetMsgType::GETBLOCKS, blockLocator, hashEnd);
            LogPrint(BCLog::NET, "getblocks from peer %s, hashEnd:%s\n", pNode->addr.ToString(), hashEnd.GetHex());
        } else {
            if (count >= 5000) {
                count = 0;
                filter.Clear();
            }
        }
    } else {
        pNode->pIndexLastGetBlocksBegin = pIndexBegin;
        pNode->hashLastGetBlocksEnd     = hashEnd;
        CBlockLocator blockLocator      = chainActive.GetLocator(pIndexBegin);
        pNode->PushMessage(NetMsgType::GETBLOCKS, blockLocator, hashEnd);
        LogPrint(BCLog::NET, "getblocks from peer %s, hashEnd:%s\n", pNode->addr.ToString(), hashEnd.GetHex());
    }
}

bool ProcessBlock(CValidationState &state, CNode *pFrom, CBlock *pBlock, CDiskBlockPos *dbp) {
    int64_t llBeginTime = GetTimeMillis();