#include <RootInputFile.h>

Classes
class	RootInputTree

Public Types
using	RootInputTreePtrArray = std::array< std::unique_ptr< RootInputTree >, NumBranchTypes >

using	EntryNumber = RootInputTree::EntryNumber

using	EntryNumbers = RootInputTree::EntryNumbers

Public Member Functions
	~RootInputFile ()

	RootInputFile (RootInputFile const &)=delete

	RootInputFile (RootInputFile &&)=delete

RootInputFile &	operator= (RootInputFile const &)=delete

RootInputFile &	operator= (RootInputFile &&)=delete

	RootInputFile (std::string const &fileName, std::string const &catalogName, ProcessConfiguration const &processConfiguration, std::string const &logicalFileName, std::unique_ptr< TFile > &&filePtr, EventID const &origEventID, unsigned int eventsToSkip, bool compactSubRunRanges, FastCloningInfoProvider const &fcip, unsigned int treeCacheSize, int64_t treeMaxVirtualSize, int64_t saveMemoryObjectThreashold, bool delayedReadEventProducts, bool delayedReadSubRunProducts, bool delayedReadRunProducts, InputSource::ProcessingMode processingMode, int forcedRunOffset, bool noEventSort, GroupSelectorRules const &groupSelectorRules, std::shared_ptr< DuplicateChecker > duplicateChecker, bool dropDescendantsOfDroppedProducts, bool readIncomingParameterSets, cet::exempt_ptr< RootInputFile > primaryFile, std::vector< std::string > const &secondaryFileNames, RootInputFileSequence *rifSequence, UpdateOutputCallbacks &outputCallbacks)

void	reportOpened ()

void	close (bool reallyClose)

std::unique_ptr< ResultsPrincipal >	readResults ()

std::unique_ptr< RunPrincipal >	readRun ()

std::unique_ptr< SubRunPrincipal >	readSubRun (cet::exempt_ptr< RunPrincipal const >)

std::unique_ptr< EventPrincipal >	readEvent ()

bool	readRunForSecondaryFile (RunID)

bool	readSubRunForSecondaryFile (SubRunID)

bool	readEventForSecondaryFile (EventID eID)

std::string const &	fileName () const

RootInputTreePtrArray &	treePointers ()

FileFormatVersion	fileFormatVersion () const

bool	fastClonable () const

std::unique_ptr< FileBlock >	createFileBlock ()

bool	setEntry_Event (EventID const &id, bool exact=true)

bool	setEntry_SubRun (SubRunID const &id, bool exact=true)

bool	setEntry_Run (RunID const &id, bool exact=true)

void	rewind ()

void	setToLastEntry ()

void	nextEntry ()

void	previousEntry ()

void	advanceEntry (std::size_t n)

unsigned	eventsToSkip () const

int	skipEvents (int offset)

int	setForcedRunOffset (RunNumber_t const &forcedRunNumber)

FileIndex::EntryType	getEntryType () const

FileIndex::EntryType	getNextEntryTypeWanted ()

std::shared_ptr< FileIndex >	fileIndexSharedPtr () const

EventID	eventIDForFileIndexPosition () const

std::vector< std::string > const &	secondaryFileNames () const

std::vector< std::unique_ptr< RootInputFile > > const &	secondaryFiles () const

void	openSecondaryFile (int const idx)

std::unique_ptr< RangeSetHandler >	runRangeSetHandler ()

std::unique_ptr< RangeSetHandler >	subRunRangeSetHandler ()

Private Member Functions
RootInputTree const &	eventTree () const

RootInputTree const &	subRunTree () const

RootInputTree const &	runTree () const

RootInputTree const &	resultsTree () const

RootInputTree &	eventTree ()

RootInputTree &	subRunTree ()

RootInputTree &	runTree ()

RootInputTree &	resultsTree ()

bool	setIfFastClonable (FastCloningInfoProvider const &fcip) const

void	validateFile ()

void	fillHistory (EntryNumber const entry, History &)

void	fillAuxiliary_Event (EntryNumber const entry)

void	fillAuxiliary_SubRun (EntryNumber const entry)

void	fillAuxiliary_Run (EntryNumber const entry)

void	fillAuxiliary_Results (EntryNumber const entry)

std::unique_ptr< RangeSetHandler >	fillAuxiliary_SubRun (EntryNumbers const &entries)

std::unique_ptr< RangeSetHandler >	fillAuxiliary_Run (EntryNumbers const &entries)

void	overrideRunNumber (RunAuxiliary &)

void	overrideRunNumber (SubRunID &id)

void	overrideRunNumber (EventID &id, bool isRealData)

void	dropOnInput (GroupSelectorRules const &rules, bool dropDescendants, ProductTables &tables)

void	readParentageTree (unsigned int treeCacheSize)

void	readEventHistoryTree (unsigned int treeCacheSize)

void	initializeDuplicateChecker ()

std::pair< EntryNumbers, bool >	getEntryNumbers (BranchType)

std::unique_ptr< RunPrincipal >	readCurrentRun (EntryNumbers const &)

std::unique_ptr< SubRunPrincipal >	readCurrentSubRun (EntryNumbers const &, cet::exempt_ptr< RunPrincipal const >)

std::unique_ptr< EventPrincipal >	readCurrentEvent (std::pair< EntryNumbers, bool > const &)

Private Attributes
std::string const	fileName_

std::string const	catalog_

ProcessConfiguration const &	processConfiguration_

std::string const	logicalFileName_

std::unique_ptr< TFile >	filePtr_

std::unique_ptr< cet::sqlite::Connection >	sqliteDB_ {nullptr}

EventID	origEventID_

EventNumber_t	eventsToSkip_

bool const	compactSubRunRanges_

RootInputTreePtrArray	treePointers_

bool	delayedReadEventProducts_

bool	delayedReadSubRunProducts_

bool	delayedReadRunProducts_

InputSource::ProcessingMode	processingMode_

int	forcedRunOffset_

bool	noEventSort_

std::shared_ptr< DuplicateChecker >	duplicateChecker_

cet::exempt_ptr< RootInputFile >	primaryFile_

std::vector< std::string >	secondaryFileNames_

cet::exempt_ptr< RootInputFileSequence >	rifSequence_

FileFormatVersion	fileFormatVersion_ {}

std::shared_ptr< FileIndex >	fileIndexSharedPtr_ {new FileIndex}

FileIndex &	fileIndex_ {*fileIndexSharedPtr_}

FileIndex::const_iterator	fiBegin_ {fileIndex_.begin()}

FileIndex::const_iterator	fiEnd_ {fileIndex_.end()}

FileIndex::const_iterator	fiIter_ {fiBegin_}

bool	fastClonable_ {false}

EventAuxiliary	eventAux_ {}

SubRunAuxiliary	subRunAux_ {}

RunAuxiliary	runAux_ {}

ResultsAuxiliary	resultsAux_ {}

ProductTables	presentProducts_ {ProductTables::invalid()}

std::unique_ptr< BranchIDLists >	branchIDLists_ {}

TTree *	eventHistoryTree_ {nullptr}

std::vector< std::unique_ptr< RootInputFile > >	secondaryFiles_ {}

cet::exempt_ptr< EventPrincipal >	primaryEP_ {}

cet::exempt_ptr< RunPrincipal >	primaryRP_ {}

cet::exempt_ptr< SubRunPrincipal >	primarySRP_ {}

std::unique_ptr< RangeSetHandler >	subRunRangeSetHandler_ {nullptr}

std::unique_ptr< RangeSetHandler >	runRangeSetHandler_ {nullptr}

int64_t	saveMemoryObjectThreshold_

Detailed Description

Definition at line 55 of file RootInputFile.h.

Member Typedef Documentation

using art::RootInputFile::EntryNumber = RootInputTree::EntryNumber

Definition at line 98 of file RootInputFile.h.

using art::RootInputFile::EntryNumbers = RootInputTree::EntryNumbers

Definition at line 99 of file RootInputFile.h.

using art::RootInputFile::RootInputTreePtrArray = std::array<std::unique_ptr<RootInputTree>, NumBranchTypes>

Definition at line 97 of file RootInputFile.h.

Constructor & Destructor Documentation

art::RootInputFile::~RootInputFile ( )

Definition at line 244 of file RootInputFile.cc.

244 {}

art::RootInputFile::RootInputFile ( RootInputFile const & )

delete

art::RootInputFile::RootInputFile ( RootInputFile && )

delete

art::RootInputFile::RootInputFile	(	std::string const &	fileName,
		std::string const &	catalogName,
		ProcessConfiguration const &	processConfiguration,
		std::string const &	logicalFileName,
		std::unique_ptr< TFile > &&	filePtr,
		EventID const &	origEventID,
		unsigned int	eventsToSkip,
		bool	compactSubRunRanges,
		FastCloningInfoProvider const &	fcip,
		unsigned int	treeCacheSize,
		int64_t	treeMaxVirtualSize,
		int64_t	saveMemoryObjectThreashold,
		bool	delayedReadEventProducts,
		bool	delayedReadSubRunProducts,
		bool	delayedReadRunProducts,
		InputSource::ProcessingMode	processingMode,
		int	forcedRunOffset,
		bool	noEventSort,
		GroupSelectorRules const &	groupSelectorRules,
		std::shared_ptr< DuplicateChecker >	duplicateChecker,
		bool	dropDescendantsOfDroppedProducts,
		bool	readIncomingParameterSets,
		cet::exempt_ptr< RootInputFile >	primaryFile,
		std::vector< std::string > const &	secondaryFileNames,
		RootInputFileSequence *	rifSequence,
		UpdateOutputCallbacks &	outputCallbacks
	)

Member Function Documentation

void art::RootInputFile::advanceEntry ( std::size_t n )

Definition at line 740 of file RootInputFile.cc.

   {
     while (n-- != 0) {
       nextEntry();
     }
   }

void art::RootInputFile::close ( bool reallyClose )

Definition at line 993 of file RootInputFile.cc.

   {
     if (!reallyClose) {
       return;
     }
     filePtr_->Close();
     for (auto const& sf : secondaryFiles_) {
       if (!sf) {
         continue;
       }
       sf->filePtr_->Close();
     }
   }

unique_ptr< FileBlock > art::RootInputFile::createFileBlock ( )

Definition at line 882 of file RootInputFile.cc.

   {
     return std::make_unique<RootFileBlock>(
       fileFormatVersion_,
       fileName_,
       readResults(),
       cet::make_exempt_ptr(eventTree().tree()),
       fastClonable());
   }

void art::RootInputFile::dropOnInput	(	GroupSelectorRules const &	rules,
		bool	dropDescendants,
		ProductTables &	tables
	)

private

Definition at line 1419 of file RootInputFile.cc.

   {
     auto dropOnInputForBranchType =
       [this, &rules, dropDescendants, &tables](BranchType const bt) {
         auto& prodList = tables.get(bt).descriptions;
 
         // This is the selector for drop on input.
         GroupSelector const groupSelector{rules, prodList};
         // Do drop on input. On the first pass, just fill in a set of
         // branches to be dropped.  Use the BranchChildren class to
         // assemble list of children to drop.
         BranchChildren children;
         set<ProductID> branchesToDrop;
         for (auto const& prod : prodList) {
           auto const& pd = prod.second;
           if (!groupSelector.selected(pd)) {
             if (dropDescendants) {
               children.appendToDescendants(pd.productID(), branchesToDrop);
             } else {
               branchesToDrop.insert(pd.productID());
             }
           }
         }
 
         // On this pass, actually drop the branches.
         auto branchesToDropEnd = branchesToDrop.cend();
         for (auto I = prodList.begin(), E = prodList.end(); I != E;) {
           auto const& bd = I->second;
           bool drop = branchesToDrop.find(bd.productID()) != branchesToDropEnd;
           if (!drop) {
             ++I;
             checkDictionaries(bd);
             continue;
           }
           if (groupSelector.selected(bd)) {
             mf::LogWarning("RootInputFile")
               << "Branch '" << bd.branchName()
               << "' is being dropped from the input\n"
               << "of file '" << fileName_
               << "' because it is dependent on a branch\n"
               << "that was explicitly dropped.\n";
           }
           treePointers_[bt]->dropBranch(bd.branchName());
           auto icopy = I++;
           prodList.erase(icopy);
         }
       };
     for_each_branch_type(dropOnInputForBranchType);
   }

EventID art::RootInputFile::eventIDForFileIndexPosition ( ) const

Definition at line 813 of file RootInputFile.cc.

   {
     if (fiIter_ == fiEnd_) {
       return EventID{};
     }
     return fiIter_->eventID_;
   }

unsigned int art::RootInputFile::eventsToSkip ( ) const

Definition at line 748 of file RootInputFile.cc.

   {
     return eventsToSkip_;
   }

