#include "Schedule.h"

Public Member Functions
	Schedule (ScheduleID sid, PathManager &pm, ActionTable const &actions, ActivityRegistry const &aReg, UpdateOutputCallbacks &outputCallbacks, GlobalTaskGroup &task_group)

	Schedule (Schedule const &)=delete

	Schedule (Schedule &&)=delete

Schedule &	operator= (Schedule const &)=delete

Schedule &	operator= (Schedule &&)=delete

void	process (Transition, Principal &)

void	process_event_modifiers (hep::concurrency::WaitingTaskPtr endPathTask)

void	process_event_observers (hep::concurrency::WaitingTaskPtr finalizeEventTask)

void	beginJob (detail::SharedResources const &resources)

void	endJob ()

void	respondToOpenInputFile (FileBlock const &)

void	respondToCloseInputFile (FileBlock const &)

void	respondToOpenOutputFiles (FileBlock const &)

void	respondToCloseOutputFiles (FileBlock const &)

bool	outputsToOpen () const

bool	outputsToClose () const

void	recordOutputClosureRequests (Granularity const granularity)

bool	someOutputsOpen () const

void	closeAllOutputFiles ()

void	openSomeOutputFiles (FileBlock const &fb)

void	closeSomeOutputFiles ()

void	writeEvent ()

void	incrementInputFileNumber ()

void	setOutputFileStatus (OutputFileStatus const ofs)

OutputFileStatus	fileStatus () const

void	seedRunRangeSet (RangeSetHandler const &rsh)

void	setRunAuxiliaryRangeSetID (RangeSet const &rs)

void	writeRun (RunPrincipal &rp)

RangeSetHandler const &	runRangeSetHandler ()

void	seedSubRunRangeSet (RangeSetHandler const &rsh)

void	setSubRunAuxiliaryRangeSetID (RangeSet const &rs)

void	writeSubRun (SubRunPrincipal &srp)

RangeSetHandler const &	subRunRangeSetHandler ()

void	accept_principal (std::unique_ptr< EventPrincipal > principal)

EventPrincipal &	event_principal ()

Private Attributes
ScheduleContext const	context_

ActionTable const &	actions_

EndPathExecutor	epExec_

TriggerPathsExecutor	tpsExec_

std::unique_ptr< EventPrincipal >	eventPrincipal_ {nullptr}

Detailed Description

Definition at line 32 of file Schedule.h.

Constructor & Destructor Documentation

art::Schedule::Schedule	(	ScheduleID	sid,
		PathManager &	pm,
		ActionTable const &	actions,
		ActivityRegistry const &	aReg,
		UpdateOutputCallbacks &	outputCallbacks,
		GlobalTaskGroup &	task_group
	)

Definition at line 18 of file Schedule.cc.

References actions_, epExec_, TDEBUG_FUNC_SI, and tpsExec_.

     : context_{scheduleID}
     , actions_{actions}
     , epExec_{scheduleID, pm, actions, outputCallbacks, task_group}
     , tpsExec_{scheduleID, pm, actions, actReg, task_group}
   {
     TDEBUG_FUNC_SI(5, scheduleID) << hex << this << dec;
   }

art::Schedule::Schedule ( Schedule const & )

delete

art::Schedule::Schedule ( Schedule && )

delete

Member Function Documentation

void art::Schedule::accept_principal ( std::unique_ptr< EventPrincipal > principal )

inline

Definition at line 178 of file Schedule.h.

Referenced by art::EventProcessor::readAndProcessAsync().

     {
       assert(principal);
       eventPrincipal_ = std::move(principal);
     }

void art::Schedule::beginJob ( detail::SharedResources const & resources )

Definition at line 33 of file Schedule.cc.

References art::EndPathExecutor::beginJob(), art::TriggerPathsExecutor::beginJob(), epExec_, and tpsExec_.

Referenced by art::EventProcessor::beginJob().

   {
     tpsExec_.beginJob(resources);
     epExec_.beginJob(resources);
   }

void art::Schedule::closeAllOutputFiles ( )

inline

Definition at line 85 of file Schedule.h.

Referenced by art::EventProcessor::closeAllOutputFiles().

     {
       epExec_.closeAllOutputFiles();
     }

void art::Schedule::closeSomeOutputFiles ( )

inline

Definition at line 97 of file Schedule.h.

Referenced by art::EventProcessor::closeSomeOutputFiles(), and art::EventProcessor::process().

     {
       epExec_.closeSomeOutputFiles();
     }

void art::Schedule::endJob ( )

Definition at line 40 of file Schedule.cc.

References art::EndPathExecutor::endJob(), art::TriggerPathsExecutor::endJob(), epExec_, and tpsExec_.

Referenced by art::EventProcessor::endJobAllSchedules().

   {
     tpsExec_.endJob();
     epExec_.endJob();
   }

