1 #ifndef art_Framework_Core_detail_Producer_h 2 #define art_Framework_Core_detail_Producer_h 21 class SharedResources;
25 template <
typename UserConfig,
typename KeysToIgnore =
void>
48 std::atomic<
std::
size_t>& counts_run,
49 std::atomic<
std::
size_t>& counts_passed,
50 std::atomic<
std::
size_t>& counts_failed);
void doBeginJob(SharedResources const &resources)
virtual void beginSubRunWithFrame(SubRun &, ProcessingFrame const &)=0
void doRespondToOpenInputFile(FileBlock const &fb)
virtual void respondToCloseInputFileWithFrame(FileBlock const &, ProcessingFrame const &)=0
void doRespondToOpenOutputFiles(FileBlock const &fb)
virtual void endSubRunWithFrame(SubRun &, ProcessingFrame const &)=0
virtual void respondToCloseOutputFilesWithFrame(FileBlock const &, ProcessingFrame const &)=0
bool doBeginRun(RunPrincipal &rp, ModuleContext const &mc)
virtual void endJobWithFrame(ProcessingFrame const &)=0
virtual void respondToOpenInputFileWithFrame(FileBlock const &, ProcessingFrame const &)=0
virtual void endRunWithFrame(Run &, ProcessingFrame const &)=0
void doRespondToCloseOutputFiles(FileBlock const &fb)
virtual void beginRunWithFrame(Run &, ProcessingFrame const &)=0
bool const checkPutProducts_
bool doEndSubRun(SubRunPrincipal &srp, ModuleContext const &mc)
void doRespondToCloseInputFile(FileBlock const &fb)
bool doEndRun(RunPrincipal &rp, ModuleContext const &mc)
virtual void respondToOpenOutputFilesWithFrame(FileBlock const &, ProcessingFrame const &)=0
bool doBeginSubRun(SubRunPrincipal &srp, ModuleContext const &mc)
bool doEvent(EventPrincipal &ep, ModuleContext const &mc, std::atomic< std::size_t > &counts_run, std::atomic< std::size_t > &counts_passed, std::atomic< std::size_t > &counts_failed)
virtual void setupQueues(SharedResources const &)=0
virtual void beginJobWithFrame(ProcessingFrame const &)=0
virtual ~Producer() noexcept
virtual void produceWithFrame(Event &, ProcessingFrame const &)=0