RootInputFile::RootInputTree const & art::RootInputFile::eventTree ( ) const

private

Definition at line 525 of file RootInputFile.cc.

   {
     return *treePointers_[InEvent];
   }

RootInputFile::RootInputTree & art::RootInputFile::eventTree ( )

private

Definition at line 549 of file RootInputFile.cc.

   {
     return *treePointers_[InEvent];
   }

bool art::RootInputFile::fastClonable ( ) const

Definition at line 705 of file RootInputFile.cc.

   {
     return fastClonable_;
   }

FileFormatVersion art::RootInputFile::fileFormatVersion ( ) const

Definition at line 699 of file RootInputFile.cc.

   {
     return fileFormatVersion_;
   }

shared_ptr< FileIndex > art::RootInputFile::fileIndexSharedPtr ( ) const

Definition at line 754 of file RootInputFile.cc.

   {
     return fileIndexSharedPtr_;
   }

string const & art::RootInputFile::fileName ( ) const

Definition at line 687 of file RootInputFile.cc.

   {
     return fileName_;
   }

void art::RootInputFile::fillAuxiliary_Event ( EntryNumber const entry )

private

Definition at line 573 of file RootInputFile.cc.

   {
     auto auxbr = treePointers_[InEvent]->auxBranch();
     auto pAux = &eventAux_;
     auxbr->SetAddress(&pAux);
     input::getEntry(auxbr, entry);
   }

void art::RootInputFile::fillAuxiliary_Results ( EntryNumber const entry )

private

Definition at line 600 of file RootInputFile.cc.

   {
     auto auxbr = treePointers_[InResults]->auxBranch();
     auto pAux = &resultsAux_;
     auxbr->SetAddress(&pAux);
     input::getEntry(auxbr, entry);
   }

void art::RootInputFile::fillAuxiliary_Run ( EntryNumber const entry )

private

Definition at line 591 of file RootInputFile.cc.

   {
     auto auxbr = treePointers_[InRun]->auxBranch();
     auto pAux = &runAux_;
     auxbr->SetAddress(&pAux);
     input::getEntry(auxbr, entry);
   }

unique_ptr< RangeSetHandler > art::RootInputFile::fillAuxiliary_Run ( EntryNumbers const & entries )

private

Definition at line 648 of file RootInputFile.cc.

   {
     RunAuxiliary auxResult{};
     {
       auto auxbr = treePointers_[InRun]->auxBranch();
       auto pAux = &auxResult;
       auxbr->SetAddress(&pAux);
       input::getEntry(auxbr, entries[0]);
     }
     if (fileFormatVersion_.value_ < 9) {
       swap(runAux_, auxResult);
       return make_unique<OpenRangeSetHandler>(runAux_.run());
     }
     auto resolve_info = [this](auto const id) {
       return detail::resolveRangeSetInfo(*sqliteDB_,
                                          this->fileName_,
                                          RunAuxiliary::branch_type,
                                          id,
                                          compactSubRunRanges_);
     };
     auto rangeSetInfo = resolve_info(auxResult.rangeSetID());
     for (auto i = entries.cbegin() + 1, e = entries.cend(); i != e; ++i) {
       RunAuxiliary tmpAux{};
       {
         auto auxbr = treePointers_[InRun]->auxBranch();
         auto pAux = &tmpAux;
         auxbr->SetAddress(&pAux);
         input::getEntry(auxbr, *i);
       }
       detail::mergeAuxiliary(auxResult, tmpAux);
       rangeSetInfo.update(resolve_info(tmpAux.rangeSetID()),
                           compactSubRunRanges_);
     }
     auxResult.setRangeSetID(-1u); // Range set of new auxiliary is invalid
     swap(runAux_, auxResult);
     return make_unique<ClosedRangeSetHandler>(resolveRangeSet(rangeSetInfo));
   }

void art::RootInputFile::fillAuxiliary_SubRun ( EntryNumber const entry )

private

Definition at line 582 of file RootInputFile.cc.

   {
     auto auxbr = treePointers_[InSubRun]->auxBranch();
     auto pAux = &subRunAux_;
     auxbr->SetAddress(&pAux);
     input::getEntry(auxbr, entry);
   }

unique_ptr< RangeSetHandler > art::RootInputFile::fillAuxiliary_SubRun ( EntryNumbers const & entries )

private

Definition at line 609 of file RootInputFile.cc.

   {
     SubRunAuxiliary auxResult{};
     {
       auto auxbr = treePointers_[InSubRun]->auxBranch();
       auto pAux = &auxResult;
       auxbr->SetAddress(&pAux);
       input::getEntry(auxbr, entries[0]);
     }
     if (fileFormatVersion_.value_ < 9) {
       swap(subRunAux_, auxResult);
       return make_unique<OpenRangeSetHandler>(subRunAux_.run());
     }
     auto resolve_info = [this](auto const id) {
       return detail::resolveRangeSetInfo(*sqliteDB_,
                                          this->fileName_,
                                          SubRunAuxiliary::branch_type,
                                          id,
                                          compactSubRunRanges_);
     };
     auto rangeSetInfo = resolve_info(auxResult.rangeSetID());
     for (auto i = entries.cbegin() + 1, e = entries.cend(); i != e; ++i) {
       SubRunAuxiliary tmpAux{};
       {
         auto auxbr = treePointers_[InSubRun]->auxBranch();
         auto pAux = &tmpAux;
         auxbr->SetAddress(&pAux);
         input::getEntry(auxbr, *i);
       }
       detail::mergeAuxiliary(auxResult, tmpAux);
       rangeSetInfo.update(resolve_info(tmpAux.rangeSetID()),
                           compactSubRunRanges_);
     }
     auxResult.setRangeSetID(-1u); // Range set of new auxiliary is invalid
     swap(subRunAux_, auxResult);
     return make_unique<ClosedRangeSetHandler>(resolveRangeSet(rangeSetInfo));
   }

void art::RootInputFile::fillHistory	(	EntryNumber const	entry,
		History &	history
	)

private

Definition at line 1008 of file RootInputFile.cc.

   {
     // We could consider doing delayed reading, but because we have to
     // store this History object in a different tree than the event
     // data tree, this is too hard to do in this first version.
     auto pHistory = &history;
     auto eventHistoryBranch =
       eventHistoryTree_->GetBranch(rootNames::eventHistoryBranchName().c_str());
     if (!eventHistoryBranch) {
       throw art::Exception{errors::DataCorruption}
         << "Failed to find history branch in event history tree.\n";
     }
     eventHistoryBranch->SetAddress(&pHistory);
     input::getEntry(eventHistoryTree_, entry);
   }

