1 #ifndef art_Framework_Core_Schedule_h 2 #define art_Framework_Core_Schedule_h 27 class ActivityRegistry;
29 class SharedResources;
49 void process_event_modifiers(hep::concurrency::WaitingTaskPtr endPathTask);
50 void process_event_observers(
51 hep::concurrency::WaitingTaskPtr finalizeEventTask);
54 void respondToOpenInputFile(
FileBlock const&);
55 void respondToCloseInputFile(
FileBlock const&);
56 void respondToOpenOutputFiles(
FileBlock const&);
57 void respondToCloseOutputFiles(
FileBlock const&);
63 return epExec_.outputsToOpen();
69 return epExec_.outputsToClose();
75 return epExec_.recordOutputClosureRequests(granularity);
81 return epExec_.someOutputsOpen();
87 epExec_.closeAllOutputFiles();
93 epExec_.openSomeOutputFiles(fb);
99 epExec_.closeSomeOutputFiles();
105 assert(eventPrincipal_);
106 epExec_.writeEvent(*eventPrincipal_);
108 eventPrincipal_.reset();
114 epExec_.incrementInputFileNumber();
120 epExec_.setOutputFileStatus(ofs);
126 return epExec_.fileStatus_.load();
133 epExec_.seedRunRangeSet(rsh);
139 epExec_.setRunAuxiliaryRangeSetID(rs);
145 epExec_.writeRun(rp);
151 return *epExec_.runRangeSetHandler_.get();
158 epExec_.seedSubRunRangeSet(rsh);
163 epExec_.setSubRunAuxiliaryRangeSetID(rs);
168 epExec_.writeSubRun(srp);
174 return *epExec_.subRunRangeSetHandler_.get();
181 eventPrincipal_ = std::move(principal);
187 assert(eventPrincipal_);
188 return *eventPrincipal_;
191 class EndPathRunnerTask;
198 std::unique_ptr<EventPrincipal> eventPrincipal_{
nullptr};
void closeAllOutputFiles()
void setSubRunAuxiliaryRangeSetID(RangeSet const &rs)
RangeSetHandler const & runRangeSetHandler()
bool outputsToClose() const
void seedSubRunRangeSet(RangeSetHandler const &rsh)
ScheduleContext const context_
void setRunAuxiliaryRangeSetID(RangeSet const &rs)
TriggerPathsExecutor tpsExec_
EventPrincipal & event_principal()
RangeSetHandler const & subRunRangeSetHandler()
void recordOutputClosureRequests(Granularity const granularity)
OutputFileStatus fileStatus() const
void incrementInputFileNumber()
bool outputsToOpen() const
ActionTable const & actions_
void closeSomeOutputFiles()
void accept_principal(std::unique_ptr< EventPrincipal > principal)
void seedRunRangeSet(RangeSetHandler const &rsh)
void writeRun(RunPrincipal &rp)
void openSomeOutputFiles(FileBlock const &fb)
void writeSubRun(SubRunPrincipal &srp)
void setOutputFileStatus(OutputFileStatus const ofs)
bool someOutputsOpen() const