#include <RootFile.h>

Public Types
typedef std::array< RootTree *, NumBranchTypes >	RootTreePtrArray

Public Member Functions
boost::shared_ptr < BranchIDListHelper const >	branchIDListHelper () const

BranchIDLists const &	branchIDLists ()

bool	branchListIndexesUnchanged () const

void	close ()

bool	containsItem (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event) const

std::unique_ptr< FileBlock >	createFileBlock () const

EventAuxiliary const &	eventAux () const

EventID const &	eventID () const

RootTree const &	eventTree () const

std::string const &	file () const

FileFormatVersion	fileFormatVersion () const

IndexIntoFile::EntryType	getNextItemType (RunNumber_t &run, LuminosityBlockNumber_t &lumi, EventNumber_t &event)

bool	goToEvent (EventID const &eventID)

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

IndexIntoFile::IndexIntoFileItr	indexIntoFileIter () const

boost::shared_ptr< IndexIntoFile >	indexIntoFileSharedPtr () const

RootTree const &	lumiTree () const

bool	modifiedIDs () const

bool	nextEventEntry ()

RootFile &	operator= (RootFile const &)=delete

boost::shared_ptr < ProductRegistry const >	productRegistry () const

bool	readCurrentEvent (EventPrincipal &cache)

void	readEvent (EventPrincipal &cache)

void	readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)

boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

void	readRun_ (RunPrincipal &runPrincipal)

boost::shared_ptr< RunAuxiliary >	readRunAuxiliary_ ()

void	reportOpened (std::string const &inputType)

void	rewind ()

	RootFile (std::string const &fileName, ProcessConfiguration const &processConfiguration, std::string const &logicalFileName, boost::shared_ptr< InputFile > filePtr, boost::shared_ptr< EventSkipperByID > eventSkipperByID, bool skipAnyEvents, int remainingEvents, int remainingLumis, unsigned int nStreams, unsigned int treeCacheSize, int treeMaxVirtualSize, InputSource::ProcessingMode processingMode, RunNumber_t const &forcedRunNumber, bool noEventSort, ProductSelectorRules const &productSelectorRules, InputType inputType, boost::shared_ptr< BranchIDListHelper > branchIDListHelper, boost::shared_ptr< DuplicateChecker > duplicateChecker, bool dropDescendantsOfDroppedProducts, ProcessHistoryRegistry &processHistoryRegistry, std::vector< boost::shared_ptr< IndexIntoFile > > const &indexesIntoFiles, std::vector< boost::shared_ptr< IndexIntoFile > >::size_type currentIndexIntoFile, std::vector< ProcessHistoryID > &orderedProcessHistoryIDs, bool labelRawDataLikeMC, bool usingGoToEvent, bool enablePrefetching)

	RootFile (RootFile const &)=delete

RootTree const &	runTree () const

void	setAtEventEntry (IndexIntoFile::EntryNumber_t entry)

bool	setEntryAtEvent (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event)

bool	setEntryAtItem (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event)

bool	setEntryAtLumi (RunNumber_t run, LuminosityBlockNumber_t lumi)

bool	setEntryAtNextEventInLumi (RunNumber_t run, LuminosityBlockNumber_t lumi)

bool	setEntryAtRun (RunNumber_t run)

void	setPosition (IndexIntoFile::IndexIntoFileItr const &position)

void	setToLastEntry ()

bool	skipEvents (int &offset)

bool	wasFirstEventJustRead () const

bool	wasLastEventJustRead () const

int	whyNotFastClonable () const

	~RootFile ()

Private Member Functions
void	dropOnInput (ProductRegistry &reg, ProductSelectorRules const &rules, bool dropDescendants, InputType inputType)

bool	fillEventAuxiliary (IndexIntoFile::EntryNumber_t entry)

void	fillEventHistory ()

void	fillIndexIntoFile ()

boost::shared_ptr < LuminosityBlockAuxiliary >	fillLumiAuxiliary ()

boost::shared_ptr< RunAuxiliary >	fillRunAuxiliary ()

void	fillThisEventAuxiliary ()

void	initializeDuplicateChecker (std::vector< boost::shared_ptr< IndexIntoFile > > const &indexesIntoFiles, std::vector< boost::shared_ptr< IndexIntoFile > >::size_type currentIndexIntoFile)

bool	isDuplicateEvent ()

boost::shared_ptr < ProductProvenanceRetriever >	makeProductProvenanceRetriever (unsigned int iStreamIndex)

std::unique_ptr < MakeProvenanceReader >	makeProvenanceReaderMaker (InputType inputType)

std::string const &	newBranchToOldBranch (std::string const &newBranch) const

void	overrideRunNumber (RunID &id)

void	overrideRunNumber (LuminosityBlockID &id)

void	overrideRunNumber (EventID &id, bool isRealData)

void	readEntryDescriptionTree (EntryDescriptionMap &entryDescriptionMap, InputType inputType)

void	readEventHistoryTree ()

void	readParentageTree (InputType inputType)

void	setIfFastClonable (int remainingEvents, int remainingLumis)

bool	skipThisEntry ()

RootTreePtrArray &	treePointers ()

void	validateFile (InputType inputType, bool usingGoToEvent)

Private Attributes
boost::shared_ptr< BranchChildren >	branchChildren_

boost::shared_ptr < BranchIDListHelper >	branchIDListHelper_

boost::shared_ptr < BranchIDLists const >	branchIDLists_

BranchListIndexes	branchListIndexes_

bool	branchListIndexesUnchanged_

std::unique_ptr < DaqProvenanceHelper >	daqProvenanceHelper_

boost::shared_ptr < DuplicateChecker >	duplicateChecker_

EventAuxiliary	eventAux_

TTree *	eventHistoryTree_

std::vector < EventProcessHistoryID >	eventProcessHistoryIDs_

std::vector < EventProcessHistoryID > ::const_iterator	eventProcessHistoryIter_

std::vector< boost::shared_ptr < ProductProvenanceRetriever > >	eventProductProvenanceRetrievers_

EventSelectionIDVector	eventSelectionIDs_

boost::shared_ptr < EventSkipperByID >	eventSkipperByID_

RootTree	eventTree_

FileID	fid_

std::string const	file_

FileFormatVersion	fileFormatVersion_

boost::shared_ptr< InputFile >	filePtr_

int	forcedRunOffset_

std::array< bool, NumBranchTypes >	hasNewlyDroppedBranch_

std::unique_ptr< History >	history_

IndexIntoFile &	indexIntoFile_

IndexIntoFile::IndexIntoFileItr	indexIntoFileBegin_

IndexIntoFile::IndexIntoFileItr	indexIntoFileEnd_

IndexIntoFile::IndexIntoFileItr	indexIntoFileIter_

boost::shared_ptr< IndexIntoFile >	indexIntoFileSharedPtr_

IndexIntoFile::EntryNumber_t	lastEventEntryNumberRead_

std::string const	logicalFile_

RootTree	lumiTree_

std::map< std::string, std::string >	newBranchToOldBranch_

bool	noEventSort_

std::vector< ProcessHistoryID > &	orderedProcessHistoryIDs_

std::vector< ParentageID >	parentageIDLookup_

ProcessConfiguration const &	processConfiguration_

ProcessHistoryRegistry *	processHistoryRegistry_

InputSource::ProcessingMode	processingMode_

boost::shared_ptr < ProductRegistry const >	productRegistry_

std::unique_ptr < ProvenanceAdaptor >	provenanceAdaptor_

std::unique_ptr < MakeProvenanceReader >	provenanceReaderMaker_

RootTree	runTree_

boost::shared_ptr< RunAuxiliary >	savedRunAuxiliary_

bool	skipAnyEvents_

RootTreePtrArray	treePointers_

int	whyNotFastClonable_

Detailed Description

Definition at line 55 of file RootFile.h.

Member Typedef Documentation

typedef std::array<RootTree*, NumBranchTypes> edm::RootFile::RootTreePtrArray

Definition at line 57 of file RootFile.h.

Constructor & Destructor Documentation

edm::RootFile::RootFile	(	std::string const &	fileName,
		ProcessConfiguration const &	processConfiguration,
		std::string const &	logicalFileName,
		boost::shared_ptr< InputFile >	filePtr,
		boost::shared_ptr< EventSkipperByID >	eventSkipperByID,
		bool	skipAnyEvents,
		int	remainingEvents,
		int	remainingLumis,
		unsigned int	nStreams,
		unsigned int	treeCacheSize,
		int	treeMaxVirtualSize,
		InputSource::ProcessingMode	processingMode,
		RunNumber_t const &	forcedRunNumber,
		bool	noEventSort,
		ProductSelectorRules const &	productSelectorRules,
		InputType	inputType,
		boost::shared_ptr< BranchIDListHelper >	branchIDListHelper,
		boost::shared_ptr< DuplicateChecker >	duplicateChecker,
		bool	dropDescendantsOfDroppedProducts,
		ProcessHistoryRegistry &	processHistoryRegistry,
		std::vector< boost::shared_ptr< IndexIntoFile > > const &	indexesIntoFiles,
		std::vector< boost::shared_ptr< IndexIntoFile > >::size_type	currentIndexIntoFile,
		std::vector< ProcessHistoryID > &	orderedProcessHistoryIDs,
		bool	labelRawDataLikeMC,
		bool	usingGoToEvent,
		bool	enablePrefetching
	)

Definition at line 138 of file RootFile.cc.

References edm::IndexIntoFile::begin(), branchChildren_, edm::poolNames::branchIDListBranchName(), branchIDListHelper_, branchIDLists_, branchListIndexesUnchanged_, edm::BranchDescription::branchName(), edm::BranchDescription::branchType(), edm::BranchTypeToAuxiliaryBranchName(), edm::BranchDescription::className(), edm::ProductRegistry::copyProduct(), daqProvenanceHelper_, edm::roottree::defaultNonEventCacheSize, edm::IndexIntoFile::doneFileInitialization(), dropOnInput(), edm::IndexIntoFile::end(), edm::errors::EventCorruption, edm::poolNames::eventHistoryBranchName(), eventProcessHistoryIDs_, eventProcessHistoryIter_, eventSkipperByID_, edm::FileBlock::EventsOrLumisSelectedByID, eventTree_, edm::hlt::Exception, fid_, file(), fileFormatVersion(), fileFormatVersion_, edm::poolNames::fileFormatVersionBranchName(), edm::poolNames::fileIdentifierBranchName(), filePtr_, edm::errors::FileReadError, edm::IndexIntoFile::firstAppearanceOrder, forcedRunOffset_, edm::BranchDescription::friendlyClassName(), edm::friendlyname::friendlyName(), edm::roottree::getEntry(), hasNewlyDroppedBranch_, i, edm::poolNames::idToParameterSetBlobsBranchName(), indexIntoFile_, indexIntoFileBegin_, edm::poolNames::indexIntoFileBranchName(), indexIntoFileEnd_, indexIntoFileIter_, edm::InEvent, edm::BranchDescription::init(), initializeDuplicateChecker(), edm::InLumi, edm::InRun, edm::pset::Registry::insertMapped(), edm::pset::Registry::instance(), lumiTree_, makeProvenanceReaderMaker(), edm::poolNames::metaDataTreeName(), edm::poolNames::moduleDescriptionMapBranchName(), newBranchToOldBranch(), newBranchToOldBranch_, edm::IndexIntoFile::numericalOrder, edm::poolNames::parameterSetMapBranchName(), edm::poolNames::parameterSetsTreeName(), edm::Primary, edm::poolNames::processConfigurationBranchName(), edm::poolNames::processHistoryBranchName(), edm::poolNames::processHistoryMapBranchName(), parseEventContent::prod, edm::poolNames::productDependenciesBranchName(), edm::poolNames::productDescriptionBranchName(), edm::ProductRegistry::productList(), edm::ProductRegistry::productListUpdator(), productRegistry(), productRegistry_, provenanceAdaptor_, provenanceReaderMaker_, readEventHistoryTree(), edm::ProcessHistoryRegistry::registerProcessHistory(), fetchall_from_DQM_v2::release, edm::RootTree::resetTraining(), runTree_, edm::SecondarySource, edm::ParameterSet::setID(), setIfFastClonable(), edm::setRefCoreStreamer(), edm::source(), AlCaHLTBitMon_QueryRunRegistry::string, edm::RootTree::trainCache(), edm::roottree::trainCache(), treePointers_, edm::errors::UnimplementedFeature, edm::BranchDescription::updateFriendlyClassName(), validateFile(), and whyNotFastClonable_.

                                              :
       file_(fileName),
       logicalFile_(logicalFileName),
       processConfiguration_(processConfiguration),
       processHistoryRegistry_(&processHistoryRegistry),
       filePtr_(filePtr),
       eventSkipperByID_(eventSkipperByID),
       fileFormatVersion_(),
       fid_(),
       indexIntoFileSharedPtr_(new IndexIntoFile),
       indexIntoFile_(*indexIntoFileSharedPtr_),
       orderedProcessHistoryIDs_(orderedProcessHistoryIDs),
       indexIntoFileBegin_(indexIntoFile_.begin(noEventSort ? IndexIntoFile::firstAppearanceOrder : IndexIntoFile::numericalOrder)),
       indexIntoFileEnd_(indexIntoFileBegin_),
       indexIntoFileIter_(indexIntoFileBegin_),
       eventProcessHistoryIDs_(),
       eventProcessHistoryIter_(eventProcessHistoryIDs_.begin()),
       savedRunAuxiliary_(),
       skipAnyEvents_(skipAnyEvents),
       noEventSort_(noEventSort),
       whyNotFastClonable_(0),
       hasNewlyDroppedBranch_(),
       branchListIndexesUnchanged_(false),
       eventAux_(),
       eventTree_(filePtr_, InEvent, nStreams, treeMaxVirtualSize, treeCacheSize, roottree::defaultLearningEntries, enablePrefetching, inputType),
       lumiTree_(filePtr_, InLumi, 1, treeMaxVirtualSize, roottree::defaultNonEventCacheSize, roottree::defaultNonEventLearningEntries, enablePrefetching, inputType),
       runTree_(filePtr_, InRun, 1, treeMaxVirtualSize, roottree::defaultNonEventCacheSize, roottree::defaultNonEventLearningEntries, enablePrefetching, inputType),
       treePointers_(),
       lastEventEntryNumberRead_(IndexIntoFile::invalidEntry),
       productRegistry_(),
       branchIDLists_(),
       branchIDListHelper_(branchIDListHelper),
       processingMode_(processingMode),
       forcedRunOffset_(0),
       newBranchToOldBranch_(),
       eventHistoryTree_(nullptr),
       eventSelectionIDs_(),
       branchListIndexes_(),
       history_(),
       branchChildren_(new BranchChildren),
       duplicateChecker_(duplicateChecker),
       provenanceAdaptor_(),
       provenanceReaderMaker_(),
       eventProductProvenanceRetrievers_(),
       parentageIDLookup_(),
       daqProvenanceHelper_() {
 
     hasNewlyDroppedBranch_.fill(false);
 
     treePointers_[InEvent] = &eventTree_;
     treePointers_[InLumi]  = &lumiTree_;
     treePointers_[InRun]   = &runTree_;
 
     // Read the metadata tree.
     // We use a smart pointer so the tree will be deleted after use, and not kept for the life of the file.
     std::unique_ptr<TTree> metaDataTree(dynamic_cast<TTree *>(filePtr_->Get(poolNames::metaDataTreeName().c_str())));
     if(nullptr == metaDataTree.get()) {
       throw Exception(errors::FileReadError) << "Could not find tree " << poolNames::metaDataTreeName()
                                              << " in the input file.\n";
     }
 
     // To keep things simple, we just read in every possible branch that exists.
     // We don't pay attention to which branches exist in which file format versions
 
     FileFormatVersion *fftPtr = &fileFormatVersion_;
     if(metaDataTree->FindBranch(poolNames::fileFormatVersionBranchName().c_str()) != nullptr) {
       TBranch *fft = metaDataTree->GetBranch(poolNames::fileFormatVersionBranchName().c_str());
       fft->SetAddress(&fftPtr);
       roottree::getEntry(fft, 0);
       metaDataTree->SetBranchAddress(poolNames::fileFormatVersionBranchName().c_str(), &fftPtr);
     }
 
     FileID *fidPtr = &fid_;
     if(metaDataTree->FindBranch(poolNames::fileIdentifierBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::fileIdentifierBranchName().c_str(), &fidPtr);
     }
 
     IndexIntoFile *iifPtr = &indexIntoFile_;
     if(metaDataTree->FindBranch(poolNames::indexIntoFileBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::indexIntoFileBranchName().c_str(), &iifPtr);
     }
 
     // Need to read to a temporary registry so we can do a translation of the BranchKeys.
     // This preserves backward compatibility against friendly class name algorithm changes.
     ProductRegistry inputProdDescReg;
     ProductRegistry *ppReg = &inputProdDescReg;
     metaDataTree->SetBranchAddress(poolNames::productDescriptionBranchName().c_str(), (&ppReg));
 
     typedef std::map<ParameterSetID, ParameterSetBlob> PsetMap;
     PsetMap psetMap;
     PsetMap *psetMapPtr = &psetMap;
     if(metaDataTree->FindBranch(poolNames::parameterSetMapBranchName().c_str()) != nullptr) {
       //backward compatibility
       assert(!fileFormatVersion().parameterSetsTree());
       metaDataTree->SetBranchAddress(poolNames::parameterSetMapBranchName().c_str(), &psetMapPtr);
     } else {
       assert(fileFormatVersion().parameterSetsTree());
       // We use a smart pointer so the tree will be deleted after use, and not kept for the life of the file.
       std::unique_ptr<TTree> psetTree(dynamic_cast<TTree *>(filePtr_->Get(poolNames::parameterSetsTreeName().c_str())));
       if(nullptr == psetTree.get()) {
         throw Exception(errors::FileReadError) << "Could not find tree " << poolNames::parameterSetsTreeName()
         << " in the input file.\n";
       }
 
       typedef std::pair<ParameterSetID, ParameterSetBlob> IdToBlobs;
       IdToBlobs idToBlob;
       IdToBlobs* pIdToBlob = &idToBlob;
       psetTree->SetBranchAddress(poolNames::idToParameterSetBlobsBranchName().c_str(), &pIdToBlob);
 
       std::unique_ptr<TTreeCache> psetTreeCache = roottree::trainCache(psetTree.get(), *filePtr_, roottree::defaultNonEventCacheSize, "*");
       psetTreeCache->SetEnablePrefetching(false);
       filePtr_->SetCacheRead(psetTreeCache.get());
       for(Long64_t i = 0; i != psetTree->GetEntries(); ++i) {
         psetTree->GetEntry(i);
         psetMap.insert(idToBlob);
       }
       filePtr_->SetCacheRead(0);
     }
 
     // backward compatibility
     ProcessHistoryRegistry::collection_type pHistMap;
     ProcessHistoryRegistry::collection_type *pHistMapPtr = &pHistMap;
     if(metaDataTree->FindBranch(poolNames::processHistoryMapBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::processHistoryMapBranchName().c_str(), &pHistMapPtr);
     }
 
     ProcessHistoryRegistry::vector_type pHistVector;
     ProcessHistoryRegistry::vector_type *pHistVectorPtr = &pHistVector;
     if(metaDataTree->FindBranch(poolNames::processHistoryBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::processHistoryBranchName().c_str(), &pHistVectorPtr);
     }
 
     // backward compatibility
     ProcessConfigurationVector processConfigurations;
     ProcessConfigurationVector* procConfigVectorPtr = &processConfigurations;
     if(metaDataTree->FindBranch(poolNames::processConfigurationBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::processConfigurationBranchName().c_str(), &procConfigVectorPtr);
     }
 
     std::unique_ptr<BranchIDLists> branchIDListsAPtr(new BranchIDLists);
     BranchIDLists* branchIDListsPtr = branchIDListsAPtr.get();
     if(metaDataTree->FindBranch(poolNames::branchIDListBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::branchIDListBranchName().c_str(), &branchIDListsPtr);
     }
 
     BranchChildren* branchChildrenBuffer = branchChildren_.get();
     if(metaDataTree->FindBranch(poolNames::productDependenciesBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::productDependenciesBranchName().c_str(), &branchChildrenBuffer);
     }
 
     // backward compatibility
     std::vector<EventProcessHistoryID> *eventHistoryIDsPtr = &eventProcessHistoryIDs_;
     if(metaDataTree->FindBranch(poolNames::eventHistoryBranchName().c_str()) != nullptr) {
       metaDataTree->SetBranchAddress(poolNames::eventHistoryBranchName().c_str(), &eventHistoryIDsPtr);
     }
 
     if(metaDataTree->FindBranch(poolNames::moduleDescriptionMapBranchName().c_str()) != nullptr) {
       if(metaDataTree->GetBranch(poolNames::moduleDescriptionMapBranchName().c_str())->GetSplitLevel() != 0) {
         metaDataTree->SetBranchStatus((poolNames::moduleDescriptionMapBranchName() + ".*").c_str(), 0);
       } else {
         metaDataTree->SetBranchStatus(poolNames::moduleDescriptionMapBranchName().c_str(), 0);
       }
     }
 
     // Here we read the metadata tree
     roottree::getEntry(metaDataTree.get(), 0);
 
     eventProcessHistoryIter_ = eventProcessHistoryIDs_.begin();
 
     // Here we read the event history tree, if we have one.
     readEventHistoryTree();
 
     ParameterSetConverter::ParameterSetIdConverter psetIdConverter;
     if(!fileFormatVersion().triggerPathsTracked()) {
       ParameterSetConverter converter(psetMap, psetIdConverter, fileFormatVersion().parameterSetsByReference());
     } else {
       // Merge into the parameter set registry.
       pset::Registry& psetRegistry = *pset::Registry::instance();
       for(auto const& psetEntry : psetMap) {
         ParameterSet pset(psetEntry.second.pset());
         pset.setID(psetEntry.first);
         // For thread safety, don't update global registries when a secondary source opens a file.
         if(inputType != InputType::SecondarySource) {
           psetRegistry.insertMapped(pset);
         }
       }
     }
     if(!fileFormatVersion().splitProductIDs()) {
       // Old provenance format input file.  Create a provenance adaptor.
       provenanceAdaptor_.reset(new ProvenanceAdaptor(
             inputProdDescReg, pHistMap, pHistVector, processConfigurations, psetIdConverter, true));
       // Fill in the branchIDLists branch from the provenance adaptor
       branchIDLists_ = provenanceAdaptor_->branchIDLists();
     } else {
       if(!fileFormatVersion().triggerPathsTracked()) {
         // New provenance format, but change in ParameterSet Format. Create a provenance adaptor.
         provenanceAdaptor_.reset(new ProvenanceAdaptor(
             inputProdDescReg, pHistMap, pHistVector, processConfigurations, psetIdConverter, false));
       }
       // New provenance format input file. The branchIDLists branch was read directly from the input file.
       if(metaDataTree->FindBranch(poolNames::branchIDListBranchName().c_str()) == nullptr) {
         throw Exception(errors::EventCorruption)
           << "Failed to find branchIDLists branch in metaData tree.\n";
       }
       branchIDLists_.reset(branchIDListsAPtr.release());
     }
 
     checkReleaseVersion(pHistVector, file());
 
     if(labelRawDataLikeMC) {
       std::string const rawData("FEDRawDataCollection");
       std::string const source("source");
       ProductRegistry::ProductList& pList = inputProdDescReg.productListUpdator();
       BranchKey finder(rawData, source, "", "");
       ProductRegistry::ProductList::iterator it = pList.lower_bound(finder);
       if(it != pList.end() && it->first.friendlyClassName() == rawData && it->first.moduleLabel() == source) {
         // We found raw data with a module label of source.
         // We need to change the module label and process name.
         // Create helper.
         it->second.init();
         daqProvenanceHelper_.reset(new DaqProvenanceHelper(it->second.unwrappedTypeID()));
         // Create the new branch description
         BranchDescription const& newBD = daqProvenanceHelper_->branchDescription();
         // Save info from the old and new branch descriptions
         daqProvenanceHelper_->saveInfo(it->second, newBD);
         // Map the new branch name to the old branch name.
         newBranchToOldBranch_.insert(std::make_pair(newBD.branchName(), it->second.branchName()));
         // Remove the old branch description from the product Registry.
         pList.erase(it);
         // Check that there was only one.
         it = pList.lower_bound(finder);
         assert(!(it != pList.end() && it->first.friendlyClassName() == rawData && it->first.moduleLabel() == source));
         // Insert the new branch description into the product registry.
         inputProdDescReg.copyProduct(newBD);
         // Fix up other per file metadata.
         daqProvenanceHelper_->fixMetaData(processConfigurations, pHistVector);
         daqProvenanceHelper_->fixMetaData(*branchIDLists_);
         daqProvenanceHelper_->fixMetaData(*branchChildren_);
       }
     }
 
     for(auto const& history : pHistVector) {
       processHistoryRegistry.registerProcessHistory(history);
     }
 
     eventTree_.trainCache(BranchTypeToAuxiliaryBranchName(InEvent).c_str());
         
     // Update the branch id info. This has to be done before validateFile since
     // depending on the file format, the branchIDListHelper_ may have its fixBranchListIndexes call made
     if(inputType == InputType::Primary || inputType == InputType::SecondarySource) {
       branchListIndexesUnchanged_ = branchIDListHelper_->updateFromInput(*branchIDLists_);
     }
         
     validateFile(inputType, usingGoToEvent);
 
     // Here, we make the class that will make the ProvenanceReader
     // It reads whatever trees it needs.
     provenanceReaderMaker_.reset(makeProvenanceReaderMaker(inputType).release());
 
     // Merge into the hashed registries.
     if(eventSkipperByID_ && eventSkipperByID_->somethingToSkip()) {
       whyNotFastClonable_ += FileBlock::EventsOrLumisSelectedByID;
     }
 
     initializeDuplicateChecker(indexesIntoFiles, currentIndexIntoFile);
     indexIntoFileIter_ = indexIntoFileBegin_ = indexIntoFile_.begin(noEventSort ? IndexIntoFile::firstAppearanceOrder : IndexIntoFile::numericalOrder);
     indexIntoFileEnd_ = indexIntoFile_.end(noEventSort ? IndexIntoFile::firstAppearanceOrder : IndexIntoFile::numericalOrder);
     forcedRunOffset_ = forcedRunOffset(forcedRunNumber, indexIntoFileBegin_, indexIntoFileEnd_);
     eventProcessHistoryIter_ = eventProcessHistoryIDs_.begin();
 
     // Set product presence information in the product registry.
     ProductRegistry::ProductList& pList = inputProdDescReg.productListUpdator();
     for(auto& product : pList) {
       BranchDescription& prod = product.second;
       prod.init();
       treePointers_[prod.branchType()]->setPresence(prod, newBranchToOldBranch(prod.branchName()));
     }
 
     std::unique_ptr<ProductRegistry> newReg(new ProductRegistry);
 
     // Do the translation from the old registry to the new one
     {
       ProductRegistry::ProductList const& prodList = inputProdDescReg.productList();
       for(auto const& product : prodList) {
         BranchDescription const& prod = product.second;
         std::string newFriendlyName = friendlyname::friendlyName(prod.className());
         if(newFriendlyName == prod.friendlyClassName()) {
           newReg->copyProduct(prod);
         } else {
           if(fileFormatVersion().splitProductIDs()) {
             throw Exception(errors::UnimplementedFeature)
               << "Cannot change friendly class name algorithm without more development work\n"
               << "to update BranchIDLists.  Contact the framework group.\n";
           }
           BranchDescription newBD(prod);
           newBD.updateFriendlyClassName();
           newReg->copyProduct(newBD);
           newBranchToOldBranch_.insert(std::make_pair(newBD.branchName(), prod.branchName()));
         }
       }
       dropOnInput(*newReg, productSelectorRules, dropDescendants, inputType);
       // freeze the product registry
       newReg->setFrozen(inputType != InputType::Primary);
       productRegistry_.reset(newReg.release());
     }
 
     // Set up information from the product registry.
     ProductRegistry::ProductList const& prodList = productRegistry()->productList();
     for(auto const& product : prodList) {
       BranchDescription const& prod = product.second;
       treePointers_[prod.branchType()]->addBranch(product.first, prod,
                                                   newBranchToOldBranch(prod.branchName()));
     }
 
     // Determine if this file is fast clonable.
     setIfFastClonable(remainingEvents, remainingLumis);
 
     setRefCoreStreamer(true);  // backward compatibility
 
     // We are done with our initial reading of EventAuxiliary.
     indexIntoFile_.doneFileInitialization();
 
     // Tell the event tree to begin training at the next read.
     eventTree_.resetTraining();
 
     // Train the run and lumi trees.
     runTree_.trainCache("*");
     lumiTree_.trainCache("*");
   }

edm::RootFile::~RootFile ( )

Definition at line 493 of file RootFile.cc.

493 {

494 }

edm::RootFile::RootFile ( RootFile const & )

delete

Member Function Documentation

boost::shared_ptr<BranchIDListHelper const> edm::RootFile::branchIDListHelper ( ) const

inline

Definition at line 100 of file RootFile.h.

References branchIDListHelper_.

100 {return branchIDListHelper_;}

edm::RootFile::branchIDListHelper_

boost::shared_ptr< BranchIDListHelper > branchIDListHelper_

Definition: RootFile.h:205

BranchIDLists const& edm::RootFile::branchIDLists ( )

inline

Definition at line 101 of file RootFile.h.

References branchIDLists_.

101 {return *branchIDLists_;}

edm::RootFile::branchIDLists_

boost::shared_ptr< BranchIDLists const > branchIDLists_

Definition: RootFile.h:204

bool edm::RootFile::branchListIndexesUnchanged ( ) const

inline

Definition at line 113 of file RootFile.h.

References branchListIndexesUnchanged_.

Referenced by createFileBlock().

113 {return branchListIndexesUnchanged_;}

edm::RootFile::branchListIndexesUnchanged_

bool branchListIndexesUnchanged_

Definition: RootFile.h:196

void edm::RootFile::close ( void )

Definition at line 1130 of file RootFile.cc.

References eventHistoryTree_, filePtr_, and treePointers_.

Referenced by lumiQTWidget.ApplicationWindow::fileQuit(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), and Vispa.Gui.FindDialog.FindDialog::keyPressEvent().

                   {
     // Just to play it safe, zero all pointers to objects in the InputFile to be closed.
     eventHistoryTree_ = nullptr;
     for(auto& treePointer : treePointers_) {
       treePointer->close();
       treePointer = nullptr;
     }
     filePtr_->Close();
     filePtr_.reset();
   }

bool edm::RootFile::containsItem	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event
	)		const

Definition at line 724 of file RootFile.cc.

References edm::IndexIntoFile::containsItem(), and indexIntoFile_.

                                                                                                  {
     return indexIntoFile_.containsItem(run, lumi, event);
   }

std::unique_ptr< FileBlock > edm::RootFile::createFileBlock ( ) const

Definition at line 633 of file RootFile.cc.

References branchChildren_, branchListIndexesUnchanged(), eventTree_, file_, fileFormatVersion(), hasNewlyDroppedBranch(), lumiTree_, edm::RootTree::metaTree(), modifiedIDs(), runTree_, edm::RootTree::tree(), and whyNotFastClonable().

                                   {
     return std::unique_ptr<FileBlock>(new FileBlock(fileFormatVersion(),
                                                      eventTree_.tree(),
                                                      eventTree_.metaTree(),
                                                      lumiTree_.tree(),
                                                      lumiTree_.metaTree(),
                                                      runTree_.tree(),
                                                      runTree_.metaTree(),
                                                      whyNotFastClonable(),
                                                      hasNewlyDroppedBranch(),
                                                      file_,
                                                      branchListIndexesUnchanged(),
                                                      modifiedIDs(),
                                                      branchChildren_));
   }

void edm::RootFile::dropOnInput	(	ProductRegistry &	reg,
		ProductSelectorRules const &	rules,
		bool	dropDescendants,
		InputType	inputType
	)

private

Definition at line 1664 of file RootFile.cc.

References edm::ProductRegistry::allBranchDescriptions(), branchChildren_, edm::BranchDescription::branchID(), edm::BranchDescription::branchName(), edm::BranchDescription::branchType(), CommonMethods::cp(), drop, file_, edm::BranchDescription::getInterface(), hasNewlyDroppedBranch_, edm::InEvent, edm::ProductSelector::initialize(), newBranchToOldBranch(), parseEventContent::prod, edm::ProductRegistry::productListUpdator(), edm::SecondaryFile, edm::ProductSelector::selected(), treePointers_, and edm::BranchDescription::wrappedName().

Referenced by RootFile().

                                                                                                                            {
     // This is the selector for drop on input.
     ProductSelector productSelector;
     productSelector.initialize(rules, reg.allBranchDescriptions());
 
     ProductRegistry::ProductList& prodList = reg.productListUpdator();
     // Do drop on input. On the first pass, just fill in a set of branches to be dropped.
     std::set<BranchID> branchesToDrop;
     for(auto const& product : prodList) {
       BranchDescription const& prod = product.second;
       if(!productSelector.selected(prod)) {
         if(dropDescendants) {
           branchChildren_->appendToDescendants(prod.branchID(), branchesToDrop);
         } else {
           branchesToDrop.insert(prod.branchID());
         }
       }
     }
 
     // On this pass, actually drop the branches.
     std::set<BranchID>::const_iterator branchesToDropEnd = branchesToDrop.end();
     for(ProductRegistry::ProductList::iterator it = prodList.begin(), itEnd = prodList.end(); it != itEnd;) {
       BranchDescription const& prod = it->second;
       bool drop = branchesToDrop.find(prod.branchID()) != branchesToDropEnd;
       if(drop) {
         if(productSelector.selected(prod)) {
           LogWarning("RootFile")
             << "Branch '" << prod.branchName() << "' is being dropped from the input\n"
             << "of file '" << file_ << "' because it is dependent on a branch\n"
             << "that was explicitly dropped.\n";
         }
         treePointers_[prod.branchType()]->dropBranch(newBranchToOldBranch(prod.branchName()));
         hasNewlyDroppedBranch_[prod.branchType()] = true;
         ProductRegistry::ProductList::iterator icopy = it;
         ++it;
         prodList.erase(icopy);
       } else {
         ++it;
       }
     }
 
     // Drop on input mergeable run and lumi products, this needs to be invoked for secondary file input
     if(inputType == InputType::SecondaryFile) {
       TString tString;
       for(ProductRegistry::ProductList::iterator it = prodList.begin(), itEnd = prodList.end(); it != itEnd;) {
         BranchDescription const& prod = it->second;
         if(prod.branchType() != InEvent) {
           TClass *cp = gROOT->GetClass(prod.wrappedName().c_str());
           WrapperOwningHolder edp(cp->New(), prod.getInterface());
           if(edp.isMergeable()) {
             treePointers_[prod.branchType()]->dropBranch(newBranchToOldBranch(prod.branchName()));
             ProductRegistry::ProductList::iterator icopy = it;
             ++it;
             prodList.erase(icopy);
           } else {
             ++it;
           }
         }
         else ++it;
       }
     }
   }

EventAuxiliary const& edm::RootFile::eventAux ( ) const

inline

Definition at line 102 of file RootFile.h.

References eventAux_.

Referenced by eventID(), fillEventHistory(), fillIndexIntoFile(), fillThisEventAuxiliary(), initializeDuplicateChecker(), readCurrentEvent(), readEvent(), readLuminosityBlockAuxiliary_(), and readRunAuxiliary_().

102 {return eventAux_;}

edm::RootFile::eventAux_

EventAuxiliary eventAux_

Definition: RootFile.h:197

EventID const& edm::RootFile::eventID ( ) const

inline

Definition at line 106 of file RootFile.h.

References eventAux(), and edm::EventAuxiliary::id().

106 {return eventAux().id();}

edm::RootFile::eventAux

EventAuxiliary const & eventAux() const

Definition: RootFile.h:102

edm::EventAuxiliary::id

EventID const & id() const

Definition: EventAuxiliary.h:59

RootTree const& edm::RootFile::eventTree ( ) const

inline

Definition at line 107 of file RootFile.h.

References eventTree_.

107 {return eventTree_;}

edm::RootFile::eventTree_

RootTree eventTree_

Definition: RootFile.h:198

std::string const& edm::RootFile::file ( ) const

inline

Definition at line 98 of file RootFile.h.

References file_.

Referenced by RootFile().

98 {return file_;}

edm::RootFile::file_

std::string const file_

Definition: RootFile.h:175

FileFormatVersion edm::RootFile::fileFormatVersion ( ) const

inline

Definition at line 110 of file RootFile.h.

References fileFormatVersion_.

Referenced by createFileBlock(), fillEventHistory(), fillIndexIntoFile(), fillLumiAuxiliary(), fillRunAuxiliary(), fillThisEventAuxiliary(), readCurrentEvent(), readEvent(), readEventHistoryTree(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), RootFile(), setIfFastClonable(), and validateFile().

110 {return fileFormatVersion_;}

edm::RootFile::fileFormatVersion_

FileFormatVersion fileFormatVersion_

Definition: RootFile.h:181

bool edm::RootFile::fillEventAuxiliary ( IndexIntoFile::EntryNumber_t entry )

private

Definition at line 1161 of file RootFile.cc.

References edm::RootTree::current(), eventTree_, fillThisEventAuxiliary(), and edm::RootTree::setEntryNumber().

Referenced by getNextItemType(), isDuplicateEvent(), readEvent(), readLuminosityBlockAuxiliary_(), readRunAuxiliary_(), setEntryAtNextEventInLumi(), skipEvents(), and skipThisEntry().

                                                                {
     if(!eventTree_.current(entry)) {
       return false;
     }
     eventTree_.setEntryNumber(entry);
     fillThisEventAuxiliary();
     return true;
   }

void edm::RootFile::fillEventHistory ( )

private

Definition at line 1171 of file RootFile.cc.

References branchIDListHelper_, branchListIndexes_, edm::poolNames::branchListIndexesBranchName(), daqProvenanceHelper_, edm::RootTree::entryNumber(), event(), eventAux(), eventAux_, edm::errors::EventCorruption, edm::poolNames::eventHistoryBranchName(), edm::FileFormatVersion::eventHistoryTree(), eventHistoryTree_, eventProcessHistoryIDs_, eventProcessHistoryIter_, eventSelectionIDs_, edm::poolNames::eventSelectionsBranchName(), eventTree_, edm::hlt::Exception, fileFormatVersion(), edm::RootTree::fillBranchEntry(), edm::roottree::getEntry(), history_, edm::lower_bound_all(), edm::FileFormatVersion::noMetaDataTrees(), edm::EventAuxiliary::processHistoryID(), provenanceAdaptor_, DTTTrigCorrFirst::run, edm::EventAuxiliary::setProcessHistoryID(), edm::FileFormatVersion::splitProductIDs(), filterCSVwithJSON::target, and edm::RootTree::tree().

Referenced by fillIndexIntoFile(), readCurrentEvent(), and readRunAuxiliary_().

                              {
     // 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.
 
     if(fileFormatVersion().eventHistoryBranch()) {
       // Lumi block number was not in EventID for the relevant releases.
       EventID id(eventAux().id().run(), 0, eventAux().id().event());
       if(eventProcessHistoryIter_->eventID() != id) {
         EventProcessHistoryID target(id, ProcessHistoryID());
         eventProcessHistoryIter_ = lower_bound_all(eventProcessHistoryIDs_, target);
         assert(eventProcessHistoryIter_->eventID() == id);
       }
       eventAux_.setProcessHistoryID(eventProcessHistoryIter_->processHistoryID());
       ++eventProcessHistoryIter_;
     } else if(fileFormatVersion().eventHistoryTree()) {
       // for backward compatibility.
       History* pHistory = history_.get();
       TBranch* eventHistoryBranch = eventHistoryTree_->GetBranch(poolNames::eventHistoryBranchName().c_str());
       if(!eventHistoryBranch) {
         throw Exception(errors::EventCorruption)
           << "Failed to find history branch in event history tree.\n";
       }
       eventHistoryBranch->SetAddress(&pHistory);
       roottree::getEntry(eventHistoryTree_, eventTree_.entryNumber());
       eventAux_.setProcessHistoryID(history_->processHistoryID());
       eventSelectionIDs_.swap(history_->eventSelectionIDs());
       branchListIndexes_.swap(history_->branchListIndexes());
     } else if(fileFormatVersion().noMetaDataTrees()) {
       // Current format
       EventSelectionIDVector* pESV = &eventSelectionIDs_;
       TBranch* eventSelectionIDBranch = eventTree_.tree()->GetBranch(poolNames::eventSelectionsBranchName().c_str());
       assert(eventSelectionIDBranch != nullptr);
       eventTree_.fillBranchEntry(eventSelectionIDBranch, pESV);
       BranchListIndexes* pBLI = &branchListIndexes_;
       TBranch* branchListIndexesBranch = eventTree_.tree()->GetBranch(poolNames::branchListIndexesBranchName().c_str());
       assert(branchListIndexesBranch != nullptr);
       eventTree_.fillBranchEntry(branchListIndexesBranch, pBLI);
     }
     if(provenanceAdaptor_) {
       eventAux_.setProcessHistoryID(provenanceAdaptor_->convertID(eventAux().processHistoryID()));
       for(auto& esID : eventSelectionIDs_) {
         esID = provenanceAdaptor_->convertID(esID);
       }
     }
     if(daqProvenanceHelper_) {
       eventAux_.setProcessHistoryID(daqProvenanceHelper_->mapProcessHistoryID(eventAux_.processHistoryID()));
     }
     if(!fileFormatVersion().splitProductIDs()) {
       // old format.  branchListIndexes_ must be filled in from the ProvenanceAdaptor.
       provenanceAdaptor_->branchListIndexes(branchListIndexes_);
     }
     branchIDListHelper_->fixBranchListIndexes(branchListIndexes_);
   }

void edm::RootFile::fillIndexIntoFile ( )

private

Definition at line 843 of file RootFile.cc.

References edm::RootTree::entries(), python.tagInventory::entries, edm::RootTree::entryNumber(), event(), eventAux(), eventAux_, eventTree_, fileFormatVersion(), fillEventHistory(), fillLumiAuxiliary(), fillRunAuxiliary(), fillThisEventAuxiliary(), edm::find_in_all(), indexIntoFile_, edm::IndexIntoFile::invalidEntry, edm::RootTree::isValid(), lastEventEntryNumberRead_, summaryLumi::lcount, fjr2json::lumi, edm::EventAuxiliary::luminosityBlock(), edmLumisInFiles::lumis, lumiTree_, edm::RootTree::next(), processHistoryRegistry_, edm::ProcessHistoryRegistry::reducedProcessHistoryID(), DTTTrigCorrFirst::run, edm::EventAuxiliary::run(), gather_cfg::runs, runTree_, edm::second(), edm::RootTree::setEntryNumber(), edm::IndexIntoFile::setProcessHistoryIDs(), edm::IndexIntoFile::setRunOrLumiEntries(), edm::stable_sort_all(), and edm::IndexIntoFile::unsortedEventNumbers().

Referenced by validateFile().

                               {
     // This function is for backward compatibility.
     // If reading a current format file, indexIntoFile_ is read from the input
     // file and should always be there. Note that the algorithm below will work
     // sometimes but often fail with the new format introduced in release 3_8_0.
     // If it ever becomes necessary to rebuild IndexIntoFile from the new format,
     // probably a separate function should be written to deal with the task.
     // This is possible just not implemented yet.
     assert(!fileFormatVersion().hasIndexIntoFile());
 
     typedef std::list<LumiItem> LumiList;
     LumiList lumis; // (declare 1)
 
     typedef std::set<LuminosityBlockID> RunLumiSet;
     RunLumiSet runLumiSet; // (declare 2)
 
     typedef std::list<RunItem> RunList;
     RunList runs; // (declare 5)
 
     typedef std::set<RunNumber_t> RunSet;
     RunSet runSet; // (declare 4)
 
     typedef std::set<RunItem, RunItemSortByRunPhid> RunItemSet;
     RunItemSet runItemSet; // (declare 3)
 
     typedef std::map<RunNumber_t, ProcessHistoryID> PHIDMap;
     PHIDMap phidMap;
 
     RunNumber_t prevRun = 0;
     LuminosityBlockNumber_t prevLumi = 0;
     ProcessHistoryID prevPhid;
     bool iFirst = true;
 
     indexIntoFile_.unsortedEventNumbers().clear(); // should already be empty, just being careful
     indexIntoFile_.unsortedEventNumbers().reserve(eventTree_.entries());
 
     // First, loop through the event tree.
     while(eventTree_.next()) {
       bool newRun = false;
       bool newLumi = false;
       fillThisEventAuxiliary();
       fillEventHistory();
 
       // Save the event numbers as we loop through the event auxiliary to avoid
       // having to read through the event auxiliary again later. These event numbers
       // are not actually used in this function, but could be needed elsewhere.
       indexIntoFile_.unsortedEventNumbers().push_back(eventAux().event());
 
       ProcessHistoryID reducedPHID = processHistoryRegistry_->reducedProcessHistoryID(eventAux().processHistoryID());
 
       if(iFirst || prevPhid != reducedPHID || prevRun != eventAux().run()) {
         iFirst = false;
         newRun = newLumi = true;
       } else if(prevLumi != eventAux().luminosityBlock()) {
         newLumi = true;
       }
       prevPhid = reducedPHID;
       prevRun = eventAux().run();
       prevLumi = eventAux().luminosityBlock();
       if(newLumi) {
         lumis.emplace_back(reducedPHID,
           eventAux().run(), eventAux().luminosityBlock(), eventTree_.entryNumber()); // (insert 1)
         runLumiSet.insert(LuminosityBlockID(eventAux().run(), eventAux().luminosityBlock())); // (insert 2)
       } else {
         LumiItem& currentLumi = lumis.back();
         assert(currentLumi.lastEventEntry_ == eventTree_.entryNumber());
         ++currentLumi.lastEventEntry_;
       }
       if(newRun) {
         // Insert run in list if it is not already there.
         RunItem item(reducedPHID, eventAux().run());
         if(runItemSet.insert(item).second) { // (check 3, insert 3)
           runs.push_back(std::move(item)); // (insert 5)
           runSet.insert(eventAux().run()); // (insert 4)
           phidMap.insert(std::make_pair(eventAux().run(), reducedPHID));
         }
       }
     }
     // now clean up.
     eventTree_.setEntryNumber(IndexIntoFile::invalidEntry);
     eventAux_ = EventAuxiliary();
     lastEventEntryNumberRead_ = IndexIntoFile::invalidEntry;
 
     // Loop over run entries and fill information.
 
     typedef std::map<RunNumber_t, IndexIntoFile::EntryNumber_t> RunMap;
     RunMap runMap; // (declare 11)
 
     typedef std::vector<RunItem> RunVector;
     RunVector emptyRuns; // (declare 12)
 
     if(runTree_.isValid()) {
       while(runTree_.next()) {
         // Note: adjacent duplicates will be skipped without an explicit check.
 
         boost::shared_ptr<RunAuxiliary> runAux = fillRunAuxiliary();
         ProcessHistoryID reducedPHID = processHistoryRegistry_->reducedProcessHistoryID(runAux->processHistoryID());
 
         if(runSet.insert(runAux->run()).second) { // (check 4, insert 4)
           // This run was not associated with any events.
           emptyRuns.emplace_back(reducedPHID, runAux->run()); // (insert 12)
         }
         runMap.insert(std::make_pair(runAux->run(), runTree_.entryNumber())); // (insert 11)
         phidMap.insert(std::make_pair(runAux->run(), reducedPHID));
       }
       // now clean up.
       runTree_.setEntryNumber(IndexIntoFile::invalidEntry);
     }
 
     // Insert the ordered empty runs into the run list.
     RunItemSortByRun runItemSortByRun;
     stable_sort_all(emptyRuns, runItemSortByRun);
 
     RunList::iterator itRuns = runs.begin(), endRuns = runs.end();
     for(auto const& emptyRun : emptyRuns) {
       for(; itRuns != endRuns; ++itRuns) {
         if(runItemSortByRun(emptyRun, *itRuns)) {
           break;
         }
       }
       runs.insert(itRuns, emptyRun);
     }
 
     // Loop over luminosity block entries and fill information.
 
     typedef std::vector<LumiItem> LumiVector;
     LumiVector emptyLumis; // (declare 7)
 
     typedef std::map<LuminosityBlockID, IndexIntoFile::EntryNumber_t> RunLumiMap;
     RunLumiMap runLumiMap; // (declare 6)
 
     if(lumiTree_.isValid()) {
       while(lumiTree_.next()) {
         // Note: adjacent duplicates will be skipped without an explicit check.
         boost::shared_ptr<LuminosityBlockAuxiliary> lumiAux = fillLumiAuxiliary();
         LuminosityBlockID lumiID = LuminosityBlockID(lumiAux->run(), lumiAux->luminosityBlock());
         if(runLumiSet.insert(lumiID).second) { // (check 2, insert 2)
           // This lumi was not associated with any events.
           // Use the process history ID from the corresponding run.  In cases of practical
           // importance, this should be the correct process history ID,  but it is possible
           // to construct files where this is not the correct process history ID ...
           PHIDMap::const_iterator iPhidMap = phidMap.find(lumiAux->run());
           assert(iPhidMap != phidMap.end());
           emptyLumis.emplace_back(iPhidMap->second, lumiAux->run(), lumiAux->luminosityBlock(), IndexIntoFile::invalidEntry); // (insert 7)
         }
         runLumiMap.insert(std::make_pair(lumiID, lumiTree_.entryNumber()));
       }
       // now clean up.
       lumiTree_.setEntryNumber(IndexIntoFile::invalidEntry);
     }
 
     // Insert the ordered empty lumis into the lumi list.
     LumiItemSortByRunLumi lumiItemSortByRunLumi;
     stable_sort_all(emptyLumis, lumiItemSortByRunLumi);
 
     LumiList::iterator itLumis = lumis.begin(), endLumis = lumis.end();
     for(auto const& emptyLumi : emptyLumis) {
       for(; itLumis != endLumis; ++itLumis) {
         if(lumiItemSortByRunLumi(emptyLumi, *itLumis)) {
           break;
         }
       }
       lumis.insert(itLumis, emptyLumi);
     }
 
     // Create a map of RunItems that gives the order of first appearance in the list.
     // Also fill in the vector of process history IDs
     typedef std::map<RunItem, int, RunItemSortByRunPhid> RunCountMap;
     RunCountMap runCountMap; // Declare (17)
     std::vector<ProcessHistoryID>& phids = indexIntoFile_.setProcessHistoryIDs();
     assert(phids.empty());
     std::vector<IndexIntoFile::RunOrLumiEntry>& entries = indexIntoFile_.setRunOrLumiEntries();
     assert(entries.empty());
     int rcount = 0;
     for(auto& run : runs) {
       RunCountMap::const_iterator countMapItem = runCountMap.find(run);
       if(countMapItem == runCountMap.end()) {
         countMapItem = runCountMap.insert(std::make_pair(run, rcount)).first; // Insert (17)
         assert(countMapItem != runCountMap.end());
         ++rcount;
       }
       std::vector<ProcessHistoryID>::const_iterator phidItem = find_in_all(phids, run.phid_);
       if(phidItem == phids.end()) {
         phids.push_back(run.phid_);
         phidItem = phids.end() - 1;
       }
       entries.emplace_back(
         countMapItem->second, // use (17)
         IndexIntoFile::invalidEntry,
         runMap[run.run_], // use (11)
         phidItem - phids.begin(),
         run.run_,
         0U,
         IndexIntoFile::invalidEntry,
         IndexIntoFile::invalidEntry);
     }
 
     // Create a map of LumiItems that gives the order of first appearance in the list.
     typedef std::map<LumiItem, int, LumiItemSortByRunLumiPhid> LumiCountMap;
     LumiCountMap lumiCountMap; // Declare (19)
     int lcount = 0;
     for(auto& lumi : lumis) {
       RunCountMap::const_iterator runCountMapItem = runCountMap.find(RunItem(lumi.phid_, lumi.run_));
       assert(runCountMapItem != runCountMap.end());
       LumiCountMap::const_iterator countMapItem = lumiCountMap.find(lumi);
       if(countMapItem == lumiCountMap.end()) {
         countMapItem = lumiCountMap.insert(std::make_pair(lumi, lcount)).first; // Insert (17)
         assert(countMapItem != lumiCountMap.end());
         ++lcount;
       }
       std::vector<ProcessHistoryID>::const_iterator phidItem = find_in_all(phids, lumi.phid_);
       assert(phidItem != phids.end());
       entries.emplace_back(
         runCountMapItem->second,
         countMapItem->second,
         runLumiMap[LuminosityBlockID(lumi.run_, lumi.lumi_)],
         phidItem - phids.begin(),
         lumi.run_,
         lumi.lumi_,
         lumi.firstEventEntry_,
         lumi.lastEventEntry_);
     }
     stable_sort_all(entries);
   }

boost::shared_ptr< LuminosityBlockAuxiliary > edm::RootFile::fillLumiAuxiliary ( )

private

Definition at line 1227 of file RootFile.cc.

References edm::conversion(), daqProvenanceHelper_, fileFormatVersion(), edm::RootTree::fillAux(), lumiTree_, provenanceAdaptor_, and edm::FileFormatVersion::runsAndLumis().

Referenced by fillIndexIntoFile(), and readLuminosityBlockAuxiliary_().

                               {
     boost::shared_ptr<LuminosityBlockAuxiliary> lumiAuxiliary(new LuminosityBlockAuxiliary);
     if(fileFormatVersion().newAuxiliary()) {
       LuminosityBlockAuxiliary *pLumiAux = lumiAuxiliary.get();
       lumiTree_.fillAux<LuminosityBlockAuxiliary>(pLumiAux);
     } else {
       LuminosityBlockAux lumiAux;
       LuminosityBlockAux *pLumiAux = &lumiAux;
       lumiTree_.fillAux<LuminosityBlockAux>(pLumiAux);
       conversion(lumiAux, *lumiAuxiliary);
     }
     if(provenanceAdaptor_) {
       lumiAuxiliary->setProcessHistoryID(provenanceAdaptor_->convertID(lumiAuxiliary->processHistoryID()));
     }
     if(daqProvenanceHelper_) {
       lumiAuxiliary->setProcessHistoryID(daqProvenanceHelper_->mapProcessHistoryID(lumiAuxiliary->processHistoryID()));
     }
     if(lumiAuxiliary->luminosityBlock() == 0 && !fileFormatVersion().runsAndLumis()) {
       lumiAuxiliary->id() = LuminosityBlockID(RunNumber_t(1), LuminosityBlockNumber_t(1));
     }
     return lumiAuxiliary;
   }

boost::shared_ptr< RunAuxiliary > edm::RootFile::fillRunAuxiliary ( )

private

Definition at line 1251 of file RootFile.cc.

References edm::conversion(), daqProvenanceHelper_, fileFormatVersion(), edm::RootTree::fillAux(), provenanceAdaptor_, and runTree_.

Referenced by fillIndexIntoFile(), and readRunAuxiliary_().

                              {
     boost::shared_ptr<RunAuxiliary> runAuxiliary(new RunAuxiliary);
     if(fileFormatVersion().newAuxiliary()) {
       RunAuxiliary *pRunAux = runAuxiliary.get();
       runTree_.fillAux<RunAuxiliary>(pRunAux);
     } else {
       RunAux runAux;
       RunAux *pRunAux = &runAux;
       runTree_.fillAux<RunAux>(pRunAux);
       conversion(runAux, *runAuxiliary);
     }
     if(provenanceAdaptor_) {
       runAuxiliary->setProcessHistoryID(provenanceAdaptor_->convertID(runAuxiliary->processHistoryID()));
     }
     if(daqProvenanceHelper_) {
       runAuxiliary->setProcessHistoryID(daqProvenanceHelper_->mapProcessHistoryID(runAuxiliary->processHistoryID()));
     }
     return runAuxiliary;
   }

void edm::RootFile::fillThisEventAuxiliary ( )

private

Definition at line 1142 of file RootFile.cc.

References edm::conversion(), edm::RootTree::entryNumber(), eventAux(), eventAux_, eventTree_, fileFormatVersion(), edm::RootTree::fillAux(), lastEventEntryNumberRead_, and edm::FileFormatVersion::newAuxiliary().

Referenced by fillEventAuxiliary(), fillIndexIntoFile(), initializeDuplicateChecker(), and readCurrentEvent().

                                    {
     if(lastEventEntryNumberRead_ == eventTree_.entryNumber()) {
       // Already read.
       return;
     }
     if(fileFormatVersion().newAuxiliary()) {
       EventAuxiliary *pEvAux = &eventAux_;
       eventTree_.fillAux<EventAuxiliary>(pEvAux);
     } else {
       // for backward compatibility.
       EventAux eventAux;
       EventAux *pEvAux = &eventAux;
       eventTree_.fillAux<EventAux>(pEvAux);
       conversion(eventAux, eventAux_);
     }
     lastEventEntryNumberRead_ = eventTree_.entryNumber();
   }

IndexIntoFile::EntryType edm::RootFile::getNextItemType	(	RunNumber_t &	run,
		LuminosityBlockNumber_t &	lumi,
		EventNumber_t &	event
	)

Definition at line 729 of file RootFile.cc.

                                                                                                  {
     // First, account for consecutive skipped entries.
     while(skipThisEntry()) {
       if(indexIntoFileIter_.getEntryType() == IndexIntoFile::kRun) {
         indexIntoFileIter_.advanceToNextRun();
       }
       else if(indexIntoFileIter_.getEntryType() == IndexIntoFile::kLumi) {
         indexIntoFileIter_.advanceToNextLumiOrRun();
       }
       else {
         ++indexIntoFileIter_;
       }
     }
     // OK, we have an entry that is not skipped.
     IndexIntoFile::EntryType entryType = indexIntoFileIter_.getEntryType();
     if(entryType == IndexIntoFile::kEnd) {
       return IndexIntoFile::kEnd;
     }
     if(entryType == IndexIntoFile::kRun) {
       run = indexIntoFileIter_.run();
       return IndexIntoFile::kRun;
     } else if(processingMode_ == InputSource::Runs) {
       indexIntoFileIter_.advanceToNextRun();
       return getNextItemType(run, lumi, event);
     }
     if(entryType == IndexIntoFile::kLumi) {
       run = indexIntoFileIter_.run();
       lumi = indexIntoFileIter_.lumi();
       return IndexIntoFile::kLumi;
     } else if(processingMode_ == InputSource::RunsAndLumis) {
       indexIntoFileIter_.advanceToNextLumiOrRun();
       return getNextItemType(run, lumi, event);
     }
     if(isDuplicateEvent()) {
       ++indexIntoFileIter_;
       return getNextItemType(run, lumi, event);
     }
     run = indexIntoFileIter_.run();
     lumi = indexIntoFileIter_.lumi();
     fillEventAuxiliary(indexIntoFileIter_.entry());
     event = eventAux_.event();
     return IndexIntoFile::kEvent;
   }

bool edm::RootFile::goToEvent ( EventID const & eventID )

Definition at line 1340 of file RootFile.cc.

References duplicateChecker_, edm::IndexIntoFile::end(), edm::EventID::event(), edm::IndexIntoFile::fillEventNumbers(), edm::IndexIntoFile::findPosition(), edm::IndexIntoFile::firstAppearanceOrder, indexIntoFile_, indexIntoFileIter_, getDQMSummary::iter, edm::EventID::luminosityBlock(), noEventSort_, edm::IndexIntoFile::numericalOrder, and edm::EventID::run().

                                             {
 
     indexIntoFile_.fillEventNumbers();
 
     if(duplicateChecker_) {
       duplicateChecker_->disable();
     }
 
     IndexIntoFile::SortOrder sortOrder = IndexIntoFile::numericalOrder;
     if(noEventSort_) sortOrder = IndexIntoFile::firstAppearanceOrder;
 
     IndexIntoFile::IndexIntoFileItr iter =
       indexIntoFile_.findPosition(sortOrder, eventID.run(), eventID.luminosityBlock(), eventID.event());
 
     if(iter == indexIntoFile_.end(sortOrder)) {
       return false;
     }
     indexIntoFileIter_ = iter;
     return true;
   }

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

inline

Definition at line 112 of file RootFile.h.

References hasNewlyDroppedBranch_.

Referenced by createFileBlock().

112 {return hasNewlyDroppedBranch_;}

edm::RootFile::hasNewlyDroppedBranch_

std::array< bool, NumBranchTypes > hasNewlyDroppedBranch_

Definition: RootFile.h:195

IndexIntoFile::IndexIntoFileItr edm::RootFile::indexIntoFileIter ( ) const

Definition at line 659 of file RootFile.cc.

References indexIntoFileIter_.

                                     {
     return indexIntoFileIter_;
   }

boost::shared_ptr<IndexIntoFile> edm::RootFile::indexIntoFileSharedPtr ( ) const

inline

Definition at line 140 of file RootFile.h.

References indexIntoFileSharedPtr_.

                                                                   {
       return indexIntoFileSharedPtr_;
     }

void edm::RootFile::initializeDuplicateChecker	(	std::vector< boost::shared_ptr< IndexIntoFile > > const &	indexesIntoFiles,
		std::vector< boost::shared_ptr< IndexIntoFile > >::size_type	currentIndexIntoFile
	)

private

Definition at line 1648 of file RootFile.cc.

References duplicateChecker_, eventAux(), eventTree_, fillThisEventAuxiliary(), indexIntoFile_, edm::IndexIntoFile::invalidEntry, edm::RootTree::next(), and edm::RootTree::setEntryNumber().

Referenced by RootFile().

                                                                               {
     if(duplicateChecker_) {
       if(eventTree_.next()) {
         fillThisEventAuxiliary();
         duplicateChecker_->inputFileOpened(eventAux().isRealData(),
                                            indexIntoFile_,
                                            indexesIntoFiles,
                                            currentIndexIntoFile);
       }
       eventTree_.setEntryNumber(IndexIntoFile::invalidEntry);
     }
   }

bool edm::RootFile::isDuplicateEvent ( )

private

Definition at line 713 of file RootFile.cc.

References duplicateChecker_, edm::IndexIntoFile::IndexIntoFileItr::entry(), edm::EventID::event(), eventAux_, file_, fillEventAuxiliary(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), edm::EventAuxiliary::id(), indexIntoFileIter_, edm::IndexIntoFile::kEvent, edm::IndexIntoFile::IndexIntoFileItr::lumi(), edm::IndexIntoFile::IndexIntoFileItr::processHistoryIDIndex(), and edm::IndexIntoFile::IndexIntoFileItr::run().

Referenced by getNextItemType().

                              {
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kEvent);
     if(duplicateChecker_.get() == nullptr) {
       return false;
     }
     fillEventAuxiliary(indexIntoFileIter_.entry());
     return duplicateChecker_->isDuplicateAndCheckActive(indexIntoFileIter_.processHistoryIDIndex(),
         indexIntoFileIter_.run(), indexIntoFileIter_.lumi(), eventAux_.id().event(), file_);
   }

RootTree const& edm::RootFile::lumiTree ( ) const

inline

Definition at line 108 of file RootFile.h.

References lumiTree_.

108 {return lumiTree_;}

edm::RootFile::lumiTree_

RootTree lumiTree_

Definition: RootFile.h:199

boost::shared_ptr< ProductProvenanceRetriever > edm::RootFile::makeProductProvenanceRetriever ( unsigned int iStreamIndex )

private

Definition at line 1745 of file RootFile.cc.

References daqProvenanceHelper_, eventProductProvenanceRetrievers_, eventTree_, and provenanceReaderMaker_.

Referenced by readCurrentEvent().

                                                                  {
     if(eventProductProvenanceRetrievers_.size()<=iStreamID) {
       eventProductProvenanceRetrievers_.resize(iStreamID+1);
     }
     if(!eventProductProvenanceRetrievers_[iStreamID]) {
       eventProductProvenanceRetrievers_[iStreamID].reset(new ProductProvenanceRetriever(provenanceReaderMaker_->makeReader(eventTree_, daqProvenanceHelper_.get())));
     }
     eventProductProvenanceRetrievers_[iStreamID]->reset();
     return eventProductProvenanceRetrievers_[iStreamID];
   }

std::unique_ptr< MakeProvenanceReader > edm::RootFile::makeProvenanceReaderMaker ( InputType inputType )

private

Definition at line 1728 of file RootFile.cc.

References fileFormatVersion_, parentageIDLookup_, edm::FileFormatVersion::perEventProductIDs(), readEntryDescriptionTree(), readParentageTree(), edm::FileFormatVersion::splitProductIDs(), and edm::FileFormatVersion::storedProductProvenanceUsed().

Referenced by RootFile().

                                                          {
     if(fileFormatVersion_.storedProductProvenanceUsed()) {
       readParentageTree(inputType);
       return std::unique_ptr<MakeProvenanceReader>(new MakeReducedProvenanceReader(parentageIDLookup_));
     } else if(fileFormatVersion_.splitProductIDs()) {
       readParentageTree(inputType);
       return std::unique_ptr<MakeProvenanceReader>(new MakeFullProvenanceReader);
     } else if(fileFormatVersion_.perEventProductIDs()) {
       std::unique_ptr<EntryDescriptionMap> entryDescriptionMap(new EntryDescriptionMap);
       readEntryDescriptionTree(*entryDescriptionMap, inputType);
       return std::unique_ptr<MakeProvenanceReader>(new MakeOldProvenanceReader(std::move(entryDescriptionMap)));
     } else {
       return std::unique_ptr<MakeProvenanceReader>(new MakeDummyProvenanceReader);
     }
   }

bool edm::RootFile::modifiedIDs ( ) const

inline

Definition at line 114 of file RootFile.h.

References daqProvenanceHelper_.

Referenced by createFileBlock().

114 {return daqProvenanceHelper_.get() != 0;}

edm::RootFile::daqProvenanceHelper_

std::unique_ptr< DaqProvenanceHelper > daqProvenanceHelper_

Definition: RootFile.h:219

std::string const & edm::RootFile::newBranchToOldBranch ( std::string const & newBranch ) const

private

Definition at line 650 of file RootFile.cc.

References newBranchToOldBranch_.

Referenced by dropOnInput(), and RootFile().

                                                                  {
     std::map<std::string, std::string>::const_iterator it = newBranchToOldBranch_.find(newBranch);
     if(it != newBranchToOldBranch_.end()) {
       return it->second;
     }
     return newBranch;
   }

bool edm::RootFile::nextEventEntry ( )

inline

Definition at line 138 of file RootFile.h.

References eventTree_, and edm::RootTree::next().

138 {return eventTree_.next();}

edm::RootTree::next

bool next()

Definition: RootTree.h:85

edm::RootFile::eventTree_

RootTree eventTree_

Definition: RootFile.h:198

RootFile& edm::RootFile::operator= ( RootFile const & )

delete

void edm::RootFile::overrideRunNumber ( RunID & id )

private

Definition at line 1604 of file RootFile.cc.

References edm::RunID::firstValidRun(), forcedRunOffset_, and DTTTrigCorrFirst::run.

Referenced by readCurrentEvent(), readLuminosityBlockAuxiliary_(), and readRunAuxiliary_().

                                        {
     if(forcedRunOffset_ != 0) {
       id = RunID(id.run() + forcedRunOffset_);
     }
     if(id < RunID::firstValidRun()) id = RunID::firstValidRun();
   }

void edm::RootFile::overrideRunNumber ( LuminosityBlockID & id )

private

Definition at line 1612 of file RootFile.cc.

References edm::RunID::firstValidRun(), forcedRunOffset_, and DTTTrigCorrFirst::run.

                                                    {
     if(forcedRunOffset_ != 0) {
       id = LuminosityBlockID(id.run() + forcedRunOffset_, id.luminosityBlock());
     }
     if(RunID(id.run()) < RunID::firstValidRun()) id = LuminosityBlockID(RunID::firstValidRun().run(), id.luminosityBlock());
   }

void edm::RootFile::overrideRunNumber	(	EventID &	id,
		bool	isRealData
	)

private

Definition at line 1620 of file RootFile.cc.

References edm::errors::Configuration, event(), edm::hlt::Exception, edm::LuminosityBlockID::firstValidLuminosityBlock(), edm::RunID::firstValidRun(), forcedRunOffset_, and DTTTrigCorrFirst::run.

                                                           {
     if(forcedRunOffset_ != 0) {
       if(isRealData) {
         throw Exception(errors::Configuration, "RootFile::RootFile()")
           << "The 'setRunNumber' parameter of PoolSource cannot be used with real data.\n";
       }
       id = EventID(id.run() + forcedRunOffset_, id.luminosityBlock(), id.event());
     }
     if(RunID(id.run()) < RunID::firstValidRun()) {
       id = EventID(RunID::firstValidRun().run(), LuminosityBlockID::firstValidLuminosityBlock().luminosityBlock(), id.event());
     }
   }

boost::shared_ptr<ProductRegistry const> edm::RootFile::productRegistry ( ) const

inline

Definition at line 99 of file RootFile.h.

References productRegistry_.

Referenced by RootFile().

99 {return productRegistry_;}

edm::RootFile::productRegistry_

boost::shared_ptr< ProductRegistry const > productRegistry_

Definition: RootFile.h:203

bool edm::RootFile::readCurrentEvent ( EventPrincipal & cache )

Definition at line 1397 of file RootFile.cc.

References branchListIndexes_, edm::RootTree::current(), eventAux(), eventAux_, eventSelectionIDs_, eventTree_, fileFormatVersion(), filePtr_, fillEventHistory(), edm::EventPrincipal::fillEventPrincipal(), fillThisEventAuxiliary(), edm::EventAuxiliary::id(), edm::RootTree::insertEntryForIndex(), edm::EventAuxiliary::isRealData(), makeProductProvenanceRetriever(), edm::EventAuxiliary::oldLuminosityBlock(), overrideRunNumber(), processHistoryRegistry_, edm::EventAuxiliary::resetObsoleteInfo(), edm::RootTree::rootDelayedReader(), edm::EventPrincipal::streamID(), edm::EDProductGetter::transitionIndex(), and edm::StreamID::value().

Referenced by readEvent().

                                                       {
     if(!eventTree_.current()) {
       return false;
     }
     fillThisEventAuxiliary();
     if(!fileFormatVersion().lumiInEventID()) {
         //ugly, but will disappear when the backward compatibility is done with schema evolution.
         const_cast<EventID&>(eventAux_.id()).setLuminosityBlockNumber(eventAux_.oldLuminosityBlock());
         eventAux_.resetObsoleteInfo();
     }
     fillEventHistory();
     overrideRunNumber(eventAux_.id(), eventAux().isRealData());
 
     // We're not done ... so prepare the EventPrincipal
     eventTree_.insertEntryForIndex(principal.transitionIndex());
     principal.fillEventPrincipal(eventAux(),
                                  *processHistoryRegistry_,
                                  std::move(eventSelectionIDs_),
                                  std::move(branchListIndexes_),
                                  *(makeProductProvenanceRetriever(principal.streamID().value())),
                                  eventTree_.rootDelayedReader());
 
     // report event read from file
     filePtr_->eventReadFromFile();
     return true;
   }

void edm::RootFile::readEntryDescriptionTree	(	EntryDescriptionMap &	entryDescriptionMap,
		InputType	inputType
	)

private

Definition at line 497 of file RootFile.cc.

References daqProvenanceHelper_, edm::poolNames::entryDescriptionBranchName(), edm::poolNames::entryDescriptionIDBranchName(), edm::poolNames::entryDescriptionTreeName(), edm::errors::EventCorruption, edm::hlt::Exception, filePtr_, edm::errors::FileReadError, edm::roottree::getEntry(), i, edm::Parentage::id(), edm::EventEntryDescription::id(), edm::ParentageRegistry::insertMapped(), edm::ParentageRegistry::instance(), edm::numEntries(), parents, edm::EventEntryDescription::parents(), edm::Parentage::parentsForUpdate(), PhysicsTools::registry, edm::SecondarySource, and edm::Parentage::setParents().

Referenced by makeProvenanceReaderMaker().

                                                                                                   {
     // Called only for old format files.
     // We use a smart pointer so the tree will be deleted after use, and not kept for the life of the file.
     std::unique_ptr<TTree> entryDescriptionTree(dynamic_cast<TTree*>(filePtr_->Get(poolNames::entryDescriptionTreeName().c_str())));
     if(nullptr == entryDescriptionTree.get()) {
       throw Exception(errors::FileReadError) << "Could not find tree " << poolNames::entryDescriptionTreeName()
                                              << " in the input file.\n";
     }
 
     EntryDescriptionID idBuffer;
     EntryDescriptionID* pidBuffer = &idBuffer;
     entryDescriptionTree->SetBranchAddress(poolNames::entryDescriptionIDBranchName().c_str(), &pidBuffer);
 
     EventEntryDescription entryDescriptionBuffer;
     EventEntryDescription *pEntryDescriptionBuffer = &entryDescriptionBuffer;
     entryDescriptionTree->SetBranchAddress(poolNames::entryDescriptionBranchName().c_str(), &pEntryDescriptionBuffer);
 
     // Fill in the parentage registry.
     ParentageRegistry& registry = *ParentageRegistry::instance();
 
     for(Long64_t i = 0, numEntries = entryDescriptionTree->GetEntries(); i < numEntries; ++i) {
       roottree::getEntry(entryDescriptionTree.get(), i);
       if(idBuffer != entryDescriptionBuffer.id()) {
         throw Exception(errors::EventCorruption) << "Corruption of EntryDescription tree detected.\n";
       }
       entryDescriptionMap.insert(std::make_pair(entryDescriptionBuffer.id(),entryDescriptionBuffer));
       Parentage parents;
       parents.setParents(entryDescriptionBuffer.parents());
       if(daqProvenanceHelper_) {
         ParentageID const oldID = parents.id();
         daqProvenanceHelper_->fixMetaData(parents.parentsForUpdate());
         ParentageID newID = parents.id();
         if(newID != oldID) {
           daqProvenanceHelper_->setOldParentageIDToNew(oldID,newID);
         }
       }
       // For thread safety, don't update global registries when a secondary source opens a file.
       if(inputType != InputType::SecondarySource) {
         registry.insertMapped(parents);
       }
     }
     entryDescriptionTree->SetBranchAddress(poolNames::entryDescriptionIDBranchName().c_str(), nullptr);
     entryDescriptionTree->SetBranchAddress(poolNames::entryDescriptionBranchName().c_str(), nullptr);
   }

void edm::RootFile::readEvent ( EventPrincipal & cache )

Definition at line 1374 of file RootFile.cc.

References daqProvenanceHelper_, edm::IndexIntoFile::IndexIntoFileItr::entry(), eventAux(), fileFormatVersion(), fillEventAuxiliary(), forcedRunOffset_, edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFile_, indexIntoFileEnd_, indexIntoFileIter_, edm::IndexIntoFile::kEvent, edm::IndexIntoFile::IndexIntoFileItr::lumi(), edm::EventAuxiliary::processHistoryID(), edm::IndexIntoFile::processHistoryID(), edm::IndexIntoFile::IndexIntoFileItr::processHistoryIDIndex(), processHistoryRegistry_, readCurrentEvent(), edm::ProcessHistoryRegistry::reducedProcessHistoryID(), DTTTrigCorrFirst::run, edm::IndexIntoFile::IndexIntoFileItr::run(), and edm::FileFormatVersion::useReducedProcessHistoryID().

                                                {
     assert(indexIntoFileIter_ != indexIntoFileEnd_);
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kEvent);
     // read the event auxiliary if not alrady read.
     assert(fillEventAuxiliary(indexIntoFileIter_.entry()));
 
     // read the event
     readCurrentEvent(principal);
 
     assert(eventAux().run() == indexIntoFileIter_.run() + forcedRunOffset_);
     assert(eventAux().luminosityBlock() == indexIntoFileIter_.lumi());
 
     // If this next assert shows up in performance profiling or significantly affects memory, then these three lines should be deleted.
     // The IndexIntoFile should guarantee that it never fails.
     ProcessHistoryID idToCheck = (daqProvenanceHelper_ && fileFormatVersion().useReducedProcessHistoryID() ? *daqProvenanceHelper_->oldProcessHistoryID() : eventAux().processHistoryID());
     ProcessHistoryID const& reducedPHID = processHistoryRegistry_->reducedProcessHistoryID(idToCheck);
     assert(reducedPHID == indexIntoFile_.processHistoryID(indexIntoFileIter_.processHistoryIDIndex()));
 
     ++indexIntoFileIter_;
   }

void edm::RootFile::readEventHistoryTree ( )

private

Definition at line 1635 of file RootFile.cc.

References edm::errors::EventCorruption, eventHistoryTree_, edm::poolNames::eventHistoryTreeName(), edm::hlt::Exception, fileFormatVersion(), filePtr_, and history_.

Referenced by RootFile().

                                  {
     // Read in the event history tree, if we have one...
     if(fileFormatVersion().eventHistoryTree()) {
       history_.reset(new History);
       eventHistoryTree_ = dynamic_cast<TTree*>(filePtr_->Get(poolNames::eventHistoryTreeName().c_str()));
       if(!eventHistoryTree_) {
         throw Exception(errors::EventCorruption)
           << "Failed to find the event history tree.\n";
       }
     }
   }

void edm::RootFile::readLuminosityBlock_ ( LuminosityBlockPrincipal & lumiPrincipal )

Definition at line 1549 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::entry(), edm::LuminosityBlockPrincipal::fillLuminosityBlockPrincipal(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileEnd_, indexIntoFileIter_, edm::RootTree::insertEntryForIndex(), edm::RootTree::isValid(), edm::IndexIntoFile::kLumi, lumiTree_, processHistoryRegistry_, edm::LuminosityBlockPrincipal::readImmediate(), edm::RootTree::rootDelayedReader(), edm::RootTree::setEntryNumber(), and edm::EDProductGetter::transitionIndex().

                                                                         {
     assert(indexIntoFileIter_ != indexIntoFileEnd_);
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kLumi);
     // Begin code for backward compatibility before the existence of lumi trees.
     if(!lumiTree_.isValid()) {
       ++indexIntoFileIter_;
       return;
     }
     // End code for backward compatibility before the existence of lumi trees.
     lumiTree_.setEntryNumber(indexIntoFileIter_.entry());
     lumiTree_.insertEntryForIndex(lumiPrincipal.transitionIndex());
     lumiPrincipal.fillLuminosityBlockPrincipal(*processHistoryRegistry_, lumiTree_.rootDelayedReader());
     // Read in all the products now.
     lumiPrincipal.readImmediate();
     ++indexIntoFileIter_;
   }

boost::shared_ptr< LuminosityBlockAuxiliary > edm::RootFile::readLuminosityBlockAuxiliary_ ( )

Definition at line 1511 of file RootFile.cc.

References edm::RootTree::current(), edm::IndexIntoFile::IndexIntoFileItr::entry(), eventAux(), eventTree_, fileFormatVersion(), filePtr_, fillEventAuxiliary(), fillLumiAuxiliary(), edm::IndexIntoFile::IndexIntoFileItr::firstEventEntryThisLumi(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileEnd_, indexIntoFileIter_, edm::IndexIntoFile::invalidEntry, edm::Timestamp::invalidTimestamp(), edm::RootTree::isValid(), edm::IndexIntoFile::kLumi, fjr2json::lumi, edm::IndexIntoFile::IndexIntoFileItr::lumi(), edm::LuminosityBlockID::luminosityBlock(), lumiTree_, overrideRunNumber(), edm::LuminosityBlockID::run(), edm::IndexIntoFile::IndexIntoFileItr::run(), savedRunAuxiliary_, edm::RootTree::setEntryNumber(), cond::rpcobgas::time, and edm::EventAuxiliary::time().

                                           {
     assert(indexIntoFileIter_ != indexIntoFileEnd_);
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kLumi);
     // Begin code for backward compatibility before the existence of lumi trees.
     if(!lumiTree_.isValid()) {
       IndexIntoFile::EntryNumber_t eventEntry = indexIntoFileIter_.firstEventEntryThisLumi();
       assert(eventEntry != IndexIntoFile::invalidEntry);
       assert(eventTree_.current(eventEntry));
       fillEventAuxiliary(eventEntry);
 
       LuminosityBlockID lumi = LuminosityBlockID(indexIntoFileIter_.run(), indexIntoFileIter_.lumi());
       overrideRunNumber(lumi);
       return boost::shared_ptr<LuminosityBlockAuxiliary>(new LuminosityBlockAuxiliary(lumi.run(), lumi.luminosityBlock(), eventAux().time(), Timestamp::invalidTimestamp()));
     }
     // End code for backward compatibility before the existence of lumi trees.
     lumiTree_.setEntryNumber(indexIntoFileIter_.entry());
     boost::shared_ptr<LuminosityBlockAuxiliary> lumiAuxiliary = fillLumiAuxiliary();
     assert(lumiAuxiliary->run() == indexIntoFileIter_.run());
     assert(lumiAuxiliary->luminosityBlock() == indexIntoFileIter_.lumi());
     overrideRunNumber(lumiAuxiliary->id());
     filePtr_->reportInputLumiSection(lumiAuxiliary->run(), lumiAuxiliary->luminosityBlock());
     if(lumiAuxiliary->beginTime() == Timestamp::invalidTimestamp()) {
       IndexIntoFile::EntryNumber_t eventEntry = indexIntoFileIter_.firstEventEntryThisLumi();
       if(eventEntry != IndexIntoFile::invalidEntry) {
         assert(eventTree_.current(eventEntry));
         fillEventAuxiliary(eventEntry);
 
         lumiAuxiliary->setBeginTime(eventAux().time());
       }
       lumiAuxiliary->setEndTime(Timestamp::invalidTimestamp());
     }
     if(!fileFormatVersion().processHistorySameWithinRun() && savedRunAuxiliary_) {
       lumiAuxiliary->setProcessHistoryID(savedRunAuxiliary_->processHistoryID());
     }
     return lumiAuxiliary;
   }

void edm::RootFile::readParentageTree ( InputType inputType )

private

Definition at line 543 of file RootFile.cc.

References daqProvenanceHelper_, edm::hlt::Exception, filePtr_, edm::errors::FileReadError, edm::roottree::getEntry(), i, edm::Parentage::id(), edm::ParentageRegistry::insertMapped(), edm::ParentageRegistry::instance(), edm::numEntries(), edm::poolNames::parentageBranchName(), parentageIDLookup_, edm::poolNames::parentageTreeName(), parents, edm::Parentage::parentsForUpdate(), PhysicsTools::registry, and edm::SecondarySource.

Referenced by makeProvenanceReaderMaker().

                                                  {
     // New format file
     // We use a smart pointer so the tree will be deleted after use, and not kept for the life of the file.
     std::unique_ptr<TTree> parentageTree(dynamic_cast<TTree*>(filePtr_->Get(poolNames::parentageTreeName().c_str())));
     if(nullptr == parentageTree.get()) {
       throw Exception(errors::FileReadError) << "Could not find tree " << poolNames::parentageTreeName()
                                              << " in the input file.\n";
     }
 
     Parentage parents;
     Parentage *pParentageBuffer = &parents;
     parentageTree->SetBranchAddress(poolNames::parentageBranchName().c_str(), &pParentageBuffer);
 
     ParentageRegistry& registry = *ParentageRegistry::instance();
 
     parentageIDLookup_.reserve(parentageTree->GetEntries());
     for(Long64_t i = 0, numEntries = parentageTree->GetEntries(); i < numEntries; ++i) {
       roottree::getEntry(parentageTree.get(), i);
       if(daqProvenanceHelper_) {
         ParentageID const oldID = parents.id();
         daqProvenanceHelper_->fixMetaData(parents.parentsForUpdate());
         ParentageID newID = parents.id();
         if(newID != oldID) {
           daqProvenanceHelper_->setOldParentageIDToNew(oldID,newID);
         }
       }
       // For thread safety, don't update global registries when a secondary source opens a file.
       if(inputType != InputType::SecondarySource) {
         registry.insertMapped(parents);
       }
       parentageIDLookup_.push_back(parents.id());
     }
     parentageTree->SetBranchAddress(poolNames::parentageBranchName().c_str(), nullptr);
   }

void edm::RootFile::readRun_ ( RunPrincipal & runPrincipal )

Definition at line 1494 of file RootFile.cc.

References edm::RunPrincipal::fillRunPrincipal(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileEnd_, indexIntoFileIter_, edm::RootTree::insertEntryForIndex(), edm::RootTree::isValid(), edm::IndexIntoFile::kRun, processHistoryRegistry_, edm::RunPrincipal::readImmediate(), edm::RootTree::rootDelayedReader(), runTree_, and edm::EDProductGetter::transitionIndex().

                                                {
     assert(indexIntoFileIter_ != indexIntoFileEnd_);
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kRun);
     // Begin code for backward compatibility before the existence of run trees.
     if(!runTree_.isValid()) {
       ++indexIntoFileIter_;
       return;
     }
     // End code for backward compatibility before the existence of run trees.
     runTree_.insertEntryForIndex(runPrincipal.transitionIndex());
     runPrincipal.fillRunPrincipal(*processHistoryRegistry_, runTree_.rootDelayedReader());
     // Read in all the products now.
     runPrincipal.readImmediate();
     ++indexIntoFileIter_;
   }

boost::shared_ptr< RunAuxiliary > edm::RootFile::readRunAuxiliary_ ( )

Definition at line 1430 of file RootFile.cc.

References edm::RootTree::current(), edm::IndexIntoFile::IndexIntoFileItr::entry(), eventAux(), eventTree_, fileFormatVersion(), filePtr_, fillEventAuxiliary(), fillEventHistory(), fillRunAuxiliary(), edm::IndexIntoFile::IndexIntoFileItr::firstEventEntryThisRun(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileEnd_, indexIntoFileIter_, edm::IndexIntoFile::invalidEntry, edm::Timestamp::invalidTimestamp(), edm::RootTree::isValid(), edm::IndexIntoFile::kRun, overrideRunNumber(), edm::FileFormatVersion::processHistorySameWithinRun(), edm::RunID::run(), DTTTrigCorrFirst::run, edm::IndexIntoFile::IndexIntoFileItr::run(), runTree_, savedRunAuxiliary_, edm::RootTree::setEntryNumber(), cond::rpcobgas::time, and edm::EventAuxiliary::time().

                               {
     assert(indexIntoFileIter_ != indexIntoFileEnd_);
     assert(indexIntoFileIter_.getEntryType() == IndexIntoFile::kRun);
 
     // Begin code for backward compatibility before the existence of run trees.
     if(!runTree_.isValid()) {
 
       // prior to the support of run trees.
       // RunAuxiliary did not contain a valid timestamp.  Take it from the next event.
       IndexIntoFile::EntryNumber_t eventEntry = indexIntoFileIter_.firstEventEntryThisRun();
       assert(eventEntry != IndexIntoFile::invalidEntry);
       assert(eventTree_.current(eventEntry));
       fillEventAuxiliary(eventEntry);
 
       RunID run = RunID(indexIntoFileIter_.run());
       overrideRunNumber(run);
       return boost::shared_ptr<RunAuxiliary>(new RunAuxiliary(run.run(), eventAux().time(), Timestamp::invalidTimestamp()));
     }
     // End code for backward compatibility before the existence of run trees.
     runTree_.setEntryNumber(indexIntoFileIter_.entry());
     boost::shared_ptr<RunAuxiliary> runAuxiliary = fillRunAuxiliary();
     assert(runAuxiliary->run() == indexIntoFileIter_.run());
     overrideRunNumber(runAuxiliary->id());
     filePtr_->reportInputRunNumber(runAuxiliary->run());
     // If RunAuxiliary did not contain a valid begin timestamp, invalidate any end timestamp.
     if(runAuxiliary->beginTime() == Timestamp::invalidTimestamp()) {
       runAuxiliary->setEndTime(Timestamp::invalidTimestamp());
     }
 
     // If RunAuxiliary did not contain a valid timestamp, or if this an old format file from
     // when the Run's ProcessHistory included only processes where products were added to the Run itself,
     // we attempt to read the first event in the run to get appropriate info.
     if(runAuxiliary->beginTime() == Timestamp::invalidTimestamp() ||
        !fileFormatVersion().processHistorySameWithinRun()) {
 
       IndexIntoFile::EntryNumber_t eventEntry = indexIntoFileIter_.firstEventEntryThisRun();
       // If we have a valid event, use its information.
       if(eventEntry != IndexIntoFile::invalidEntry) {
         assert(eventTree_.current(eventEntry));
         fillEventAuxiliary(eventEntry);
 
         // RunAuxiliary did not contain a valid timestamp.  Take it from the next event in this run if there is one.
         if(runAuxiliary->beginTime() == Timestamp::invalidTimestamp()) {
           runAuxiliary->setBeginTime(eventAux().time());
         }
 
         // For backwards compatibility when the Run's ProcessHistory included only processes where products were added to the
         // Run, and then the Run and Event auxiliaries could be different.  Use the event ProcessHistoryID if there is one. It should
         // almost always be correct by the current definition (processes included if any products are added. This makes the run, lumi,
         // and event ProcessHistory's always be the same if no file merging occurs).
         if(!fileFormatVersion().processHistorySameWithinRun()) {
           fillEventHistory();
           runAuxiliary->setProcessHistoryID(eventAux().processHistoryID());
           savedRunAuxiliary_ = runAuxiliary;
         }
       } else {
         // No valid event, just use what is there, because it is the best we can do.
         savedRunAuxiliary_ = runAuxiliary;
       }
     }
     return runAuxiliary;
   }

void edm::RootFile::reportOpened ( std::string const & inputType )

Definition at line 1116 of file RootFile.cc.

References edm::RootTree::branchNames(), eventTree_, edm::FileID::fid(), fid_, filePtr_, diffTwoXMLs::label, logicalFile_, edm::moduleName(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                    {
     // Report file opened.
     std::string const label = "source";
     std::string moduleName = "PoolSource";
     filePtr_->inputFileOpened(
               logicalFile_,
               inputType,
               moduleName,
               label,
               fid_.fid(),
               eventTree_.branchNames());
   }

void edm::RootFile::rewind ( )

inline

Definition at line 126 of file RootFile.h.

References eventTree_, indexIntoFileBegin_, indexIntoFileIter_, lumiTree_, edm::RootTree::rewind(), and runTree_.

                   {
       indexIntoFileIter_ = indexIntoFileBegin_;
       eventTree_.rewind();
       lumiTree_.rewind();
       runTree_.rewind();
     }

RootTree const& edm::RootFile::runTree ( ) const

inline

Definition at line 109 of file RootFile.h.

References runTree_.

Referenced by validateFile().

109 {return runTree_;}

edm::RootFile::runTree_

RootTree runTree_

Definition: RootFile.h:200

void edm::RootFile::setAtEventEntry ( IndexIntoFile::EntryNumber_t entry )

Definition at line 1425 of file RootFile.cc.

References eventTree_, and edm::RootTree::setEntryNumber().

                                                             {
     eventTree_.setEntryNumber(entry);
   }

bool edm::RootFile::setEntryAtEvent	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event
	)

Definition at line 1567 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::entry(), eventTree_, edm::IndexIntoFile::findEventPosition(), indexIntoFile_, indexIntoFileEnd_, indexIntoFileIter_, and edm::RootTree::setEntryNumber().

Referenced by setEntryAtItem().

                                                                                               {
     indexIntoFileIter_ = indexIntoFile_.findEventPosition(run, lumi, event);
     if(indexIntoFileIter_ == indexIntoFileEnd_) return false;
     eventTree_.setEntryNumber(indexIntoFileIter_.entry());
     return true;
   }

bool edm::RootFile::setEntryAtItem	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event
	)

inline

Definition at line 116 of file RootFile.h.

References setEntryAtEvent(), setEntryAtLumi(), and setEntryAtRun().

                                                                                             {
       return event ? setEntryAtEvent(run, lumi, event) : (lumi ? setEntryAtLumi(run, lumi) : setEntryAtRun(run));
     }

bool edm::RootFile::setEntryAtLumi	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi
	)

Definition at line 1575 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::entry(), edm::IndexIntoFile::findLumiPosition(), indexIntoFile_, indexIntoFileEnd_, indexIntoFileIter_, lumiTree_, and edm::RootTree::setEntryNumber().

Referenced by setEntryAtItem().

                                                                         {
     indexIntoFileIter_ = indexIntoFile_.findLumiPosition(run, lumi);
     if(indexIntoFileIter_ == indexIntoFileEnd_) return false;
     lumiTree_.setEntryNumber(indexIntoFileIter_.entry());
     return true;
   }

bool edm::RootFile::setEntryAtNextEventInLumi	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi
	)

Definition at line 1591 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::advanceToEvent(), edm::IndexIntoFile::IndexIntoFileItr::entry(), fillEventAuxiliary(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileIter_, edm::IndexIntoFile::kEvent, edm::IndexIntoFile::IndexIntoFileItr::lumi(), and edm::IndexIntoFile::IndexIntoFileItr::run().

                                                                                    {
     if(indexIntoFileIter_.getEntryType() == IndexIntoFile::kEvent) {
       ++indexIntoFileIter_;
     }
     indexIntoFileIter_.advanceToEvent();
     if(indexIntoFileIter_.getEntryType() != IndexIntoFile::kEvent) return false;
     if(run != indexIntoFileIter_.run()) return false;
     if(lumi != indexIntoFileIter_.lumi()) return false;
     fillEventAuxiliary(indexIntoFileIter_.entry());
     return true;
   }

bool edm::RootFile::setEntryAtRun ( RunNumber_t run )

Definition at line 1583 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::entry(), edm::IndexIntoFile::findRunPosition(), indexIntoFile_, indexIntoFileEnd_, indexIntoFileIter_, runTree_, and edm::RootTree::setEntryNumber().

Referenced by setEntryAtItem().

                                          {
     indexIntoFileIter_ = indexIntoFile_.findRunPosition(run);
     if(indexIntoFileIter_ == indexIntoFileEnd_) return false;
     runTree_.setEntryNumber(indexIntoFileIter_.entry());
     return true;
   }

void edm::RootFile::setIfFastClonable	(	int	remainingEvents,
		int	remainingLumis
	)

private

Definition at line 579 of file RootFile.cc.

References duplicateChecker_, edm::FileBlock::DuplicateEventsRemoved, edm::RootTree::entries(), edm::FileBlock::EventsToBeSorted, eventTree_, fileFormatVersion(), edm::FileBlock::FileTooOld, edm::IndexIntoFile::firstAppearanceOrder, edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFile_, indexIntoFileBegin_, indexIntoFileEnd_, edm::FileBlock::InitialEventsSkipped, edm::IndexIntoFile::iterationWillBeInEntryOrder(), edm::IndexIntoFile::kEvent, lumiTree_, edm::FileBlock::MaxEventsTooSmall, edm::FileBlock::MaxLumisTooSmall, edm::FileBlock::NoEventsInFile, noEventSort_, edm::FileBlock::NotProcessingEvents, edm::IndexIntoFile::numericalOrder, processingMode_, edm::FileBlock::RunOrLumiNotContiguous, edm::InputSource::RunsLumisAndEvents, skipAnyEvents_, and whyNotFastClonable_.

Referenced by RootFile().

                                                                      {
     if(fileFormatVersion().noMetaDataTrees() and !fileFormatVersion().storedProductProvenanceUsed()) {
       //we must avoid copying the old branch which stored the per product per event provenance
       whyNotFastClonable_ += FileBlock::FileTooOld;
       return;
     }
     if(!fileFormatVersion().splitProductIDs()) {
       whyNotFastClonable_ += FileBlock::FileTooOld;
       return;
     }
     if(processingMode_ != InputSource::RunsLumisAndEvents) {
       whyNotFastClonable_ += FileBlock::NotProcessingEvents;
       return;
     }
     // Find entry for first event in file
     IndexIntoFile::IndexIntoFileItr it = indexIntoFileBegin_;
     while(it != indexIntoFileEnd_ && it.getEntryType() != IndexIntoFile::kEvent) {
       ++it;
     }
     if(it == indexIntoFileEnd_) {
       whyNotFastClonable_ += FileBlock::NoEventsInFile;
       return;
     }
 
     // From here on, record all reasons we can't fast clone.
     IndexIntoFile::SortOrder sortOrder = (noEventSort_ ? IndexIntoFile::firstAppearanceOrder : IndexIntoFile::numericalOrder);
     if(!indexIntoFile_.iterationWillBeInEntryOrder(sortOrder)) {
       whyNotFastClonable_ += (noEventSort_ ? FileBlock::RunOrLumiNotContiguous : FileBlock::EventsToBeSorted);
     }
     if(skipAnyEvents_) {
       whyNotFastClonable_ += FileBlock::InitialEventsSkipped;
     }
     if(remainingEvents >= 0 && eventTree_.entries() > remainingEvents) {
       whyNotFastClonable_ += FileBlock::MaxEventsTooSmall;
     }
     if(remainingLumis >= 0 && lumiTree_.entries() > remainingLumis) {
       whyNotFastClonable_ += FileBlock::MaxLumisTooSmall;
     }
     // We no longer fast copy the EventAuxiliary branch, so there
     // is no longer any need to disable fast copying because the run
     // number is being modified.   Also, this check did not work anyway
     // because this function is called before forcedRunOffset_ is set.
 
     // if(forcedRunOffset_ != 0) {
     //   whyNotFastClonable_ += FileBlock::RunNumberModified;
     // }
     if(duplicateChecker_ &&
       !duplicateChecker_->checkDisabled() &&
       !duplicateChecker_->noDuplicatesInFile()) {
       whyNotFastClonable_ += FileBlock::DuplicateEventsRemoved;
     }
   }

void edm::RootFile::setPosition ( IndexIntoFile::IndexIntoFileItr const & position )

Definition at line 664 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::copyPosition(), and indexIntoFileIter_.

                                                                      {
     indexIntoFileIter_.copyPosition(position);
   }

void edm::RootFile::setToLastEntry ( )

inline

Definition at line 132 of file RootFile.h.

References indexIntoFileEnd_, and indexIntoFileIter_.

                           {
       indexIntoFileIter_ = indexIntoFileEnd_;
     }

bool edm::RootFile::skipEvents ( int & offset )

Definition at line 1272 of file RootFile.cc.

References duplicateChecker_, edm::EventID::event(), eventAux_, eventSkipperByID_, file_, fillEventAuxiliary(), edm::EventAuxiliary::id(), indexIntoFileEnd_, indexIntoFileIter_, edm::IndexIntoFile::invalidEntry, edm::IndexIntoFile::invalidIndex, edm::IndexIntoFile::invalidLumi, edm::IndexIntoFile::invalidRun, evf::evtn::offset(), edm::IndexIntoFile::IndexIntoFileItr::skipEventBackward(), and edm::IndexIntoFile::IndexIntoFileItr::skipEventForward().

                                   {
     while(offset > 0 && indexIntoFileIter_ != indexIntoFileEnd_) {
 
       int phIndexOfSkippedEvent = IndexIntoFile::invalidIndex;
       RunNumber_t runOfSkippedEvent = IndexIntoFile::invalidRun;
       LuminosityBlockNumber_t lumiOfSkippedEvent = IndexIntoFile::invalidLumi;
       IndexIntoFile::EntryNumber_t skippedEventEntry = IndexIntoFile::invalidEntry;
 
       indexIntoFileIter_.skipEventForward(phIndexOfSkippedEvent,
                                           runOfSkippedEvent,
                                           lumiOfSkippedEvent,
                                           skippedEventEntry);
 
       // At the end of the file and there were no more events to skip
       if(skippedEventEntry == IndexIntoFile::invalidEntry) break;
 
       if(eventSkipperByID_ && eventSkipperByID_->somethingToSkip()) {
         fillEventAuxiliary(skippedEventEntry);
         if(eventSkipperByID_->skipIt(runOfSkippedEvent, lumiOfSkippedEvent, eventAux_.id().event())) {
             continue;
         }
       }
       if(duplicateChecker_ &&
          !duplicateChecker_->checkDisabled() &&
          !duplicateChecker_->noDuplicatesInFile()) {
 
         fillEventAuxiliary(skippedEventEntry);
         if(duplicateChecker_->isDuplicateAndCheckActive(phIndexOfSkippedEvent,
                                                          runOfSkippedEvent,
                                                          lumiOfSkippedEvent,
                                                          eventAux_.id().event(),
                                                          file_)) {
           continue;
         }
       }
       --offset;
     }
 
     while(offset < 0) {
 
       if(duplicateChecker_) {
         duplicateChecker_->disable();
       }
 
       int phIndexOfEvent = IndexIntoFile::invalidIndex;
       RunNumber_t runOfEvent =  IndexIntoFile::invalidRun;
       LuminosityBlockNumber_t lumiOfEvent = IndexIntoFile::invalidLumi;
       IndexIntoFile::EntryNumber_t eventEntry = IndexIntoFile::invalidEntry;
 
       indexIntoFileIter_.skipEventBackward(phIndexOfEvent,
                                            runOfEvent,
                                            lumiOfEvent,
                                            eventEntry);
 
       if(eventEntry == IndexIntoFile::invalidEntry) break;
 
       if(eventSkipperByID_ && eventSkipperByID_->somethingToSkip()) {
         fillEventAuxiliary(eventEntry);
         if(eventSkipperByID_->skipIt(runOfEvent, lumiOfEvent, eventAux_.id().event())) {
           continue;
         }
       }
       ++offset;
     }
     return(indexIntoFileIter_ == indexIntoFileEnd_);
   }

bool edm::RootFile::skipThisEntry ( )

private

Definition at line 669 of file RootFile.cc.

Referenced by getNextItemType().

                           {
     if(indexIntoFileIter_ == indexIntoFileEnd_) {
         return false;
     }
     if(eventSkipperByID_ && eventSkipperByID_->somethingToSkip()) {
 
       // See first if the entire lumi or run is skipped, so we won't have to read the event Auxiliary in that case.
       if(eventSkipperByID_->skipIt(indexIntoFileIter_.run(), indexIntoFileIter_.lumi(), 0U)) {
         return true;
       }
 
       // The Lumi is not skipped.  If this is an event, see if the event is skipped.
       if(indexIntoFileIter_.getEntryType() == IndexIntoFile::kEvent) {
         fillEventAuxiliary(indexIntoFileIter_.entry());
         if(eventSkipperByID_->skipIt(indexIntoFileIter_.run(),
                                       indexIntoFileIter_.lumi(),
                                       eventAux_.id().event())) {
           return true;
         }
       }
 
       // Skip runs with no lumis if either lumisToSkip or lumisToProcess have been set to select lumis
       if(indexIntoFileIter_.getEntryType() == IndexIntoFile::kRun &&
           eventSkipperByID_->skippingLumis()) {
         IndexIntoFile::IndexIntoFileItr iterLumi = indexIntoFileIter_;
 
         // There are no lumis in this run, not even ones we will skip
         if(iterLumi.peekAheadAtLumi() == IndexIntoFile::invalidLumi) {
           return true;
         }
         // If we get here there are lumis in the run, check to see if we are skipping all of them
         do {
           if(!eventSkipperByID_->skipIt(iterLumi.run(), iterLumi.peekAheadAtLumi(), 0U)) {
             return false;
           }
         }
         while(iterLumi.skipLumiInRun());
         return true;
       }
     }
     return false;
   }

RootTreePtrArray& edm::RootFile::treePointers ( )

inlineprivate

Definition at line 149 of file RootFile.h.

References treePointers_.

149 {return treePointers_;}

edm::RootFile::treePointers_

RootTreePtrArray treePointers_

Definition: RootFile.h:201

void edm::RootFile::validateFile	(	InputType	inputType,
		bool	usingGoToEvent
	)

private

Definition at line 1069 of file RootFile.cc.

References edm::createGlobalIdentifier(), daqProvenanceHelper_, duplicateChecker_, edm::IndexIntoFile::empty(), edm::RootTree::entries(), python.tagInventory::entries, edm::errors::EventCorruption, eventTree_, edm::hlt::Exception, fid_, fileFormatVersion(), edm::IndexIntoFile::fillEventNumbersOrEntries(), fillIndexIntoFile(), edm::IndexIntoFile::fixIndexes(), indexIntoFile_, edm::FileID::isValid(), edm::RootTree::isValid(), noEventSort_, orderedProcessHistoryIDs_, edm::Primary, processHistoryRegistry_, edm::IndexIntoFile::reduceProcessHistoryIDs(), runTree(), edm::IndexIntoFile::setEventFinder(), edm::IndexIntoFile::setNumberOfEvents(), edm::IndexIntoFile::setProcessHistoryIDs(), and edm::FileFormatVersion::useReducedProcessHistoryID().

Referenced by RootFile().

                                                                  {
     if(!fid_.isValid()) {
       fid_ = FileID(createGlobalIdentifier());
     }
     if(!eventTree_.isValid()) {
       throw Exception(errors::EventCorruption) <<
          "'Events' tree is corrupted or not present\n" << "in the input file.\n";
     }
 
     if(fileFormatVersion().hasIndexIntoFile()) {
       if(runTree().entries() > 0) {
         assert(!indexIntoFile_.empty());
       }
       if(!fileFormatVersion().useReducedProcessHistoryID()) {
         if(daqProvenanceHelper_) {
           std::vector<ProcessHistoryID>& phidVec = indexIntoFile_.setProcessHistoryIDs();
           for(auto& phid : phidVec) {
             phid = daqProvenanceHelper_->mapProcessHistoryID(phid);
           }
         }
         indexIntoFile_.reduceProcessHistoryIDs(*processHistoryRegistry_);
       }
     }
     else {
       assert(indexIntoFile_.empty());
       fillIndexIntoFile();
     }
 
     indexIntoFile_.fixIndexes(orderedProcessHistoryIDs_);
     indexIntoFile_.setNumberOfEvents(eventTree_.entries());
     indexIntoFile_.setEventFinder(boost::shared_ptr<IndexIntoFile::EventFinder>(new RootFileEventFinder(eventTree_)));
     // We fill the event numbers explicitly if we need to find events in closed files,
     // such as for secondary files (or secondary sources) or if duplicate checking across files.
     bool needEventNumbers = false;
     bool needIndexesForDuplicateChecker = duplicateChecker_ && duplicateChecker_->checkingAllFiles() && !duplicateChecker_->checkDisabled();
     if(inputType != InputType::Primary || needIndexesForDuplicateChecker || usingGoToEvent) {
       needEventNumbers = true;
     }
     bool needEventEntries = false;
     if(inputType != InputType::Primary || !noEventSort_) {
       // We need event entries for sorting or for secondary files or sources.
       needEventEntries = true;
     }
     indexIntoFile_.fillEventNumbersOrEntries(needEventNumbers, needEventEntries);
   }

bool edm::RootFile::wasFirstEventJustRead ( ) const

Definition at line 781 of file RootFile.cc.

References indexIntoFileIter_, edm::IndexIntoFile::invalidEntry, fjr2json::lumi, DTTTrigCorrFirst::run, and edm::IndexIntoFile::IndexIntoFileItr::skipEventBackward().

                                         {
     IndexIntoFile::IndexIntoFileItr itr(indexIntoFileIter_);
     int phIndex;
     RunNumber_t run;
     LuminosityBlockNumber_t lumi;
     IndexIntoFile::EntryNumber_t eventEntry;
     itr.skipEventBackward(phIndex,
                           run,
                           lumi,
                           eventEntry);
     itr.skipEventBackward(phIndex,
                           run,
                           lumi,
                           eventEntry);
     return eventEntry == IndexIntoFile::invalidEntry;
   }

bool edm::RootFile::wasLastEventJustRead ( ) const

Definition at line 774 of file RootFile.cc.

References edm::IndexIntoFile::IndexIntoFileItr::advanceToEvent(), edm::IndexIntoFile::IndexIntoFileItr::getEntryType(), indexIntoFileIter_, and edm::IndexIntoFile::kEnd.

                                        {
     IndexIntoFile::IndexIntoFileItr itr(indexIntoFileIter_);
     itr.advanceToEvent();
     return itr.getEntryType() == IndexIntoFile::kEnd;
   }