#include <Schedule.h>

Public Member Functions
	Schedule (ScheduleID sid, PathManager &pm, ActionTable const &actions, ActivityRegistry const &aReg, UpdateOutputCallbacks &outputCallbacks, std::unique_ptr< Worker > triggerResultsInserter, 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

bool	allAtLimit () 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_

ActivityRegistry const &	actReg_

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,
		std::unique_ptr< Worker >	triggerResultsInserter,
		GlobalTaskGroup &	task_group
	)

Definition at line 21 of file Schedule.cc.

     : context_{scheduleID}
     , actions_{actions}
     , actReg_{actReg}
     , epExec_{scheduleID, pm, actions, actReg_, outputCallbacks, task_group}
     , tpsExec_{scheduleID,
                pm,
                actions,
                move(triggerResultsInserter),
                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 185 of file Schedule.h.

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

bool art::Schedule::allAtLimit ( ) const

inline

Definition at line 131 of file Schedule.h.

     {
       return epExec_.allAtLimit();
     }

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

Definition at line 42 of file Schedule.cc.

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

void art::Schedule::closeAllOutputFiles ( )

inline

Definition at line 86 of file Schedule.h.

     {
       epExec_.closeAllOutputFiles();
     }

void art::Schedule::closeSomeOutputFiles ( )

inline

Definition at line 98 of file Schedule.h.

     {
       epExec_.closeSomeOutputFiles();
     }

void art::Schedule::endJob ( )

Definition at line 49 of file Schedule.cc.

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

EventPrincipal& art::Schedule::event_principal ( )

inline

Definition at line 192 of file Schedule.h.

     {
       assert(eventPrincipal_);
       return *eventPrincipal_;
     }

OutputFileStatus art::Schedule::fileStatus ( ) const

inline

Definition at line 125 of file Schedule.h.

     {
       return epExec_.fileStatus_.load();
     }

void art::Schedule::incrementInputFileNumber ( )

inline

Definition at line 113 of file Schedule.h.

     {
       epExec_.incrementInputFileNumber();
     }

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

inline

Definition at line 92 of file Schedule.h.

     {
       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 68 of file Schedule.h.

     {
       return epExec_.outputsToClose();
     }

bool art::Schedule::outputsToOpen ( ) const

inline

Definition at line 62 of file Schedule.h.

     {
       return epExec_.outputsToOpen();
     }

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

Definition at line 84 of file Schedule.cc.

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

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

Definition at line 91 of file Schedule.cc.

   {
     // We get here as part of the readAndProcessEvent task.
     actReg_.sPreProcessEvent.invoke(
       Event{*eventPrincipal_, ModuleContext::invalid()}, context_);
     tpsExec_.process_event(endPathTask, *eventPrincipal_);
   }

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

Definition at line 100 of file Schedule.cc.

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

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

inline

Definition at line 74 of file Schedule.h.

     {
       return epExec_.recordOutputClosureRequests(granularity);
     }

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

Definition at line 63 of file Schedule.cc.

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

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

Definition at line 77 of file Schedule.cc.

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

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

Definition at line 56 of file Schedule.cc.

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

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

Definition at line 70 of file Schedule.cc.

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

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

inline

Definition at line 156 of file Schedule.h.

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

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

inline

Definition at line 138 of file Schedule.h.

     {
       epExec_.seedRunRangeSet(rsh);
     }

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

inline

Definition at line 163 of file Schedule.h.

     {
       epExec_.seedSubRunRangeSet(rsh);
     }

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

inline

Definition at line 119 of file Schedule.h.

     {
       epExec_.setOutputFileStatus(ofs);
     }

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

inline

Definition at line 144 of file Schedule.h.

     {
       epExec_.setRunAuxiliaryRangeSetID(rs);
     }

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

inline

Definition at line 168 of file Schedule.h.

     {
       epExec_.setSubRunAuxiliaryRangeSetID(rs);
     }

bool art::Schedule::someOutputsOpen ( ) const

inline

Definition at line 80 of file Schedule.h.

     {
       return epExec_.someOutputsOpen();
     }

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

inline

Definition at line 179 of file Schedule.h.

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

void art::Schedule::writeEvent ( )

inline

Definition at line 104 of file Schedule.h.

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

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

inline

Definition at line 150 of file Schedule.h.

     {
       epExec_.writeRun(rp);
     }

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

inline

Definition at line 173 of file Schedule.h.

     {
       epExec_.writeSubRun(srp);
     }

Member Data Documentation

ActionTable const& art::Schedule::actions_

private

Definition at line 202 of file Schedule.h.

ActivityRegistry const& art::Schedule::actReg_

private

Definition at line 203 of file Schedule.h.

ScheduleContext const art::Schedule::context_

private

Definition at line 198 of file Schedule.h.

EndPathExecutor art::Schedule::epExec_

private

Definition at line 204 of file Schedule.h.

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

private

Definition at line 206 of file Schedule.h.

TriggerPathsExecutor art::Schedule::tpsExec_

private

Definition at line 205 of file Schedule.h.

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

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

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation