Method run

tools/parser/block_processor.cpp:687–707

inputProcessingDone

    }
    // inputProcessingDone
    void run() {
        using namespace std::chrono_literals;
        // CompletionGuard sets isDone to true in its destructor that is called at the end of this operator() method
        std::list<CompletionGuard> guards;
        for (auto &stage : stages) {
            guards.emplace_back(stage->isDone);
        }
        
        // Consume queued items as long as the previous processing step has not finished
        while (anyNotDone()) {
            doAll();
            prevWaitCount++;
            std::this_thread::sleep_for(5ms);
        }

        // Last call to consume queued items to catch last items
        doAll();
        for (auto &stage : stages) {
            stage->complete();
        }
    }
};

ProcessStep makeStandardProcessStep(std::unique_ptr<ProcessorStep> && func, const DiscardCheckFunc &advanceFuncFirst, const DiscardCheckFunc &advanceFuncSecond, bool discardIfFullFirst = false, bool discardIfFullSecond = false) {