pair< RootInputFile::EntryNumbers, bool > art::RootInputFile::getEntryNumbers ( BranchType bt )

private

Definition at line 1397 of file RootInputFile.cc.

   {
     EntryNumbers enumbers;
     if (fiIter_ == fiEnd_) {
       return pair<EntryNumbers, bool>{enumbers, true};
     }
     auto const eid = fiIter_->eventID_;
     auto iter = fiIter_;
     for (; (iter != fiEnd_) && (iter->eventID_ == eid); ++iter) {
       enumbers.push_back(iter->entry_);
     }
     if ((bt == InEvent) && (enumbers.size() > 1ul)) {
       throw Exception{errors::FileReadError} << "File " << fileName_
                                              << " has multiple entries for\n"
                                              << eid << '\n';
     }
     bool const lastInSubRun{(iter == fiEnd_) ||
                             (iter->eventID_.subRun() != eid.subRun())};
     return pair<EntryNumbers, bool>{enumbers, lastInSubRun};
   }

FileIndex::EntryType art::RootInputFile::getEntryType ( ) const

Definition at line 893 of file RootInputFile.cc.

   {
     if (fiIter_ == fiEnd_) {
       return FileIndex::kEnd;
     }
     return fiIter_->getEntryType();
   }

FileIndex::EntryType art::RootInputFile::getNextEntryTypeWanted ( )

Definition at line 902 of file RootInputFile.cc.

   {
     auto entryType = getEntryType();
     if (entryType == FileIndex::kEnd) {
       return FileIndex::kEnd;
     }
     RunID currentRun(fiIter_->eventID_.runID());
     if (!currentRun.isValid()) {
       return FileIndex::kEnd;
     }
     if (entryType == FileIndex::kRun) {
       // Skip any runs before the first run specified
       if (currentRun < origEventID_.runID()) {
         fiIter_ = fileIndex_.findPosition(origEventID_.runID(), false);
         return getNextEntryTypeWanted();
       }
       return FileIndex::kRun;
     }
     if (processingMode_ == InputSource::Runs) {
       fiIter_ = fileIndex_.findPosition(
         currentRun.isValid() ? currentRun.next() : currentRun, false);
       return getNextEntryTypeWanted();
     }
     SubRunID const& currentSubRun = fiIter_->eventID_.subRunID();
     if (entryType == FileIndex::kSubRun) {
       // Skip any subRuns before the first subRun specified
       if ((currentRun == origEventID_.runID()) &&
           (currentSubRun < origEventID_.subRunID())) {
         fiIter_ = fileIndex_.findSubRunOrRunPosition(origEventID_.subRunID());
         return getNextEntryTypeWanted();
       }
       return FileIndex::kSubRun;
     }
     if (processingMode_ == InputSource::RunsAndSubRuns) {
       fiIter_ = fileIndex_.findSubRunOrRunPosition(currentSubRun.next());
       return getNextEntryTypeWanted();
     }
     assert(entryType == FileIndex::kEvent);
     // Skip any events before the first event specified
     if (fiIter_->eventID_ < origEventID_) {
       fiIter_ = fileIndex_.findPosition(origEventID_);
       return getNextEntryTypeWanted();
     }
     if (duplicateChecker_.get() && duplicateChecker_->isDuplicateAndCheckActive(
                                      fiIter_->eventID_, fileName_)) {
       nextEntry();
       return getNextEntryTypeWanted();
     }
     if (eventsToSkip_ == 0) {
       return FileIndex::kEvent;
     }
     // We have specified a count of events to skip, keep skipping
     // events in this subRun block until we reach the end of the
     // subRun block or the full count of the number of events to skip.
     while ((eventsToSkip_ != 0) && (fiIter_ != fiEnd_) &&
            (getEntryType() == FileIndex::kEvent)) {
       nextEntry();
       --eventsToSkip_;
       while ((eventsToSkip_ != 0) && (fiIter_ != fiEnd_) &&
              (fiIter_->getEntryType() == FileIndex::kEvent) &&
              duplicateChecker_.get() &&
              duplicateChecker_->isDuplicateAndCheckActive(fiIter_->eventID_,
                                                           fileName_)) {
         nextEntry();
       }
     }
     return getNextEntryTypeWanted();
   }

void art::RootInputFile::initializeDuplicateChecker ( )

private

Definition at line 1383 of file RootInputFile.cc.

   {
     if (duplicateChecker_.get() == nullptr) {
       return;
     }
     if (eventTree().entries()) {
       // FIXME: We don't initialize the duplicate checker if there are no
       // events!
       fillAuxiliary_Event(0);
       duplicateChecker_->init(eventAux_.isRealData(), fileIndex_);
     }
   }

void art::RootInputFile::nextEntry ( )

Definition at line 728 of file RootInputFile.cc.

   {
     ++fiIter_;
   }

void art::RootInputFile::openSecondaryFile ( int const idx )

Definition at line 1472 of file RootInputFile.cc.

   {
     secondaryFiles_[idx] =
       rifSequence_->openSecondaryFile(secondaryFileNames_[idx], this);
   }

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

delete

RootInputFile& art::RootInputFile::operator= ( RootInputFile && )

delete

void art::RootInputFile::overrideRunNumber ( RunAuxiliary & aux )

private

Definition at line 1336 of file RootInputFile.cc.

   {
     if (forcedRunOffset_ != 0) {
       aux.runID(RunID(aux.run() + forcedRunOffset_));
     }
     if (aux.runID() < RunID::firstRun()) {
       aux.runID(RunID::firstRun());
     }
   }

void art::RootInputFile::overrideRunNumber ( SubRunID & id )

private

Definition at line 1347 of file RootInputFile.cc.

   {
     if (forcedRunOffset_ != 0) {
       id = SubRunID(id.run() + forcedRunOffset_, id.subRun());
     }
   }

void art::RootInputFile::overrideRunNumber	(	EventID &	id,
		bool	isRealData
	)

private

Definition at line 1355 of file RootInputFile.cc.

   {
     if (forcedRunOffset_ == 0) {
       return;
     }
     if (isRealData) {
       throw art::Exception{errors::Configuration,
                            "RootInputFile::overrideRunNumber()"}
         << "The 'setRunNumber' parameter of RootInput cannot "
         << "be used with real data.\n";
     }
     id = EventID(id.run() + forcedRunOffset_, id.subRun(), id.event());
   }

