#include "/cvmfs/nova.opensciencegrid.org/externals/art/v2_13_00/source/art/Framework/Core/EndPathExecutor.h"

Public Member Functions
	EndPathExecutor (PathManager &pm, ActionTable &actions, ActivityRegistry &areg, MasterProductRegistry &mpr, bool const parentageEnabled, bool const rangesEnabled)

template<typename T >
void	process (typename T::MyPrincipal &principal)

void	beginJob ()

void	endJob ()

void	writeEvent (EventPrincipal &ep)

void	writeSubRun (SubRunPrincipal &srp)

void	writeRun (RunPrincipal &rp)

void	seedRunRangeSet (std::unique_ptr< RangeSetHandler >)

void	seedSubRunRangeSet (std::unique_ptr< RangeSetHandler >)

void	setAuxiliaryRangeSetID (SubRunPrincipal &srp)

void	setAuxiliaryRangeSetID (RunPrincipal &rp)

void	closeAllOutputFiles ()

void	openAllOutputFiles (FileBlock &fb)

void	closeSomeOutputFiles ()

void	openSomeOutputFiles (FileBlock const &fb)

void	setOutputFileStatus (OutputFileStatus)

void	respondToOpenInputFile (FileBlock const &fb)

void	respondToCloseInputFile (FileBlock const &fb)

void	respondToOpenOutputFiles (FileBlock const &fb)

void	respondToCloseOutputFiles (FileBlock const &fb)

void	recordOutputClosureRequests (Granularity)

bool	outputsToOpen () const

bool	outputsToClose () const

bool	someOutputsOpen () const

void	incrementInputFileNumber ()

bool	terminate () const

void	selectProducts (ProductList const &)

Private Types
using	OutputWorkers = std::vector< OutputWorker * >

using	OutputWorkerSet = std::set< OutputWorker * >

Private Member Functions
void	resetAll ()

template<typename T >
void	runEndPaths (typename T::MyPrincipal &)

template<class F >
void	doForAllEnabledWorkers_ (F f)

template<class F >
void	doForAllEnabledOutputWorkers_ (F f)

Private Attributes
PathsInfo &	endPathInfo_

ActionTable *	act_table_

ActivityRegistry &	actReg_

OutputWorkers	outputWorkers_

OutputWorkerSet	outputWorkersToOpen_

OutputWorkerSet	outputWorkersToClose_ {}

std::vector< unsigned char >	workersEnabled_

std::vector< unsigned char >	outputWorkersEnabled_

OutputFileStatus	fileStatus_ {OutputFileStatus::Closed}

std::unique_ptr< RangeSetHandler >	runRangeSetHandler_ {nullptr}

std::unique_ptr< RangeSetHandler >	subRunRangeSetHandler_ {nullptr}

bool const	parentageEnabled_ {true}

bool const	rangesEnabled_ {true}

Detailed Description

Definition at line 41 of file EndPathExecutor.h.

Member Typedef Documentation

using art::EndPathExecutor::OutputWorkers = std::vector<OutputWorker*>

private

Definition at line 92 of file EndPathExecutor.h.

using art::EndPathExecutor::OutputWorkerSet = std::set<OutputWorker*>

private

Definition at line 93 of file EndPathExecutor.h.

Constructor & Destructor Documentation

art::EndPathExecutor::EndPathExecutor	(	PathManager &	pm,
		ActionTable &	actions,
		ActivityRegistry &	areg,
		MasterProductRegistry &	mpr,
		bool const	parentageEnabled,
		bool const	rangesEnabled
	)

Member Function Documentation

void art::EndPathExecutor::beginJob ( )

void art::EndPathExecutor::closeAllOutputFiles ( )

void art::EndPathExecutor::closeSomeOutputFiles ( )

template<class F >

void art::EndPathExecutor::doForAllEnabledOutputWorkers_ ( F f )

private

Definition at line 174 of file EndPathExecutor.h.

References fcn, allTimeWatchdog::index, outputWorkers_, and outputWorkersEnabled_.

 {
   size_t index{0};
   for (auto ow : outputWorkers_) {
     if (outputWorkersEnabled_[index++]) {
       fcn(ow);
     }
   }
 }

template<class F >

void art::EndPathExecutor::doForAllEnabledWorkers_ ( F f )

private

Definition at line 162 of file EndPathExecutor.h.

References endPathInfo_, fcn, allTimeWatchdog::index, febshutoff_auto::val, art::PathsInfo::workers(), and workersEnabled_.

 {
   size_t index{0};
   for (auto const& val : endPathInfo_.workers()) {
     if (workersEnabled_[index++]) {
       fcn(val.second.get());
     }
   }
 }

void art::EndPathExecutor::endJob ( )

void art::EndPathExecutor::incrementInputFileNumber ( )

void art::EndPathExecutor::openAllOutputFiles ( FileBlock & fb )

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

bool art::EndPathExecutor::outputsToClose ( ) const

