Method push

tools/parser/block_processor.cpp:545–555

    StepNum stepNum;
    
    void push(RawTransaction *tx) {
        using namespace std::chrono_literals;
        while (!nextQueue->push(tx)) {
            if (nextDone && *nextDone) {
                // Error: next ProcessStep finished before all items were queued
                throw NextQueueFinishedEarlyException();
            }
            nextWaitCount++;
            std::this_thread::sleep_for(5ms);
        }
    }
    
    void linkBack(QueueStage &prevStage) {
        // Link the queue- and done-pointers for the previous queue to this object's variables