void art::RootInputFile::previousEntry ( )

Definition at line 734 of file RootInputFile.cc.

   {
     --fiIter_;
   }

unique_ptr< EventPrincipal > art::RootInputFile::readCurrentEvent ( std::pair< EntryNumbers, bool > const & entryNumbers )

private

Definition at line 1077 of file RootInputFile.cc.

   {
     assert(entryNumbers.first.size() == 1ull);
     fillAuxiliary_Event(entryNumbers.first.front());
     assert(eventAux_.eventID() == fiIter_->eventID_);
     unique_ptr<History> history = make_unique<History>();
     fillHistory(entryNumbers.first.front(), *history);
     overrideRunNumber(const_cast<EventID&>(eventAux_.eventID()),
                       eventAux_.isRealData());
     auto ep = make_unique<EventPrincipal>(
       eventAux_,
       processConfiguration_,
       &presentProducts_.get(InEvent),
       move(history),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      nullptr,
                                      entryNumbers.first,
                                      &eventTree().branches(),
                                      eventTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      branchIDLists_.get(),
                                      InEvent,
                                      eventAux_.eventID(),
                                      compactSubRunRanges_),
       entryNumbers.second);
     if (!delayedReadEventProducts_) {
       ep->readImmediate();
     }
     primaryEP_ = make_exempt_ptr(ep.get());
     return ep;
   }

unique_ptr< RunPrincipal > art::RootInputFile::readCurrentRun ( EntryNumbers const & entryNumbers )

private

Definition at line 1167 of file RootInputFile.cc.

   {
     runRangeSetHandler_ = fillAuxiliary_Run(entryNumbers);
     assert(runAux_.runID() == fiIter_->eventID_.runID());
     overrideRunNumber(runAux_);
     if (runAux_.beginTime() == Timestamp::invalidTimestamp()) {
       runAux_.beginTime(eventAux_.time());
       runAux_.endTime(Timestamp::invalidTimestamp());
     }
     auto rp = make_unique<RunPrincipal>(
       runAux_,
       processConfiguration_,
       &presentProducts_.get(InRun),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      *sqliteDB_,
                                      entryNumbers,
                                      &runTree().branches(),
                                      runTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      nullptr,
                                      InRun,
                                      fiIter_->eventID_,
                                      compactSubRunRanges_));
     if (!delayedReadRunProducts_) {
       rp->readImmediate();
     }
     primaryRP_ = make_exempt_ptr(rp.get());
     return rp;
   }

unique_ptr< SubRunPrincipal > art::RootInputFile::readCurrentSubRun	(	EntryNumbers const &	,
		cet::exempt_ptr< RunPrincipal const >
	)

private

Definition at line 1259 of file RootInputFile.cc.

   {
     subRunRangeSetHandler_ = fillAuxiliary_SubRun(entryNumbers);
     assert(subRunAux_.subRunID() == fiIter_->eventID_.subRunID());
     overrideRunNumber(subRunAux_.id_);
     assert(subRunAux_.runID() == rp->runID());
     if (subRunAux_.beginTime() == Timestamp::invalidTimestamp()) {
       subRunAux_.beginTime_ = eventAux_.time();
       subRunAux_.endTime_ = Timestamp::invalidTimestamp();
     }
     auto srp = make_unique<SubRunPrincipal>(
       subRunAux_,
       processConfiguration_,
       &presentProducts_.get(InSubRun),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      *sqliteDB_,
                                      entryNumbers,
                                      &subRunTree().branches(),
                                      subRunTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      nullptr,
                                      InSubRun,
                                      fiIter_->eventID_,
                                      compactSubRunRanges_));
     if (!delayedReadSubRunProducts_) {
       srp->readImmediate();
     }
     primarySRP_ = make_exempt_ptr(srp.get());
     return srp;
   }

unique_ptr< EventPrincipal > art::RootInputFile::readEvent ( )

Definition at line 1060 of file RootInputFile.cc.

   {
     assert(fiIter_ != fiEnd_);
     assert(fiIter_->getEntryType() == FileIndex::kEvent);
     assert(fiIter_->eventID_.runID().isValid());
     auto const& entryNumbers = getEntryNumbers(InEvent);
     auto ep = readCurrentEvent(entryNumbers);
     assert(ep);
     assert(eventAux_.run() == fiIter_->eventID_.run() + forcedRunOffset_);
     assert(eventAux_.subRunID() == fiIter_->eventID_.subRunID());
     nextEntry();
     return ep;
   }

bool art::RootInputFile::readEventForSecondaryFile ( EventID eID )

Definition at line 1111 of file RootInputFile.cc.

   {
     // Used just after opening a new secondary file in response to a
     // failed product lookup.  Synchronize the file index to the event
     // needed and create a secondary EventPrincipal for it.
     if (!setEntry_Event(eID, /*exact=*/true)) {
       // Error, could not find specified event in file.
       return false;
     }
     auto const& entryNumbers = getEntryNumbers(InEvent);
     assert(entryNumbers.first.size() == 1ull);
     fillAuxiliary_Event(entryNumbers.first.front());
     unique_ptr<History> history = make_unique<History>();
     fillHistory(entryNumbers.first.front(), *history);
     overrideRunNumber(const_cast<EventID&>(eventAux_.eventID()),
                       eventAux_.isRealData());
     auto ep = make_unique<EventPrincipal>(
       eventAux_,
       processConfiguration_,
       &presentProducts_.get(InEvent),
       move(history),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      nullptr,
                                      entryNumbers.first,
                                      &eventTree().branches(),
                                      eventTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      branchIDLists_.get(),
                                      InEvent,
                                      eventAux_.eventID(),
                                      compactSubRunRanges_),
       entryNumbers.second);
     primaryFile_->primaryEP_->addSecondaryPrincipal(move(ep));
     return true;
   }

void art::RootInputFile::readEventHistoryTree ( unsigned int treeCacheSize )

private

Definition at line 1370 of file RootInputFile.cc.

   {
     // Read in the event history tree, if we have one...
     eventHistoryTree_ = static_cast<TTree*>(
       filePtr_->Get(rootNames::eventHistoryTreeName().c_str()));
     if (!eventHistoryTree_) {
       throw art::Exception{errors::DataCorruption}
         << "Failed to find the event history tree.\n";
     }
     eventHistoryTree_->SetCacheSize(static_cast<Long64_t>(treeCacheSize));
   }

void art::RootInputFile::readParentageTree ( unsigned int treeCacheSize )

private

Definition at line 772 of file RootInputFile.cc.

   {
     //
     //  Auxiliary routine for the constructor.
     //
     auto parentageTree = static_cast<TTree*>(
       filePtr_->Get(rootNames::parentageTreeName().c_str()));
     if (!parentageTree) {
       throw art::Exception{errors::FileReadError}
         << couldNotFindTree(rootNames::parentageTreeName());
     }
     parentageTree->SetCacheSize(static_cast<Long64_t>(treeCacheSize));
     auto idBuffer = root::getObjectRequireDict<ParentageID>();
     auto pidBuffer = &idBuffer;
     parentageTree->SetBranchAddress(rootNames::parentageIDBranchName().c_str(),
                                     &pidBuffer);
 
     auto parentageBuffer = root::getObjectRequireDict<Parentage>();
     auto pParentageBuffer = &parentageBuffer;
     parentageTree->SetBranchAddress(rootNames::parentageBranchName().c_str(),
                                     &pParentageBuffer);
 
     // Fill the registry
     for (EntryNumber i = 0, numEntries = parentageTree->GetEntries();
          i < numEntries;
          ++i) {
       input::getEntry(parentageTree, i);
       if (idBuffer != parentageBuffer.id()) {
         throw art::Exception{errors::DataCorruption}
           << "Corruption of Parentage tree detected.\n";
       }
       ParentageRegistry::emplace(parentageBuffer.id(), parentageBuffer);
     }
 
     parentageTree->SetBranchAddress(rootNames::parentageIDBranchName().c_str(),
                                     nullptr);
     parentageTree->SetBranchAddress(rootNames::parentageBranchName().c_str(),
                                     nullptr);
   }

unique_ptr< art::ResultsPrincipal > art::RootInputFile::readResults ( )

Definition at line 1479 of file RootInputFile.cc.

   {
     unique_ptr<art::ResultsPrincipal> resp;
     if (!resultsTree().isValid()) {
       resp = make_unique<ResultsPrincipal>(
         ResultsAuxiliary{}, processConfiguration_, nullptr);
       return resp;
     }
 
     EntryNumbers const& entryNumbers{
       0}; // FIXME: Not sure hard-coding 0 is the right thing to do.
     assert(entryNumbers.size() == 1ull);
     fillAuxiliary_Results(entryNumbers.front());
     resp = std::make_unique<ResultsPrincipal>(
       resultsAux_,
       processConfiguration_,
       &presentProducts_.get(InResults),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      nullptr,
                                      entryNumbers,
                                      &resultsTree().branches(),
                                      resultsTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      nullptr,
                                      InResults,
                                      EventID{},
                                      compactSubRunRanges_));
     return resp;
   }

unique_ptr< RunPrincipal > art::RootInputFile::readRun ( )

Definition at line 1155 of file RootInputFile.cc.

   {
     assert(fiIter_ != fiEnd_);
     assert(fiIter_->getEntryType() == FileIndex::kRun);
     assert(fiIter_->eventID_.runID().isValid());
     auto const& entryNumbers = getEntryNumbers(InRun).first;
     auto rp = readCurrentRun(entryNumbers);
     advanceEntry(entryNumbers.size());
     return rp;
   }

bool art::RootInputFile::readRunForSecondaryFile ( RunID rID )

Definition at line 1199 of file RootInputFile.cc.

   {
     // Used just after opening a new secondary file in response to a failed
     // product lookup.  Synchronize the file index to the run needed and
     // create a secondary RunPrincipal for it.
     if (!setEntry_Run(rID)) {
       // Error, could not find specified run in file.
       return false;
     }
     auto const& entryNumbers = getEntryNumbers(InRun).first;
     assert(fiIter_ != fiEnd_);
     assert(fiIter_->getEntryType() == FileIndex::kRun);
     assert(fiIter_->eventID_.runID().isValid());
     runRangeSetHandler_ = fillAuxiliary_Run(entryNumbers);
     assert(runAux_.runID() == fiIter_->eventID_.runID());
     overrideRunNumber(runAux_);
     if (runAux_.beginTime() == Timestamp::invalidTimestamp()) {
       runAux_.beginTime(eventAux_.time());
       runAux_.endTime(Timestamp::invalidTimestamp());
     }
     auto rp = make_unique<RunPrincipal>(
       runAux_,
       processConfiguration_,
       &presentProducts_.get(InRun),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      *sqliteDB_,
                                      entryNumbers,
                                      &runTree().branches(),
                                      runTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      nullptr,
                                      InRun,
                                      fiIter_->eventID_,
                                      compactSubRunRanges_));
     if (!delayedReadRunProducts_) {
       rp->readImmediate();
     }
     primaryFile_->primaryRP_->addSecondaryPrincipal(move(rp));
     return true;
   }

unique_ptr< SubRunPrincipal > art::RootInputFile::readSubRun ( cet::exempt_ptr< RunPrincipal const > rp )

Definition at line 1248 of file RootInputFile.cc.

   {
     assert(fiIter_ != fiEnd_);
     assert(fiIter_->getEntryType() == FileIndex::kSubRun);
     auto const& entryNumbers = getEntryNumbers(InSubRun).first;
     auto srp = readCurrentSubRun(entryNumbers, rp);
     advanceEntry(entryNumbers.size());
     return srp;
   }

bool art::RootInputFile::readSubRunForSecondaryFile ( SubRunID srID )

Definition at line 1294 of file RootInputFile.cc.

   {
     // Used just after opening a new secondary file in response to a failed
     // product lookup.  Synchronize the file index to the subRun needed and
     // create a secondary SubRunPrincipal for it.
     if (!setEntry_SubRun(srID)) {
       // Error, could not find specified subRun in file.
       return false;
     }
     auto const& entryNumbers = getEntryNumbers(InSubRun).first;
     assert(fiIter_ != fiEnd_);
     assert(fiIter_->getEntryType() == FileIndex::kSubRun);
     subRunRangeSetHandler_ = fillAuxiliary_SubRun(entryNumbers);
     assert(subRunAux_.subRunID() == fiIter_->eventID_.subRunID());
     overrideRunNumber(subRunAux_.id_);
     if (subRunAux_.beginTime() == Timestamp::invalidTimestamp()) {
       subRunAux_.beginTime_ = eventAux_.time();
       subRunAux_.endTime_ = Timestamp::invalidTimestamp();
     }
     auto srp = make_unique<SubRunPrincipal>(
       subRunAux_,
       processConfiguration_,
       &presentProducts_.get(InSubRun),
       make_unique<RootDelayedReader>(fileFormatVersion_,
                                      *sqliteDB_,
                                      entryNumbers,
                                      &subRunTree().branches(),
                                      subRunTree().productProvenanceBranch(),
                                      saveMemoryObjectThreshold_,
                                      this,
                                      nullptr,
                                      InSubRun,
                                      fiIter_->eventID_,
                                      compactSubRunRanges_));
     if (!delayedReadSubRunProducts_) {
       srp->readImmediate();
     }
     primaryFile_->primarySRP_->addSecondaryPrincipal(move(srp));
     return true;
   }

void art::RootInputFile::reportOpened ( )

Definition at line 989 of file RootInputFile.cc.

990 {}

RootInputFile::RootInputTree const & art::RootInputFile::resultsTree ( ) const

private

Definition at line 543 of file RootInputFile.cc.

   {
     return *treePointers_[InResults];
   }

RootInputFile::RootInputTree & art::RootInputFile::resultsTree ( )

private

Definition at line 567 of file RootInputFile.cc.

   {
     return *treePointers_[InResults];
   }

void art::RootInputFile::rewind ( )

Definition at line 711 of file RootInputFile.cc.

   {
     fiIter_ = fiBegin_;
     // FIXME: Rewinding the trees is suspicious!
     // FIXME: They should be positioned based on the new iter pos.
     // eventTree().rewind();
     // subRunTree().rewind();
     // runTree().rewind();
   }

unique_ptr< RangeSetHandler > art::RootInputFile::runRangeSetHandler ( )

Definition at line 1149 of file RootInputFile.cc.

   {
     return move(runRangeSetHandler_);
   }

RootInputFile::RootInputTree const & art::RootInputFile::runTree ( ) const

private

Definition at line 537 of file RootInputFile.cc.

   {
     return *treePointers_[InRun];
   }

RootInputFile::RootInputTree & art::RootInputFile::runTree ( )

private

Definition at line 561 of file RootInputFile.cc.

   {
     return *treePointers_[InRun];
   }

vector< string > const & art::RootInputFile::secondaryFileNames ( ) const

Definition at line 760 of file RootInputFile.cc.

   {
     return secondaryFileNames_;
   }

vector< unique_ptr< RootInputFile > > const & art::RootInputFile::secondaryFiles ( ) const

Definition at line 766 of file RootInputFile.cc.

   {
     return secondaryFiles_;
   }

bool art::RootInputFile::setEntry_Event	(	EventID const &	id,
		bool	exact = `true`
	)

Definition at line 495 of file RootInputFile.cc.

   {
     fiIter_ = fileIndex_.findPosition(id, exact);
     if (fiIter_ == fiEnd_) {
       return false;
     }
     return true;
   }

bool art::RootInputFile::setEntry_Run	(	RunID const &	id,
		bool	exact = `true`
	)

Definition at line 515 of file RootInputFile.cc.

   {
     fiIter_ = fileIndex_.findPosition(id, exact);
     if (fiIter_ == fiEnd_) {
       return false;
     }
     return true;
   }

bool art::RootInputFile::setEntry_SubRun	(	SubRunID const &	id,
		bool	exact = `true`
	)

Definition at line 505 of file RootInputFile.cc.

   {
     fiIter_ = fileIndex_.findPosition(id, exact);
     if (fiIter_ == fiEnd_) {
       return false;
     }
     return true;
   }

int art::RootInputFile::setForcedRunOffset ( RunNumber_t const & forcedRunNumber )

Definition at line 865 of file RootInputFile.cc.

   {
     if (fiBegin_ == fiEnd_) {
       return 0;
     }
     forcedRunOffset_ = 0;
     if (!RunID(forcedRunNumber).isValid()) {
       return 0;
     }
     forcedRunOffset_ = forcedRunNumber - fiBegin_->eventID_.run();
     if (forcedRunOffset_ != 0) {
       fastClonable_ = false;
     }
     return forcedRunOffset_;
   }

bool art::RootInputFile::setIfFastClonable ( FastCloningInfoProvider const & fcip ) const

private

Definition at line 822 of file RootInputFile.cc.

   {
     if (!fcip.fastCloningPermitted()) {
       return false;
     }
     if (secondaryFileNames_.size() != 0) {
       return false;
     }
     if (!fileIndex_.allEventsInEntryOrder()) {
       return false;
     }
     if (eventsToSkip_ != 0) {
       return false;
     }
     if ((fcip.remainingEvents() >= 0) &&
         (eventTree().entries() > fcip.remainingEvents())) {
       return false;
     }
     if ((fcip.remainingSubRuns() >= 0) &&
         (subRunTree().entries() > fcip.remainingSubRuns())) {
       return false;
     }
     if (processingMode_ != InputSource::RunsSubRunsAndEvents) {
       return false;
     }
     if (forcedRunOffset_ != 0) {
       return false;
     }
     // Find entry for first event in file.
     auto it = fiBegin_;
     while ((it != fiEnd_) && (it->getEntryType() != FileIndex::kEvent)) {
       ++it;
     }
     if (it == fiEnd_) {
       return false;
     }
     if (it->eventID_ < origEventID_) {
       return false;
     }
     return true;
   }

void art::RootInputFile::setToLastEntry ( )

Definition at line 722 of file RootInputFile.cc.

   {
     fiIter_ = fiEnd_;
   }

int art::RootInputFile::skipEvents ( int offset )

Definition at line 1025 of file RootInputFile.cc.

   {
     while ((offset > 0) && (fiIter_ != fiEnd_)) {
       if (fiIter_->getEntryType() == FileIndex::kEvent) {
         --offset;
       }
       nextEntry();
     }
     while ((offset < 0) && (fiIter_ != fiBegin_)) {
       previousEntry();
       if (fiIter_->getEntryType() == FileIndex::kEvent) {
         ++offset;
       }
     }
     while ((fiIter_ != fiEnd_) &&
            (fiIter_->getEntryType() != FileIndex::kEvent)) {
       nextEntry();
     }
     return offset;
   }

unique_ptr< RangeSetHandler > art::RootInputFile::subRunRangeSetHandler ( )

Definition at line 1242 of file RootInputFile.cc.

   {
     return move(subRunRangeSetHandler_);
   }

RootInputFile::RootInputTree const & art::RootInputFile::subRunTree ( ) const

private

Definition at line 531 of file RootInputFile.cc.

   {
     return *treePointers_[InSubRun];
   }

RootInputFile::RootInputTree & art::RootInputFile::subRunTree ( )

private

Definition at line 555 of file RootInputFile.cc.

   {
     return *treePointers_[InSubRun];
   }

RootInputFile::RootInputTreePtrArray & art::RootInputFile::treePointers ( )

Definition at line 693 of file RootInputFile.cc.

   {
     return treePointers_;
   }

void art::RootInputFile::validateFile ( )

private

Definition at line 972 of file RootInputFile.cc.

   {
     if (!fileFormatVersion_.isValid()) {
       fileFormatVersion_.value_ = 0;
     }
     if (!eventTree().isValid()) {
       throw art::Exception{errors::DataCorruption}
         << "'Events' tree is corrupted or not present\n"
         << "in the input file.\n";
     }
     if (fileIndex_.empty()) {
       throw art::Exception{art::errors::FileReadError}
         << "FileIndex information is missing for the input file.\n";
     }
   }

Member Data Documentation

std::unique_ptr<BranchIDLists> art::RootInputFile::branchIDLists_ {}

private

Definition at line 242 of file RootInputFile.h.

std::string const art::RootInputFile::catalog_

private

Definition at line 210 of file RootInputFile.h.

bool const art::RootInputFile::compactSubRunRanges_

private

Definition at line 218 of file RootInputFile.h.

bool art::RootInputFile::delayedReadEventProducts_

private

Definition at line 220 of file RootInputFile.h.

bool art::RootInputFile::delayedReadRunProducts_

private

Definition at line 222 of file RootInputFile.h.

bool art::RootInputFile::delayedReadSubRunProducts_

private

Definition at line 221 of file RootInputFile.h.

std::shared_ptr<DuplicateChecker> art::RootInputFile::duplicateChecker_

private

Definition at line 226 of file RootInputFile.h.

EventAuxiliary art::RootInputFile::eventAux_ {}

private

Definition at line 237 of file RootInputFile.h.

TTree* art::RootInputFile::eventHistoryTree_ {nullptr}

private

Definition at line 243 of file RootInputFile.h.

EventNumber_t art::RootInputFile::eventsToSkip_

private

Definition at line 217 of file RootInputFile.h.

bool art::RootInputFile::fastClonable_ {false}

private

Definition at line 236 of file RootInputFile.h.

FileIndex::const_iterator art::RootInputFile::fiBegin_ {fileIndex_.begin()}

private

Definition at line 233 of file RootInputFile.h.

FileIndex::const_iterator art::RootInputFile::fiEnd_ {fileIndex_.end()}

private

Definition at line 234 of file RootInputFile.h.

FileIndex::const_iterator art::RootInputFile::fiIter_ {fiBegin_}

private

Definition at line 235 of file RootInputFile.h.

FileFormatVersion art::RootInputFile::fileFormatVersion_ {}

private

Definition at line 230 of file RootInputFile.h.

FileIndex& art::RootInputFile::fileIndex_ {*fileIndexSharedPtr_}

private

Definition at line 232 of file RootInputFile.h.

std::shared_ptr<FileIndex> art::RootInputFile::fileIndexSharedPtr_ {new FileIndex}

private

Definition at line 231 of file RootInputFile.h.

std::string const art::RootInputFile::fileName_

private

Definition at line 209 of file RootInputFile.h.

std::unique_ptr<TFile> art::RootInputFile::filePtr_

private

Definition at line 213 of file RootInputFile.h.

int art::RootInputFile::forcedRunOffset_

private

Definition at line 224 of file RootInputFile.h.

std::string const art::RootInputFile::logicalFileName_

private

Definition at line 212 of file RootInputFile.h.

bool art::RootInputFile::noEventSort_

private

Definition at line 225 of file RootInputFile.h.

EventID art::RootInputFile::origEventID_

private

Definition at line 216 of file RootInputFile.h.

ProductTables art::RootInputFile::presentProducts_ {ProductTables::invalid()}

private

Definition at line 241 of file RootInputFile.h.

cet::exempt_ptr<EventPrincipal> art::RootInputFile::primaryEP_ {}

private

Definition at line 250 of file RootInputFile.h.

cet::exempt_ptr<RootInputFile> art::RootInputFile::primaryFile_

private

Definition at line 227 of file RootInputFile.h.

cet::exempt_ptr<RunPrincipal> art::RootInputFile::primaryRP_ {}

private

Definition at line 251 of file RootInputFile.h.

cet::exempt_ptr<SubRunPrincipal> art::RootInputFile::primarySRP_ {}

private

Definition at line 252 of file RootInputFile.h.

ProcessConfiguration const& art::RootInputFile::processConfiguration_

private

Definition at line 211 of file RootInputFile.h.

InputSource::ProcessingMode art::RootInputFile::processingMode_

private

Definition at line 223 of file RootInputFile.h.

ResultsAuxiliary art::RootInputFile::resultsAux_ {}

private

Definition at line 240 of file RootInputFile.h.

cet::exempt_ptr<RootInputFileSequence> art::RootInputFile::rifSequence_

private

Definition at line 229 of file RootInputFile.h.

RunAuxiliary art::RootInputFile::runAux_ {}

private

Definition at line 239 of file RootInputFile.h.

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

private

Definition at line 254 of file RootInputFile.h.

int64_t art::RootInputFile::saveMemoryObjectThreshold_

private

Definition at line 255 of file RootInputFile.h.

std::vector<std::string> art::RootInputFile::secondaryFileNames_

private

Definition at line 228 of file RootInputFile.h.

std::vector<std::unique_ptr<RootInputFile> > art::RootInputFile::secondaryFiles_ {}

private

Definition at line 244 of file RootInputFile.h.

std::unique_ptr<cet::sqlite::Connection> art::RootInputFile::sqliteDB_ {nullptr}

private

Definition at line 215 of file RootInputFile.h.

SubRunAuxiliary art::RootInputFile::subRunAux_ {}

private

Definition at line 238 of file RootInputFile.h.

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

private

Definition at line 253 of file RootInputFile.h.

RootInputTreePtrArray art::RootInputFile::treePointers_

private

Definition at line 219 of file RootInputFile.h.

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

art/art/Framework/IO/Root/RootInputFile.h
art/art/Framework/IO/Root/RootInputFile.cc

Classes

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation