12 std::unique_ptr<Worker>
15 return std::make_unique<WorkerT<SharedProducer>>(
this, wp);
void respondToCloseInputFileWithFrame(FileBlock const &, ProcessingFrame const &) final
void endJobWithFrame(ProcessingFrame const &) final
void respondToOpenInputFileWithFrame(FileBlock const &, ProcessingFrame const &) final
void setupQueues(detail::SharedResources const &) final
virtual void respondToOpenInputFile(FileBlock const &, ProcessingFrame const &)
void endSubRunWithFrame(SubRun &, ProcessingFrame const &) final
virtual void beginSubRun(SubRun &, ProcessingFrame const &)
virtual void endJob(ProcessingFrame const &)
virtual void respondToOpenOutputFiles(FileBlock const &, ProcessingFrame const &)
void respondToOpenOutputFilesWithFrame(FileBlock const &, ProcessingFrame const &) final
void endRunWithFrame(Run &, ProcessingFrame const &) final
virtual void beginJob(ProcessingFrame const &)
void respondToCloseOutputFilesWithFrame(FileBlock const &, ProcessingFrame const &) final
virtual void produce(Event &, ProcessingFrame const &)=0
void beginSubRunWithFrame(SubRun &, ProcessingFrame const &) final
virtual void beginRun(Run &, ProcessingFrame const &)
void beginJobWithFrame(ProcessingFrame const &) final
virtual void respondToCloseOutputFiles(FileBlock const &, ProcessingFrame const &)
void createQueues(SharedResources const &resources)
virtual void endRun(Run &, ProcessingFrame const &)
virtual void respondToCloseInputFile(FileBlock const &, ProcessingFrame const &)
void produceWithFrame(Event &, ProcessingFrame const &) final
std::unique_ptr< Worker > doMakeWorker(WorkerParams const &wp) final
void beginRunWithFrame(Run &, ProcessingFrame const &) final
virtual void endSubRun(SubRun &, ProcessingFrame const &)