bool art::EndPathExecutor::outputsToOpen ( ) const

template<typename T >

void art::EndPathExecutor::process ( typename T::MyPrincipal & principal )

Definition at line 122 of file EndPathExecutor.h.

References act_table_, plot_validation_datamc::action, art::PathsInfo::addEvent(), art::PathsInfo::addPass(), endPathInfo_, lem_server::ep, art::Event, art::errors::EventProcessorFailure, art::ActionTable::find(), art::actions::IgnoreCompletely, art::PathsInfo::pathPtrs(), resetAll(), art::actions::Rethrow, T, and cet::trim_right_copy().

 {
   this->resetAll();
 
   if (T::level == Level::Event) {
     endPathInfo_.addEvent();
   }
   try {
     if (!endPathInfo_.pathPtrs().empty()) {
       endPathInfo_.pathPtrs().front()->process<T>(ep);
     }
   }
   catch (cet::exception& ex) {
     actions::ActionCodes const action{T::level == Level::Event ?
                                         act_table_->find(ex.root_cause()) :
                                         actions::Rethrow};
     switch (action) {
       case actions::IgnoreCompletely: {
         mf::LogWarning(ex.category())
           << "exception being ignored for current event:\n"
           << cet::trim_right_copy(ex.what(), " \n");
         break;
       }
       default: {
         throw art::Exception(errors::EventProcessorFailure, "EndPathExecutor:")
           << "an exception occurred during current event processing\n"
           << ex;
       }
     }
   }
   catch (...) {
     mf::LogError("PassingThrough")
       << "an exception occurred during current event processing\n";
     throw;
   }
   endPathInfo_.addPass();
 }

void art::EndPathExecutor::recordOutputClosureRequests ( Granularity )

void art::EndPathExecutor::resetAll ( )

private

Referenced by process().

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

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

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

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

template<typename T >

void art::EndPathExecutor::runEndPaths ( typename T::MyPrincipal & )

private

void art::EndPathExecutor::seedRunRangeSet ( std::unique_ptr< RangeSetHandler > )

void art::EndPathExecutor::seedSubRunRangeSet ( std::unique_ptr< RangeSetHandler > )

void art::EndPathExecutor::selectProducts ( ProductList const & )

void art::EndPathExecutor::setAuxiliaryRangeSetID ( SubRunPrincipal & srp )

void art::EndPathExecutor::setAuxiliaryRangeSetID ( RunPrincipal & rp )

void art::EndPathExecutor::setOutputFileStatus ( OutputFileStatus )

bool art::EndPathExecutor::someOutputsOpen ( ) const

bool art::EndPathExecutor::terminate ( ) const

void art::EndPathExecutor::writeEvent ( EventPrincipal & ep )

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

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

Member Data Documentation

ActionTable* art::EndPathExecutor::act_table_

private

Definition at line 106 of file EndPathExecutor.h.

Referenced by process().

ActivityRegistry& art::EndPathExecutor::actReg_

private

Definition at line 107 of file EndPathExecutor.h.

PathsInfo& art::EndPathExecutor::endPathInfo_

private

Definition at line 105 of file EndPathExecutor.h.

Referenced by doForAllEnabledWorkers_(), and process().

OutputFileStatus art::EndPathExecutor::fileStatus_ {OutputFileStatus::Closed}

private

Definition at line 113 of file EndPathExecutor.h.

OutputWorkers art::EndPathExecutor::outputWorkers_

private

Definition at line 108 of file EndPathExecutor.h.

Referenced by doForAllEnabledOutputWorkers_().

std::vector<unsigned char> art::EndPathExecutor::outputWorkersEnabled_

private

Definition at line 112 of file EndPathExecutor.h.

Referenced by doForAllEnabledOutputWorkers_().

OutputWorkerSet art::EndPathExecutor::outputWorkersToClose_ {}

private

Definition at line 110 of file EndPathExecutor.h.

OutputWorkerSet art::EndPathExecutor::outputWorkersToOpen_

private

Definition at line 109 of file EndPathExecutor.h.

bool const art::EndPathExecutor::parentageEnabled_ {true}

private

Definition at line 116 of file EndPathExecutor.h.

bool const art::EndPathExecutor::rangesEnabled_ {true}

private

Definition at line 117 of file EndPathExecutor.h.

std::unique_ptr<RangeSetHandler> art::EndPathExecutor::runRangeSetHandler_ {nullptr}

private

Definition at line 114 of file EndPathExecutor.h.

std::unique_ptr<RangeSetHandler> art::EndPathExecutor::subRunRangeSetHandler_ {nullptr}

private

Definition at line 115 of file EndPathExecutor.h.

std::vector<unsigned char> art::EndPathExecutor::workersEnabled_

private

Definition at line 111 of file EndPathExecutor.h.

Referenced by doForAllEnabledWorkers_().

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

art/Framework/Core/EndPathExecutor.h

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation