Function AddBlockToQueue

src/p2p/chainmessage.cpp:199–239

Requires cs_main.

// Requires cs_main.
bool AddBlockToQueue(const uint256 &hash, NodeId nodeId) {
    int64_t now  = GetTimeMicros();
    bool isMiner = SysCfg().GetBoolArg("-genblock", false);

    int64_t blocksToDownloadTimeout = isMiner ? MINER_NODE_BLOCKS_TO_DOWNLOAD_TIMEOUT : WITNESS_NODE_BLOCKS_TO_DOWNLOAD_TIMEOUT;
    int64_t blockInFlightTimeout    = isMiner ? MINER_NODE_BLOCKS_IN_FLIGHT_TIMEOUT : WITNESS_NODE_BLOCKS_IN_FLIGHT_TIMEOUT;

    if ((mapBlocksToDownload.count(hash) &&
         (now - std::get<2>(mapBlocksToDownload[hash]) < blocksToDownloadTimeout * 1000000)) ||
        (mapBlocksInFlight.count(hash) &&
         (now - std::get<2>(mapBlocksInFlight[hash]) < blockInFlightTimeout * 1000000))) {
        LogPrint(BCLog::NET, "block (%s) being downloaded from another peer, ignore! ts=%lld\n", hash.GetHex(), GetTimeMillis());

        return false;
    }

    LOCK(cs_mapNodeState);
    CNodeState *state = State(nodeId);
    if (state == nullptr) {
        LogPrint(BCLog::NET, "peer (%d) not found! ts=%lld, block(%s) \n",
            nodeId, GetTimeMillis(), hash.ToString());
        return false;
    }

    // Make sure it's not listed somewhere already.
    MarkBlockAsReceived(hash);

    list<uint256>::iterator it = state->vBlocksToDownload.insert(state->vBlocksToDownload.end(), hash);
    state->nBlocksToDownload++;
    if (state->nBlocksToDownload > 5000) {
        LogPrint(BCLog::INFO, "Misbehaving: AddBlockToQueue download too many times, nMisbehavior add 10\n");
        Misbehaving(nodeId, 10);
    }

    LogPrint(BCLog::NET, "start downloading block(%s)! time_ms=%lld, peer=%s\n", hash.ToString(),
                          GetTimeMillis(), state->name);

    mapBlocksToDownload[hash] = std::make_tuple(nodeId, it, GetTimeMicros());

    return true;
}

int32_t ProcessVersionMessage(CNode *pFrom, string strCommand, CDataStream &vRecv) {
    // Each connection can only send one version message