Function MarkBlockAsInFlight

src/p2p/chainmessage.cpp:57–72

Requires cs_mapNodeState.

// Requires cs_mapNodeState.
void MarkBlockAsInFlight(const uint256 &hash, NodeId nodeId) {
    AssertLockHeld(cs_mapNodeState);
    CNodeState *state = State(nodeId);
    assert(state != nullptr);

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

    QueuedBlock newentry = {hash, GetTimeMicros(), state->nBlocksInFlight};
    if (state->nBlocksInFlight == 0)
        state->nLastBlockReceive = newentry.nTime;  // Reset when a first request is sent.

    list<QueuedBlock>::iterator it = state->vBlocksInFlight.insert(state->vBlocksInFlight.end(), newentry);
    state->nBlocksInFlight++;
    mapBlocksInFlight[hash] = std::make_tuple(nodeId, it, GetTimeMicros());
}

void ProcessGetData(CNode *pFrom) {
    deque<CInv>::iterator it = pFrom->vRecvGetData.begin();