EventPrincipal& art::Schedule::event_principal ( )

inline

Definition at line 185 of file Schedule.h.

Referenced by art::EventProcessor::finishEventAsync().

     {
       assert(eventPrincipal_);
       return *eventPrincipal_;
     }

OutputFileStatus art::Schedule::fileStatus ( ) const

inline

Definition at line 124 of file Schedule.h.

     {
       return epExec_.fileStatus_.load();
     }

void art::Schedule::incrementInputFileNumber ( )

inline

Definition at line 112 of file Schedule.h.

Referenced by art::EventProcessor::closeInputFile().

     {
       epExec_.incrementInputFileNumber();
     }

void art::Schedule::openSomeOutputFiles ( FileBlock const & fb )

inline

Definition at line 91 of file Schedule.h.

Referenced by art::EventProcessor::openSomeOutputFiles().

     {
       epExec_.openSomeOutputFiles(fb);
     }

Schedule& art::Schedule::operator= ( Schedule const & )

delete

Schedule& art::Schedule::operator= ( Schedule && )

delete

bool art::Schedule::outputsToClose ( ) const

inline

Definition at line 67 of file Schedule.h.

Referenced by art::EventProcessor::levelsToProcess().

     {
       return epExec_.outputsToClose();
     }

bool art::Schedule::outputsToOpen ( ) const

inline

Definition at line 61 of file Schedule.h.

Referenced by art::EventProcessor::outputsToOpen().

     {
       return epExec_.outputsToOpen();
     }

void art::Schedule::process	(	Transition	trans,
		Principal &	principal
	)

Definition at line 75 of file Schedule.cc.

References epExec_, art::TriggerPathsExecutor::process(), art::EndPathExecutor::process(), and tpsExec_.

Referenced by art::EventProcessor::beginRun(), art::EventProcessor::beginSubRun(), art::EventProcessor::endRun(), and art::EventProcessor::endSubRun().

   {
     tpsExec_.process(trans, principal);
     epExec_.process(trans, principal);
   }

void art::Schedule::process_event_modifiers ( hep::concurrency::WaitingTaskPtr endPathTask )

Definition at line 82 of file Schedule.cc.

References eventPrincipal_, art::TriggerPathsExecutor::process_event(), and tpsExec_.

Referenced by art::EventProcessor::processEventAsync().

   {
     tpsExec_.process_event(endPathTask, *eventPrincipal_);
   }

void art::Schedule::process_event_observers ( hep::concurrency::WaitingTaskPtr finalizeEventTask )

Definition at line 88 of file Schedule.cc.

References epExec_, eventPrincipal_, and art::EndPathExecutor::process_event().

   {
     epExec_.process_event(finalizeEventTask, *eventPrincipal_);
   }

void art::Schedule::recordOutputClosureRequests ( Granularity const granularity )

inline

Definition at line 73 of file Schedule.h.

Referenced by art::EventProcessor::closeInputFile(), art::EventProcessor::recordOutputModuleClosureRequests< Level::Event >(), art::EventProcessor::recordOutputModuleClosureRequests< Level::Run >(), art::EventProcessor::recordOutputModuleClosureRequests< Level::SubRun >(), and art::EventProcessor::finishEventAsync().

     {
       return epExec_.recordOutputClosureRequests(granularity);
     }

void art::Schedule::respondToCloseInputFile ( FileBlock const & fb )

Definition at line 54 of file Schedule.cc.

References epExec_, art::EndPathExecutor::respondToCloseInputFile(), art::TriggerPathsExecutor::respondToCloseInputFile(), and tpsExec_.

Referenced by art::EventProcessor::respondToCloseInputFile().

   {
     tpsExec_.respondToCloseInputFile(fb);
     epExec_.respondToCloseInputFile(fb);
   }

void art::Schedule::respondToCloseOutputFiles ( FileBlock const & fb )

Definition at line 68 of file Schedule.cc.

References epExec_, art::EndPathExecutor::respondToCloseOutputFiles(), art::TriggerPathsExecutor::respondToCloseOutputFiles(), and tpsExec_.

Referenced by art::EventProcessor::respondToCloseOutputFiles().

   {
     tpsExec_.respondToCloseOutputFiles(fb);
     epExec_.respondToCloseOutputFiles(fb);
   }

void art::Schedule::respondToOpenInputFile ( FileBlock const & fb )

Definition at line 47 of file Schedule.cc.

References epExec_, art::EndPathExecutor::respondToOpenInputFile(), art::TriggerPathsExecutor::respondToOpenInputFile(), and tpsExec_.

Referenced by art::EventProcessor::respondToOpenInputFile().

   {
     tpsExec_.respondToOpenInputFile(fb);
     epExec_.respondToOpenInputFile(fb);
   }

void art::Schedule::respondToOpenOutputFiles ( FileBlock const & fb )

Definition at line 61 of file Schedule.cc.

References epExec_, art::EndPathExecutor::respondToOpenOutputFiles(), art::TriggerPathsExecutor::respondToOpenOutputFiles(), and tpsExec_.

Referenced by art::EventProcessor::respondToOpenOutputFiles().

   {
     tpsExec_.respondToOpenOutputFiles(fb);
     epExec_.respondToOpenOutputFiles(fb);
   }

RangeSetHandler const& art::Schedule::runRangeSetHandler ( )

inline

Definition at line 149 of file Schedule.h.

Referenced by art::EventProcessor::setRunAuxiliaryRangeSetID(), and art::EventProcessor::setSubRunAuxiliaryRangeSetID().

     {
       return *epExec_.runRangeSetHandler_.get();
     }

void art::Schedule::seedRunRangeSet ( RangeSetHandler const & rsh )

inline

Definition at line 131 of file Schedule.h.

Referenced by art::EventProcessor::readRun(), and art::EventProcessor::setSubRunAuxiliaryRangeSetID().

     {
       epExec_.seedRunRangeSet(rsh);
     }

void art::Schedule::seedSubRunRangeSet ( RangeSetHandler const & rsh )

inline

Definition at line 156 of file Schedule.h.

Referenced by art::EventProcessor::readSubRun(), and art::EventProcessor::setSubRunAuxiliaryRangeSetID().

     {
       epExec_.seedSubRunRangeSet(rsh);
     }

void art::Schedule::setOutputFileStatus ( OutputFileStatus const ofs )

inline

Definition at line 118 of file Schedule.h.

Referenced by art::EventProcessor::setOutputFileStatus().

     {
       epExec_.setOutputFileStatus(ofs);
     }

void art::Schedule::setRunAuxiliaryRangeSetID ( RangeSet const & rs )

inline

Definition at line 137 of file Schedule.h.

Referenced by art::EventProcessor::setRunAuxiliaryRangeSetID().

     {
       epExec_.setRunAuxiliaryRangeSetID(rs);
     }

void art::Schedule::setSubRunAuxiliaryRangeSetID ( RangeSet const & rs )

inline

Definition at line 161 of file Schedule.h.

Referenced by art::EventProcessor::setSubRunAuxiliaryRangeSetID().

     {
       epExec_.setSubRunAuxiliaryRangeSetID(rs);
     }

bool art::Schedule::someOutputsOpen ( ) const

inline

Definition at line 79 of file Schedule.h.

     {
       return epExec_.someOutputsOpen();
     }

RangeSetHandler const& art::Schedule::subRunRangeSetHandler ( )

inline

Definition at line 172 of file Schedule.h.

Referenced by art::EventProcessor::setSubRunAuxiliaryRangeSetID().

     {
       return *epExec_.subRunRangeSetHandler_.get();
     }

void art::Schedule::writeEvent ( )

inline

Definition at line 103 of file Schedule.h.

Referenced by art::EventProcessor::finishEventAsync().

     {
       assert(eventPrincipal_);
       epExec_.writeEvent(*eventPrincipal_);
       // Delete principal
       eventPrincipal_.reset();
     }

void art::Schedule::writeRun ( RunPrincipal & rp )

inline

Definition at line 143 of file Schedule.h.

Referenced by art::EventProcessor::writeRun().

     {
       epExec_.writeRun(rp);
     }

void art::Schedule::writeSubRun ( SubRunPrincipal & srp )

inline

Definition at line 166 of file Schedule.h.

Referenced by art::EventProcessor::writeSubRun().

     {
       epExec_.writeSubRun(srp);
     }

Member Data Documentation

ActionTable const& art::Schedule::actions_

private

Definition at line 195 of file Schedule.h.

Referenced by Schedule().

ScheduleContext const art::Schedule::context_

private

Definition at line 191 of file Schedule.h.

EndPathExecutor art::Schedule::epExec_

private

Definition at line 196 of file Schedule.h.

Referenced by beginJob(), endJob(), process(), process_event_observers(), respondToCloseInputFile(), respondToCloseOutputFiles(), respondToOpenInputFile(), respondToOpenOutputFiles(), and Schedule().

std::unique_ptr<EventPrincipal> art::Schedule::eventPrincipal_ {nullptr}

private

Definition at line 198 of file Schedule.h.

Referenced by process_event_modifiers(), and process_event_observers().

TriggerPathsExecutor art::Schedule::tpsExec_

private

Definition at line 197 of file Schedule.h.

Referenced by beginJob(), endJob(), process(), process_event_modifiers(), respondToCloseInputFile(), respondToCloseOutputFiles(), respondToOpenInputFile(), respondToOpenOutputFiles(), and Schedule().

The documentation for this class was generated from the following files:

art/Framework/Core/Schedule.h
art/Framework/Core/Schedule.cc

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation