Inheritance diagram for art::RootOutput:

Classes
struct	Config

Public Types
using	Parameters = fhicl::WrappedTable< Config, 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
	~RootOutput ()

	RootOutput (Parameters const &)

	RootOutput (RootOutput const &)=delete

	RootOutput (RootOutput &&)=delete

RootOutput &	operator= (RootOutput const &)=delete

RootOutput &	operator= (RootOutput &&)=delete

void	postSelectProducts () override

void	beginJob () override

void	endJob () override

void	beginRun (RunPrincipal const &) override

void	endRun (RunPrincipal const &) override

void	beginSubRun (SubRunPrincipal const &) override

void	endSubRun (SubRunPrincipal const &) override

void	event (EventPrincipal const &) override

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

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 &)

std::string const &	processName () const

bool	wantAllEvents () const

bool	wantEvent (Event const &e)

fhicl::ParameterSetID	selectorConfig () const

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

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

	ModuleBase ()

ModuleDescription const &	moduleDescription () const

void	setModuleDescription (ModuleDescription const &)

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 ()

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)

	~SharedModule () noexcept

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

void	createQueues ()

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

template<BranchType BT = InEvent>
void	async ()

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

Static Public Attributes
static constexpr char const *	default_tmpDir {"<parent-path-of-filename>"}

Private Member Functions
string	fileNameAtOpen () const

string	fileNameAtClose (string const &currentFileName)

string const &	lastClosedFileName () const override

Granularity	fileGranularity () const override

void	openFile (FileBlock const &) override

void	respondToOpenInputFile (FileBlock const &) override

void	readResults (ResultsPrincipal const &resp) override

void	respondToCloseInputFile (FileBlock const &) override

void	incrementInputFileNumber () override

void	write (EventPrincipal &) override

void	writeSubRun (SubRunPrincipal &) override

void	writeRun (RunPrincipal &) override

void	setSubRunAuxiliaryRangeSetID (RangeSet const &) override

void	setRunAuxiliaryRangeSetID (RangeSet const &) override

bool	isFileOpen () const override

void	setFileStatus (OutputFileStatus) override

bool	requestsToCloseFile () const override

void	startEndFile () override

void	writeFileFormatVersion () override

void	writeFileIndex () override

void	writeEventHistory () override

void	writeProcessConfigurationRegistry () override

void	writeProcessHistoryRegistry () override

void	writeParameterSetRegistry () override

void	writeProductDescriptionRegistry () override

void	writeParentageRegistry () override

void	doWriteFileCatalogMetadata (FileCatalogMetadata::collection_type const &md, FileCatalogMetadata::collection_type const &ssmd) override

void	writeProductDependencies () override

void	finishEndFile () override

void	doRegisterProducts (ProductDescriptions &productsToProduce, ModuleDescription const &md) override

void	doOpenFile ()

Private Attributes
RecursiveMutex	mutex_

string const	catalog_

bool	dropAllEvents_

bool	dropAllSubRuns_

string const	moduleLabel_

int	inputFileCount_

unique_ptr< RootOutputFile >	rootOutputFile_

FileStatsCollector	fstats_

PostCloseFileRenamer	fRenamer_

string const	filePattern_

string	tmpDir_

string	lastClosedFileName_ {}

int const	compressionLevel_

int64_t const	saveMemoryObjectThreshold_

int64_t const	treeMaxVirtualSize_

int const	splitLevel_

int const	basketSize_

DropMetaData	dropMetaData_

bool	dropMetaDataForDroppedData_

bool	fastCloningEnabled_

bool	writeParameterSets_

ClosingCriteria	fileProperties_

ProductDescriptions	productsToProduce_

ProductTables	producedResultsProducts_

RPManager	rpm_

Additional Inherited Members
Protected Member Functions inherited from art::Observer
	Observer (fhicl::ParameterSet const &config)

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

detail::ProcessAndEventSelectors &	processAndEventSelectors ()

Detailed Description

Definition at line 56 of file RootOutput_module.cc.

Member Typedef Documentation

using art::RootOutput::Parameters = fhicl::WrappedTable<Config, Config::KeysToIgnore>

Definition at line 114 of file RootOutput_module.cc.

Constructor & Destructor Documentation

art::RootOutput::~RootOutput ( )

default

art::RootOutput::RootOutput ( Parameters const & config )

explicit

Definition at line 209 of file RootOutput_module.cc.

     : OutputModule{config().omConfig, config.get_PSet()}
     , mutex_{"RootOutput::mutex_"}
     , catalog_{config().catalog()}
     , dropAllEvents_{false}
     , dropAllSubRuns_{config().dropAllSubRuns()}
     , moduleLabel_{config.get_PSet().get<string>("module_label")}
     , inputFileCount_{0}
     , rootOutputFile_{}
     , fstats_{moduleLabel_, processName()}
     , fRenamer_{fstats_}
     , filePattern_{config().omConfig().fileName()}
     , tmpDir_{config().tmpDir() == default_tmpDir ? parent_path(filePattern_) :
                                                     config().tmpDir()}
     , lastClosedFileName_{}
     , compressionLevel_{config().compressionLevel()}
     , saveMemoryObjectThreshold_{config().saveMemoryObjectThreshold()}
     , treeMaxVirtualSize_{config().treeMaxVirtualSize()}
     , splitLevel_{config().splitLevel()}
     , basketSize_{config().basketSize()}
     , dropMetaData_{config().dropMetaData()}
     , dropMetaDataForDroppedData_{config().dropMetaDataForDroppedData()}
     , fastCloningEnabled_{true}
     , writeParameterSets_{config().writeParameterSets()}
     , fileProperties_{(
         detail::validateFileNamePattern(
           config.get_PSet().has_key(config().fileProperties.name()),
           filePattern_),
         config().fileProperties())}
     , productsToProduce_{}
     , producedResultsProducts_{ProductTables::invalid()}
     , rpm_{config.get_PSet()}
   {
     bool const dropAllEventsSet{config().dropAllEvents(dropAllEvents_)};
     dropAllEvents_ = detail::shouldDropEvents(
       dropAllEventsSet, dropAllEvents_, dropAllSubRuns_);
     // N.B. Any time file switching is enabled at a boundary other than
     //      InputFile, fastCloningEnabled_ ***MUST*** be deactivated.  This is
     //      to ensure that the Event tree from the InputFile is not
     //      accidentally cloned to the output file before the output
     //      module has seen the events that are going to be processed.
     bool const fastCloningSet{config().fastCloning(fastCloningEnabled_)};
     fastCloningEnabled_ = RootOutputFile::shouldFastClone(
       fastCloningSet, fastCloningEnabled_, wantAllEvents(), fileProperties_);
     if (!writeParameterSets_) {
       mf::LogWarning("PROVENANCE")
         << "Output module " << moduleLabel_
         << " has parameter writeParameterSets set to false.\n"
         << "Parameter set provenance will not be available in subsequent "
            "jobs.\n"
         << "Check your experiment's policy on this issue to avoid future "
            "problems\n"
         << "with analysis reproducibility.\n";
     }
   }

art::RootOutput::RootOutput ( RootOutput const & )

delete

art::RootOutput::RootOutput ( RootOutput && )

delete

Member Function Documentation

void art::RootOutput::beginJob ( )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 604 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.invoke(&ResultsProducer::doBeginJob);
   }

void art::RootOutput::beginRun ( RunPrincipal const & rp )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 639 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker([&rp](RPWorker& w) { w.rp().doBeginRun(rp); });
   }

void art::RootOutput::beginSubRun ( SubRunPrincipal const & srp )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 625 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker([&srp](RPWorker& w) { w.rp().doBeginSubRun(srp); });
   }

void art::RootOutput::doOpenFile ( )

private

Definition at line 553 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (inputFileCount_ == 0) {
       throw Exception(errors::LogicError)
         << "Attempt to open output file before input file. "
         << "Please report this to the core framework developers.\n";
     }
     rootOutputFile_ = make_unique<RootOutputFile>(this,
                                                   fileNameAtOpen(),
                                                   fileProperties_,
                                                   compressionLevel_,
                                                   saveMemoryObjectThreshold_,
                                                   treeMaxVirtualSize_,
                                                   splitLevel_,
                                                   basketSize_,
                                                   dropMetaData_,
                                                   dropMetaDataForDroppedData_,
                                                   fastCloningEnabled_);
     fstats_.recordFileOpen();
     detail::logFileAction("Opened output file with pattern ", filePattern_);
   }

void art::RootOutput::doRegisterProducts	(	ProductDescriptions &	productsToProduce,
		ModuleDescription const &	md
	)

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 491 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     // Register Results products from ResultsProducers.
     rpm_.for_each_RPWorker([&producedProducts, &md](RPWorker& w) {
       auto const& params = w.params();
       w.setModuleDescription(
         ModuleDescription{params.rpPSetID,
                           params.rpPluginType,
                           md.moduleLabel() + '#' + params.rpLabel,
                           ModuleThreadingType::legacy,
                           md.processConfiguration()});
       w.rp().registerProducts(producedProducts, w.moduleDescription());
     });
     // Form product table for Results products.  We do this here so we
     // can appropriately set the product tables for the
     // ResultsPrincipal.
     productsToProduce_ = producedProducts;
     producedResultsProducts_ = ProductTables{productsToProduce_};
   }

void art::RootOutput::doWriteFileCatalogMetadata	(	FileCatalogMetadata::collection_type const &	md,
		FileCatalogMetadata::collection_type const &	ssmd
	)

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 462 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeFileCatalogMetadata(fstats_, md, ssmd);
   }

void art::RootOutput::endJob ( )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 611 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.invoke(&ResultsProducer::doEndJob);
   }

void art::RootOutput::endRun ( RunPrincipal const & rp )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 646 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker([&rp](RPWorker& w) { w.rp().doEndRun(rp); });
   }

void art::RootOutput::endSubRun ( SubRunPrincipal const & srp )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 632 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker([&srp](RPWorker& w) { w.rp().doEndSubRun(srp); });
   }

void art::RootOutput::event ( EventPrincipal const & ep )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 618 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker([&ep](RPWorker& w) { w.rp().doEvent(ep); });
   }

Granularity art::RootOutput::fileGranularity ( ) const

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 546 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     return fileProperties_.granularity();
   }

string art::RootOutput::fileNameAtClose ( std::string const & currentFileName )

private

Definition at line 585 of file RootOutput_module.cc.

   {
     return (filePattern_ == dev_null) ?
              dev_null :
              fRenamer_.maybeRenameFile(currentFileName, filePattern_);
   }

string art::RootOutput::fileNameAtOpen ( ) const

private

Definition at line 577 of file RootOutput_module.cc.

   {
     return (filePattern_ == dev_null) ?
              dev_null :
              unique_filename(tmpDir_ + "/RootOutput");
   }

void art::RootOutput::finishEndFile ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 478 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     string const currentFileName{rootOutputFile_->currentFileName()};
     rootOutputFile_->writeTTrees();
     rootOutputFile_.reset();
     fstats_.recordFileClose();
     lastClosedFileName_ = fileNameAtClose(currentFileName);
     detail::logFileAction("Closed output file ", lastClosedFileName_);
     rpm_.invoke(&ResultsProducer::doClear);
   }

void art::RootOutput::incrementInputFileNumber ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 530 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (isFileOpen()) {
       rootOutputFile_->incrementInputFileNumber();
     }
   }

bool art::RootOutput::isFileOpen ( ) const

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 523 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     return rootOutputFile_.get() != nullptr;
   }

string const & art::RootOutput::lastClosedFileName ( ) const

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 593 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (lastClosedFileName_.empty()) {
       throw Exception(errors::LogicError, "RootOutput::currentFileName(): ")
         << "called before meaningful.\n";
     }
     return lastClosedFileName_;
   }

void art::RootOutput::openFile ( FileBlock const & fb )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 266 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     // Note: The file block here refers to the currently open
     //       input file, so we can find out about the available
     //       products by looping over the branches of the input
     //       file data trees.
     if (!isFileOpen()) {
       doOpenFile();
       respondToOpenInputFile(fb);
     }
   }

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

delete

RootOutput& art::RootOutput::operator= ( RootOutput && )

delete

void art::RootOutput::postSelectProducts ( )

overridevirtual

Reimplemented from art::OutputModule.

Definition at line 280 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (isFileOpen()) {
       rootOutputFile_->selectProducts();
     }
   }

void art::RootOutput::readResults ( ResultsPrincipal const & resp )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 317 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rpm_.for_each_RPWorker(
       [&resp](RPWorker& w) { w.rp().doReadResults(resp); });
   }

bool art::RootOutput::requestsToCloseFile ( ) const

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 539 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     return isFileOpen() ? rootOutputFile_->requestsToCloseFile() : false;
   }

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

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 325 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (isFileOpen()) {
       rootOutputFile_->respondToCloseInputFile(fb);
     }
   }

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

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 289 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     ++inputFileCount_;
     if (!isFileOpen()) {
       return;
     }
     auto const* rfb = dynamic_cast<RootFileBlock const*>(&fb);
     bool fastCloneThisOne = fastCloningEnabled_ && rfb &&
                             (rfb->tree() != nullptr) &&
                             ((remainingEvents() < 0) ||
                              (remainingEvents() >= rfb->tree()->GetEntries()));
     if (fastCloningEnabled_ && !fastCloneThisOne) {
       mf::LogWarning("FastCloning")
         << "Fast cloning deactivated for this input file due to "
         << "empty event tree and/or event limits.";
     }
     if (fastCloneThisOne && !rfb->fastClonable()) {
       mf::LogWarning("FastCloning")
         << "Fast cloning deactivated for this input file due to "
         << "information in FileBlock.";
       fastCloneThisOne = false;
     }
     rootOutputFile_->beginInputFile(rfb, fastCloneThisOne);
     fstats_.recordInputFile(fb.fileName());
   }

void art::RootOutput::setFileStatus ( OutputFileStatus ofs )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 514 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (isFileOpen()) {
       rootOutputFile_->setFileStatus(ofs);
     }
   }

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

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 369 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->setRunAuxiliaryRangeSetID(rs);
   }

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

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 348 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->setSubRunAuxiliaryRangeSetID(rs);
   }

void art::RootOutput::startEndFile ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 387 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     auto resp = make_unique<ResultsPrincipal>(
       ResultsAuxiliary{}, moduleDescription().processConfiguration(), nullptr);
     resp->createGroupsForProducedProducts(producedResultsProducts_);
     resp->enableLookupOfProducedProducts(producedResultsProducts_);
     if (!producedResultsProducts_.descriptions(InResults).empty() ||
         hasNewlyDroppedBranch()[InResults]) {
       resp->addToProcessHistory();
     }
     rpm_.for_each_RPWorker(
       [&resp](RPWorker& w) { w.rp().doWriteResults(*resp); });
     rootOutputFile_->writeResults(*resp);
   }

void art::RootOutput::write ( EventPrincipal & ep )

overrideprivatevirtual

Implements art::OutputModule.

Definition at line 334 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (dropAllEvents_) {
       return;
     }
     if (hasNewlyDroppedBranch()[InEvent]) {
       ep.addToProcessHistory();
     }
     rootOutputFile_->writeOne(ep);
     fstats_.recordEvent(ep.eventID());
   }

void art::RootOutput::writeEventHistory ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 418 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeEventHistory();
   }

void art::RootOutput::writeFileFormatVersion ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 404 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeFileFormatVersion();
   }

void art::RootOutput::writeFileIndex ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 411 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeFileIndex();
   }

void art::RootOutput::writeParameterSetRegistry ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 439 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (writeParameterSets_) {
       rootOutputFile_->writeParameterSetRegistry();
     }
   }

void art::RootOutput::writeParentageRegistry ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 455 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeParentageRegistry();
   }

void art::RootOutput::writeProcessConfigurationRegistry ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 425 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeProcessConfigurationRegistry();
   }

void art::RootOutput::writeProcessHistoryRegistry ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 432 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeProcessHistoryRegistry();
   }

void art::RootOutput::writeProductDependencies ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 471 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeProductDependencies();
   }

void art::RootOutput::writeProductDescriptionRegistry ( )

overrideprivatevirtual

Reimplemented from art::OutputModule.

Definition at line 448 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     rootOutputFile_->writeProductDescriptionRegistry();
   }

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

overrideprivatevirtual

Implements art::OutputModule.

Definition at line 376 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (hasNewlyDroppedBranch()[InRun]) {
       rp.addToProcessHistory();
     }
     rootOutputFile_->writeRun(rp);
     fstats_.recordRun(rp.runID());
   }

void art::RootOutput::writeSubRun ( SubRunPrincipal & sr )

overrideprivatevirtual

Implements art::OutputModule.

Definition at line 355 of file RootOutput_module.cc.

   {
     RecursiveMutexSentry sentry{mutex_, __func__};
     if (dropAllSubRuns_) {
       return;
     }
     if (hasNewlyDroppedBranch()[InSubRun]) {
       sr.addToProcessHistory();
     }
     rootOutputFile_->writeSubRun(sr);
     fstats_.recordSubRun(sr.subRunID());
   }

Member Data Documentation

int const art::RootOutput::basketSize_

private

Definition at line 194 of file RootOutput_module.cc.

string const art::RootOutput::catalog_

private

Definition at line 179 of file RootOutput_module.cc.

int const art::RootOutput::compressionLevel_

private

Definition at line 190 of file RootOutput_module.cc.

constexpr char const* art::RootOutput::default_tmpDir {"<parent-path-of-filename>"}

static

Definition at line 60 of file RootOutput_module.cc.

bool art::RootOutput::dropAllEvents_

private

Definition at line 180 of file RootOutput_module.cc.

bool art::RootOutput::dropAllSubRuns_

private

Definition at line 181 of file RootOutput_module.cc.

DropMetaData art::RootOutput::dropMetaData_

private

Definition at line 195 of file RootOutput_module.cc.

bool art::RootOutput::dropMetaDataForDroppedData_

private

Definition at line 196 of file RootOutput_module.cc.

bool art::RootOutput::fastCloningEnabled_

private

Definition at line 197 of file RootOutput_module.cc.

string const art::RootOutput::filePattern_

private

Definition at line 187 of file RootOutput_module.cc.

ClosingCriteria art::RootOutput::fileProperties_

private

Definition at line 201 of file RootOutput_module.cc.

PostCloseFileRenamer art::RootOutput::fRenamer_

private

Definition at line 186 of file RootOutput_module.cc.

FileStatsCollector art::RootOutput::fstats_

private

Definition at line 185 of file RootOutput_module.cc.

int art::RootOutput::inputFileCount_

private

Definition at line 183 of file RootOutput_module.cc.

string art::RootOutput::lastClosedFileName_ {}

private

Definition at line 189 of file RootOutput_module.cc.

string const art::RootOutput::moduleLabel_

private

Definition at line 182 of file RootOutput_module.cc.

RecursiveMutex art::RootOutput::mutex_

mutableprivate

Definition at line 178 of file RootOutput_module.cc.

ProductTables art::RootOutput::producedResultsProducts_

private

Definition at line 203 of file RootOutput_module.cc.

ProductDescriptions art::RootOutput::productsToProduce_

private

Definition at line 202 of file RootOutput_module.cc.

unique_ptr<RootOutputFile> art::RootOutput::rootOutputFile_

private

Definition at line 184 of file RootOutput_module.cc.

RPManager art::RootOutput::rpm_

private

Definition at line 204 of file RootOutput_module.cc.

int64_t const art::RootOutput::saveMemoryObjectThreshold_

private

Definition at line 191 of file RootOutput_module.cc.

int const art::RootOutput::splitLevel_

private

Definition at line 193 of file RootOutput_module.cc.

string art::RootOutput::tmpDir_

private

Definition at line 188 of file RootOutput_module.cc.

int64_t const art::RootOutput::treeMaxVirtualSize_

private

Definition at line 192 of file RootOutput_module.cc.

bool art::RootOutput::writeParameterSets_

private

Definition at line 200 of file RootOutput_module.cc.

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

art/art/Framework/IO/Root/RootOutput_module.cc

Classes

Public Types

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation