1 #ifndef art_Framework_Core_Schedule_h 2 #define art_Framework_Core_Schedule_h 44 #include "hep_concurrency/WaitingTask.h" 57 class ActivityRegistry;
58 class UpdateOutputCallbacks;
79 void process_event(hep::concurrency::WaitingTask* endPathTask,
80 tbb::task* eventLoopTask,
90 void pathsDoneTask(hep::concurrency::WaitingTask* endPathTask,
91 tbb::task* eventLoopTask,
93 std::exception_ptr
const*);
97 tbb::task* eventLoopTask,
void respondToCloseOutputFiles(FileBlock const &)
void respondToCloseInputFile(FileBlock const &)
std::atomic< PathsInfo * > triggerPathsInfo_
void process(Transition, Principal &)
std::vector< BranchDescription > ProductDescriptions
ScheduleContext const sc_
void pathsDoneTask(hep::concurrency::WaitingTask *endPathTask, tbb::task *eventLoopTask, EventPrincipal &, std::exception_ptr const *)
std::atomic< Worker * > results_inserter_
void respondToOpenOutputFiles(FileBlock const &)
std::atomic< int > runningWorkerCnt_
std::atomic< ActionTable const * > actionTable_
std::atomic< ActivityRegistry const * > actReg_
Service to store calibration data products (CDP) in the SQLite3 metadatabase of a file...
void process_event_pathsDone(hep::concurrency::WaitingTask *endPathTask, tbb::task *eventLoopTask, EventPrincipal &)
void respondToOpenInputFile(FileBlock const &)
bool skipNonReplicated_(Worker const &)
Schedule(ScheduleID, PathManager &, std::string const &processName, fhicl::ParameterSet const &proc_pset, fhicl::ParameterSet const &trig_pset, UpdateOutputCallbacks &, ProductDescriptions &, ActionTable const &, ActivityRegistry const &)
void process_event(hep::concurrency::WaitingTask *endPathTask, tbb::task *eventLoopTask, EventPrincipal &)
Schedule & operator=(Schedule const &)=delete