Inheritance diagram for arttest::EventProcessorTestOutput:

Classes
struct	Config

Public Types
using	Parameters = fhicl::WrappedTable< Config, OutputModule::Config::KeysToIgnore >

Public Types inherited from art::OutputModule
using	ModuleType = OutputModule

using	WorkerType = OutputWorker

using	PluginCollection_t = std::vector< std::unique_ptr< FileCatalogMetadataPlugin >>

Public Member Functions
	EventProcessorTestOutput (Parameters const &ps)

Public Member Functions inherited from art::OutputModule
virtual	~OutputModule () noexcept

	OutputModule (fhicl::ParameterSet const &pset)

	OutputModule (fhicl::TableFragment< Config > const &pset, fhicl::ParameterSet const &containing_pset)

	OutputModule (OutputModule const &)=delete

	OutputModule (OutputModule &&)=delete

OutputModule &	operator= (OutputModule const &)=delete

OutputModule &	operator= (OutputModule &&)=delete

int	maxEvents () const

int	remainingEvents () const

bool	fileIsOpen () const

OutputFileStatus	fileStatus () const

virtual std::string const &	lastClosedFileName () const

SelectionsArray const &	keptProducts () const

bool	selected (BranchDescription const &) const

std::array< bool, NumBranchTypes > const &	hasNewlyDroppedBranch () const

void	selectProducts (ProductTables const &)

void	doSelectProducts (ProductTables const &)

void	registerProducts (ProductDescriptions &, ModuleDescription const &)

BranchChildren const &	branchChildren () const

Public Member Functions inherited from art::Observer
	~Observer () noexcept

	Observer (Observer const &)=delete

	Observer (Observer &&)=delete

Observer &	operator= (Observer const &)=delete

Observer &	operator= (Observer &&)=delete

void	registerProducts (ProductDescriptions &, ModuleDescription const &)

void	fillDescriptions (ModuleDescription const &)

fhicl::ParameterSetID	selectorConfig () const

Public Member Functions inherited from art::ModuleBase
virtual	~ModuleBase () noexcept

	ModuleBase ()

ModuleDescription const &	moduleDescription () const

void	setModuleDescription (ModuleDescription const &)

std::array< std::vector< ProductInfo >, NumBranchTypes > const &	getConsumables () const

void	sortConsumables (std::string const &current_process_name)

template<typename T , BranchType BT>
ViewToken< T >	consumesView (InputTag const &tag)

template<typename T , BranchType BT>
ViewToken< T >	mayConsumeView (InputTag const &tag)

Public Member Functions inherited from art::detail::SharedModule
	SharedModule ()

	SharedModule (std::string const &moduleLabel)

hep::concurrency::SerialTaskQueueChain *	serialTaskQueueChain () const

std::set< std::string > const &	sharedResources () const

void	createQueues (SharedResources const &resources)

template<BranchType , typename... T>
void	serialize (T const &...resources)

template<BranchType , typename... T>
void	serializeExternal (T const &...resources)

Private Member Functions
void	respondToOpenInputFile (FileBlock const &fb) override

void	write (EventPrincipal &ep) override

void	writeSubRun (SubRunPrincipal &srp) override

void	writeRun (RunPrincipal &rp) override

void	incrementInputFileNumber () override

bool	requestsToCloseFile () const override

Granularity	fileGranularity () const override

void	updateSwitchPoints ()

Private Attributes
std::vector< SwitchPoint >	switchPoints_

SwitchPoint	activeSwitchPoint_ {}

std::string	currentInputFileName_ {}

bool	requestsFileClose_ {false}

Additional Inherited Members
Protected Member Functions inherited from art::OutputModule
virtual void	doRegisterProducts (ProductDescriptions &, ModuleDescription const &)

Protected Member Functions inherited from art::Observer
std::string const &	processName () const

bool	wantAllEvents () const noexcept

bool	wantEvent (ScheduleID id, Event const &e) const

Handle< TriggerResults >	getTriggerResults (Event const &e) const

	Observer (fhicl::ParameterSet const &config)

	Observer (std::vector< std::string > const &select_paths, std::vector< std::string > const &reject_paths, fhicl::ParameterSet const &config)

Protected Member Functions inherited from art::ModuleBase
ConsumesCollector &	consumesCollector ()

template<typename T , BranchType = InEvent>
ProductToken< T >	consumes (InputTag const &)

template<typename Element , BranchType = InEvent>
ViewToken< Element >	consumesView (InputTag const &)

template<typename T , BranchType = InEvent>
void	consumesMany ()

template<typename T , BranchType = InEvent>
ProductToken< T >	mayConsume (InputTag const &)

template<typename Element , BranchType = InEvent>
ViewToken< Element >	mayConsumeView (InputTag const &)

template<typename T , BranchType = InEvent>
void	mayConsumeMany ()

Protected Member Functions inherited from art::detail::SharedModule
template<BranchType BT = InEvent, typename... T>
void	serialize (T const &...)

template<BranchType BT = InEvent, typename... T>
void	serializeExternal (T const &...)

template<BranchType BT = InEvent>
void	async ()

Detailed Description

Definition at line 114 of file EventProcessorTestOutput_module.cc.

Member Typedef Documentation

using arttest::EventProcessorTestOutput::Parameters = fhicl::WrappedTable<Config, OutputModule::Config::KeysToIgnore>

Definition at line 126 of file EventProcessorTestOutput_module.cc.

Constructor & Destructor Documentation

arttest::EventProcessorTestOutput::EventProcessorTestOutput ( Parameters const & ps )

inlineexplicit

Definition at line 127 of file EventProcessorTestOutput_module.cc.

       : OutputModule{ps().omConfig, ps.get_PSet()}
       , switchPoints_{ps().switchAfter()}
     {
       if (!switchPoints_.empty()) {
         activeSwitchPoint_ = switchPoints_.front();
       }
     }

Member Function Documentation

Granularity arttest::EventProcessorTestOutput::fileGranularity ( ) const

inlineoverrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 189 of file EventProcessorTestOutput_module.cc.

     {
       return Granularity::Event;
     }

void arttest::EventProcessorTestOutput::incrementInputFileNumber ( )

inlineoverrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 174 of file EventProcessorTestOutput_module.cc.

     {
       requestsFileClose_ = activeSwitchPoint_.matches(currentInputFileName_);
       if (requestsFileClose_) {
         updateSwitchPoints();
       }
     }

bool arttest::EventProcessorTestOutput::requestsToCloseFile ( ) const

inlineoverrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 183 of file EventProcessorTestOutput_module.cc.

     {
       return requestsFileClose_;
     }

void arttest::EventProcessorTestOutput::respondToOpenInputFile ( FileBlock const & fb )

inlineoverrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 138 of file EventProcessorTestOutput_module.cc.

     {
       currentInputFileName_ = fb.fileName();
     }

void arttest::EventProcessorTestOutput::updateSwitchPoints ( )

inlineprivate

Definition at line 195 of file EventProcessorTestOutput_module.cc.

     {
       assert(activeSwitchPoint_.valid());
       if (switchPoints_.empty()) {
         // Invalidate the next switch point--matching against a
         // default-constructed SwitchPoint will always return false.
         activeSwitchPoint_ = SwitchPoint{};
       } else {
         // Pop the front
         switchPoints_.erase(cbegin(switchPoints_));
         activeSwitchPoint_ = switchPoints_.front();
       }
     }

void arttest::EventProcessorTestOutput::write ( EventPrincipal & ep )

inlineoverrideprivatevirtual

Implements art::OutputModule.

Definition at line 144 of file EventProcessorTestOutput_module.cc.

     {
       requestsFileClose_ =
         activeSwitchPoint_.matches(currentInputFileName_, ep.eventID());
       if (requestsFileClose_) {
         updateSwitchPoints();
       }
     }

void arttest::EventProcessorTestOutput::writeRun ( RunPrincipal & rp )

inlineoverrideprivatevirtual

Implements art::OutputModule.

Definition at line 164 of file EventProcessorTestOutput_module.cc.

     {
       requestsFileClose_ =
         activeSwitchPoint_.matches(currentInputFileName_, rp.runID());
       if (requestsFileClose_) {
         updateSwitchPoints();
       }
     }

void arttest::EventProcessorTestOutput::writeSubRun ( SubRunPrincipal & srp )

inlineoverrideprivatevirtual

Implements art::OutputModule.

Definition at line 154 of file EventProcessorTestOutput_module.cc.

     {
       requestsFileClose_ =
         activeSwitchPoint_.matches(currentInputFileName_, srp.subRunID());
       if (requestsFileClose_) {
         updateSwitchPoints();
       }
     }