Method ProcessBlockDelegates

src/chain/blockdelegates.cpp:69–143

process block delegates, call at the tail of block executing

// process block delegates, call at the tail of block executing
bool chain::ProcessBlockDelegates(CBlock &block, CCacheWrapper &cw, CValidationState &state) {
    // required preparing the undo for cw

    auto version = GetFeatureForkVersion(block.GetHeight());

    if (version >= MAJOR_VER_R3_5) {
        CBlockInflatedReward blockInflatedReward;
        cw.blockCache.GetBlockInflatedReward(blockInflatedReward);
        if (blockInflatedReward.start_height != 0 && block.GetHeight() >= blockInflatedReward.start_height) {
            uint64_t new_rewards = 0;
            cw.sysParamCache.GetParam(SysParamType::BLOCK_INFLATED_REWARD_AMOUNT, new_rewards);
            blockInflatedReward.new_rewards += new_rewards;
            if (!cw.blockCache.SetBlockInflatedReward(blockInflatedReward)) {
                return state.DoS(100, ERRORMSG("[%d] Save BlockInflatedReward failed! block=%s",
                        block.GetHeight(), block.GetHash().ToString()));
            }
            LogPrint(BCLog::DELEGATE, "Inflated rewards=%llu at block=%s", new_rewards, block.GetIdStr());
        }
    }

    bool isR3Fork = version >= MAJOR_VER_R3;
    int32_t countVoteInterval = (isR3Fork) ? COUNT_VOTE_INTERVAL_AFTER_V3 : COUNT_VOTE_INTERVAL_BEFORE_V3; // the interval to count the vote
    int32_t activateDelegateInterval = (isR3Fork) ? ACTIVATE_DELEGATE_DELAY_AFTER_V3 : ACTIVATE_DELEGATE_DELAY_BEFORE_V3;

    PendingDelegates pendingDelegates;
    cw.delegateCache.GetPendingDelegates(pendingDelegates);

    // get last update height of vote
    if (pendingDelegates.state != VoteDelegateState::PENDING &&
        (countVoteInterval == 0 || (block.GetHeight() % countVoteInterval == 0))) {
        VoteDelegateVector activeDelegates;
        if (!cw.delegateCache.GetActiveDelegates(activeDelegates)) {
            LogPrint(BCLog::INFO, "[%d] Active delegates do not exist, will be initialized later! block=%s\n",
                    block.GetHeight(), block.GetHash().ToString());
        }
        int32_t lastVoteHeight = cw.delegateCache.GetLastVoteHeight();
        uint32_t delegateNum = cw.sysParamCache.GetTotalBpsSize(block.GetHeight()) ;

        if (pendingDelegates.counted_vote_height == 0 ||
            lastVoteHeight > (int32_t)pendingDelegates.counted_vote_height ||
            activeDelegates.size() != delegateNum) {

            if (!GenPendingDelegates(block, delegateNum, cw, activeDelegates, pendingDelegates, isR3Fork)) {
                return state.DoS(100, ERRORMSG("[%d] GenPendingDelegates failed! block=%s",
                        block.GetHeight(), block.GetHash().ToString()));
            }

            if (!cw.delegateCache.SetPendingDelegates(pendingDelegates)) {
                return state.DoS(100, ERRORMSG("[%d] Save pending delegates failed! block=%s",
                        block.GetHeight(), block.GetHash().ToString()));
            }
        }
    }

    // must execute below separately because activateDelegateInterval may be 0
    if (pendingDelegates.state != VoteDelegateState::ACTIVATED) {
        if (block.GetHeight() - pendingDelegates.counted_vote_height >= (uint32_t)activateDelegateInterval) {
            VoteDelegateVector activeDelegates = pendingDelegates.top_vote_delegates;