#include <PoolSource.h>

Inheritance diagram for edm::PoolSource:

Public Member Functions
	PoolSource (ParameterSet const &pset, InputSourceDescription const &desc)

virtual	~PoolSource ()

Public Member Functions inherited from edm::VectorInputSource
void	dropUnwantedBranches (std::vector< std::string > const &wantedBranches)

template<typename T >
size_t	loopRandom (EventPrincipal &cache, size_t number, T eventOperator, CLHEP::HepRandomEngine *)

template<typename T >
size_t	loopRandomWithID (EventPrincipal &cache, LuminosityBlockID const &id, size_t number, T eventOperator, CLHEP::HepRandomEngine *)

template<typename T >
size_t	loopSequential (EventPrincipal &cache, size_t number, T eventOperator)

template<typename T >
size_t	loopSequentialWithID (EventPrincipal &cache, LuminosityBlockID const &id, size_t number, T eventOperator)

template<typename T , typename Collection >
size_t	loopSpecified (EventPrincipal &cache, Collection const &events, T eventOperator)

	VectorInputSource (ParameterSet const &pset, InputSourceDescription const &desc)

virtual	~VectorInputSource ()

Public Member Functions inherited from edm::EDInputSource
InputFileCatalog &	catalog (int n=0)

	EDInputSource (ParameterSet const &pset, InputSourceDescription const &desc)

std::vector< FileCatalogItem > const &	fileCatalogItems (int n=0) const

std::vector< std::string > const &	fileNames (int n=0) const

std::vector< std::string > const &	logicalFileNames (int n=0) const

virtual	~EDInputSource ()

Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

std::shared_ptr < BranchIDListHelper >	branchIDListHelper () const
	Accessor for branchIDListHelper. More...

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doBeginLumi (LuminosityBlockPrincipal &lbp, ProcessContext const *)
	Called by framework at beginning of lumi block. More...

void	doBeginRun (RunPrincipal &rp, ProcessContext const *)
	Called by framework at beginning of run. More...

void	doEndJob ()
	Called by framework at end of job. More...

void	doEndLumi (LuminosityBlockPrincipal &lbp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of lumi block. More...

void	doEndRun (RunPrincipal &rp, bool cleaningUpAfterException, ProcessContext const *)
	Called by framework at end of run. More...

void	doPostForkReacquireResources (std::shared_ptr< multicore::MessageReceiverForSource >)

void	doPreForkReleaseResources ()
	Called by the framework before forking the process. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

	InputSource (InputSource const &)=delete

void	issueReports (EventID const &eventID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

std::shared_ptr < LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()
	Advances the source to the next item. More...

InputSource &	operator= (InputSource const &)=delete

bool	primary () const
	Accessor for primary input source flag. More...

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessHistoryRegistry const &	processHistoryRegistry () const
	Const accessor for process history registry. More...

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()
	Non-const accessor for process history registry. More...

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

std::shared_ptr < ProductRegistry const >	productRegistry () const
	Accessor for product registry. More...

bool	randomAccess () const

void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...

bool	readEvent (EventPrincipal &ep, EventID const &, StreamContext &)
	Read a specific event. More...

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...

std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

void	registerProducts ()
	Register any produced products. More...

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...

SharedResourcesAcquirer *	resourceSharedWithDelayedReader () const
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

std::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

bool	skipForForking ()

std::shared_ptr < ThinnedAssociationsHelper >	thinnedAssociationsHelper () const
	Accessor for thinnedAssociationsHelper. More...

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource ()
	Destructor. More...

Static Public Member Functions
static void	fillDescriptions (ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::EDInputSource
static void	fillDescription (ParameterSetDescription &desc)

Static Public Member Functions inherited from edm::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Private Member Functions
virtual void	closeFile_ ()

virtual void	dropUnwantedBranches_ (std::vector< std::string > const &wantedBranches)

virtual void	endJob ()

virtual ProcessingController::ForwardState	forwardState_ () const

virtual ItemType	getNextItemType ()

virtual bool	goToEvent_ (EventID const &eventID)

virtual void	preForkReleaseResources ()

virtual bool	randomAccess_ () const

virtual void	readEvent_ (EventPrincipal &eventPrincipal)

virtual std::unique_ptr < FileBlock >	readFile_ ()

virtual bool	readIt (EventID const &id, EventPrincipal &eventPrincipal, StreamContext &streamContext) override

virtual void	readLuminosityBlock_ (LuminosityBlockPrincipal &lumiPrincipal)

virtual std::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

virtual void	readOneRandom (EventPrincipal &cache, CLHEP::HepRandomEngine *) override

virtual bool	readOneRandomWithID (EventPrincipal &cache, LuminosityBlockID const &lumiID, CLHEP::HepRandomEngine *) override

virtual bool	readOneSequential (EventPrincipal &cache)

virtual bool	readOneSequentialWithID (EventPrincipal &cache, LuminosityBlockID const &lumiID)

virtual void	readOneSpecified (EventPrincipal &cache, EventID const &id)

virtual void	readRun_ (RunPrincipal &runPrincipal)

virtual std::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()

SharedResourcesAcquirer *	resourceSharedWithDelayedReader_ () const override

virtual ProcessingController::ReverseState	reverseState_ () const

virtual void	rewind_ ()

virtual void	skip (int offset)

Private Attributes
std::array< std::vector < BranchID >, NumBranchTypes >	branchIDsToReplace_

std::unique_ptr < RootInputFileSequence >	primaryFileSequence_

std::unique_ptr < SharedResourcesAcquirer >	resourceSharedWithDelayedReaderPtr_

RootServiceChecker	rootServiceChecker_

std::vector< std::unique_ptr < EventPrincipal > >	secondaryEventPrincipals_

std::unique_ptr < RootInputFileSequence >	secondaryFileSequence_

std::shared_ptr < LuminosityBlockPrincipal >	secondaryLumiPrincipal_

std::shared_ptr< RunPrincipal >	secondaryRunPrincipal_

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

std::shared_ptr < LuminosityBlockPrincipal > const	luminosityBlockPrincipal () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryUpdate () const

ProductRegistry &	productRegistryUpdate () const

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

std::shared_ptr< RunPrincipal > const	runPrincipal () const

void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

ItemType	state () const

Detailed Description

Definition at line 31 of file PoolSource.h.

Constructor & Destructor Documentation

edm::PoolSource::PoolSource	(	ParameterSet const &	pset,
		InputSourceDescription const &	desc
	)

explicit

Definition at line 63 of file PoolSource.cc.

References edm::SharedResourcesRegistry::createAcquirerForSourceDelayedReader(), edm::SharedResourcesRegistry::instance(), edm::Primary, edm::SecondaryFile, and edm::SecondarySource.

                                                                                      :
     VectorInputSource(pset, desc),
     rootServiceChecker_(),
     primaryFileSequence_(new RootInputFileSequence(pset, *this, catalog(), desc.allocations_->numberOfStreams(),
                                                    primary() ? InputType::Primary : InputType::SecondarySource)),
     secondaryFileSequence_(catalog(1).empty() ? nullptr :
                            new RootInputFileSequence(pset, *this, catalog(1), desc.allocations_->numberOfStreams(),
                            InputType::SecondaryFile)),
     secondaryRunPrincipal_(),
     secondaryLumiPrincipal_(),
     secondaryEventPrincipals_(),
     branchIDsToReplace_(),
     resourceSharedWithDelayedReaderPtr_(primary()?
                                         new SharedResourcesAcquirer{SharedResourcesRegistry::instance()->createAcquirerForSourceDelayedReader()}:
                                         static_cast<SharedResourcesAcquirer*>(nullptr))
   {
     if(secondaryFileSequence_) {
       unsigned int nStreams = desc.allocations_->numberOfStreams();
       assert(primary());
       secondaryEventPrincipals_.reserve(nStreams);
       for(unsigned int index = 0; index < nStreams; ++index) {
         secondaryEventPrincipals_.emplace_back(new EventPrincipal(secondaryFileSequence_->fileProductRegistry(),
                                                                   secondaryFileSequence_->fileBranchIDListHelper(),
                                                                   std::make_shared<ThinnedAssociationsHelper const>(),
                                                                   processConfiguration(),
                                                                   nullptr,
                                                                   index));
       }
       std::array<std::set<BranchID>, NumBranchTypes> idsToReplace;
       ProductRegistry::ProductList const& secondary = secondaryFileSequence_->fileProductRegistry()->productList();
       ProductRegistry::ProductList const& primary = primaryFileSequence_->fileProductRegistry()->productList();
       std::set<BranchID> associationsFromSecondary;
       typedef ProductRegistry::ProductList::const_iterator const_iterator;
       typedef ProductRegistry::ProductList::iterator iterator;
       //this is the registry used by the 'outside' world and only has the primary file information in it at present
       ProductRegistry::ProductList& fullList = productRegistryUpdate().productListUpdator();
       for(const_iterator it = secondary.begin(), itEnd = secondary.end(); it != itEnd; ++it) {
         if(it->second.present()) {
           idsToReplace[it->second.branchType()].insert(it->second.branchID());
           if(it->second.branchType() == InEvent &&
              it->second.unwrappedType().typeInfo() == typeid(ThinnedAssociation)) {
             associationsFromSecondary.insert(it->second.branchID());
           }
           //now make sure this is marked as not dropped else the product will not be 'get'table from the Event
           iterator itFound = fullList.find(it->first);
           if(itFound != fullList.end()) {
             itFound->second.setDropped(false);
           }
         }
       }
       for(const_iterator it = primary.begin(), itEnd = primary.end(); it != itEnd; ++it) {
         if(it->second.present()) {
           idsToReplace[it->second.branchType()].erase(it->second.branchID());
           associationsFromSecondary.erase(it->second.branchID());
         }
       }
       if(idsToReplace[InEvent].empty() && idsToReplace[InLumi].empty() && idsToReplace[InRun].empty()) {
         secondaryFileSequence_.reset();
       } else {
         for(int i = InEvent; i < NumBranchTypes; ++i) {
           branchIDsToReplace_[i].reserve(idsToReplace[i].size());
           for(std::set<BranchID>::const_iterator it = idsToReplace[i].begin(), itEnd = idsToReplace[i].end();
                it != itEnd; ++it) {
             branchIDsToReplace_[i].push_back(*it);
           }
         }
       }
       secondaryFileSequence_->initAssociationsFromSecondary(associationsFromSecondary);
     }
   }

edm::PoolSource::~PoolSource ( )

virtual

Definition at line 134 of file PoolSource.cc.

134 {}

Member Function Documentation

void edm::PoolSource::closeFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 152 of file PoolSource.cc.

References primaryFileSequence_.

                               {
     primaryFileSequence_->closeFile_();
   }

void edm::PoolSource::dropUnwantedBranches_ ( std::vector< std::string > const & wantedBranches )

privatevirtual

Implements edm::VectorInputSource.

Definition at line 320 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                               {
     assert(!secondaryFileSequence_);
     primaryFileSequence_->dropUnwantedBranches_(wantedBranches);
   }

void edm::PoolSource::endJob ( void )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 137 of file PoolSource.cc.

References primaryFileSequence_, edm::InputFile::reportReadBranches(), and secondaryFileSequence_.

                      {
     if(secondaryFileSequence_) secondaryFileSequence_->endJob();
     primaryFileSequence_->endJob();
     InputFile::reportReadBranches();
   }

void edm::PoolSource::fillDescriptions ( ConfigurationDescriptions & descriptions )

static

Definition at line 326 of file PoolSource.cc.

References edm::ConfigurationDescriptions::add(), edm::EDInputSource::fillDescription(), edm::RootInputFileSequence::fillDescription(), and edm::ParameterSetDescription::setComment().

                                                                        {
 
     ParameterSetDescription desc;
 
     desc.setComment("Reads EDM/Root files.");
     VectorInputSource::fillDescription(desc);
     RootInputFileSequence::fillDescription(desc);
 
     descriptions.add("source", desc);
   }

ProcessingController::ForwardState edm::PoolSource::forwardState_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 343 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->forwardState();
   }

InputSource::ItemType edm::PoolSource::getNextItemType ( )

privatevirtual

Implements edm::InputSource.

Definition at line 247 of file PoolSource.cc.

References event(), edm::IndexIntoFile::invalidEvent, edm::IndexIntoFile::invalidLumi, edm::IndexIntoFile::invalidRun, edm::InputSource::IsEvent, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsSynchronize, fjr2json::lumi, primaryFileSequence_, edm::InputSource::run(), secondaryFileSequence_, and edm::InputSource::state().

                               {
     RunNumber_t run = IndexIntoFile::invalidRun;
     LuminosityBlockNumber_t lumi = IndexIntoFile::invalidLumi;
     EventNumber_t event = IndexIntoFile::invalidEvent;
     InputSource::ItemType itemType = primaryFileSequence_->getNextItemType(run, lumi, event);
     if(secondaryFileSequence_ && (IsSynchronize != state())) {
       if(itemType == IsRun || itemType == IsLumi || itemType == IsEvent) {
         if(!secondaryFileSequence_->containedInCurrentFile(run, lumi, event)) {
           return IsSynchronize;
         }
       }
     }
     return itemType;
   }

bool edm::PoolSource::goToEvent_ ( EventID const & eventID )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 285 of file PoolSource.cc.

References primaryFileSequence_.

                                                {
     return primaryFileSequence_->goToEvent(eventID);
   }

void edm::PoolSource::preForkReleaseResources ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 263 of file PoolSource.cc.

References primaryFileSequence_.

                                       {
     primaryFileSequence_->closeFile_();
   }

bool edm::PoolSource::randomAccess_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 338 of file PoolSource.cc.

                                   {
     return true;
   }

void edm::PoolSource::readEvent_ ( EventPrincipal & eventPrincipal )

privatevirtual

Implements edm::InputSource.

Definition at line 216 of file PoolSource.cc.

References branchIDsToReplace_, edm::Principal::clearPrincipal(), relativeConstraints::empty, edm::EventID::event(), edm::hlt::Exception, newFWLiteAna::found, edm::EventPrincipal::id(), edm::InEvent, edm::EventPrincipal::luminosityBlock(), edm::EventPrincipal::mergeProvenanceRetrievers(), edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::Principal::recombine(), edm::EventPrincipal::run(), secondaryEventPrincipals_, secondaryFileSequence_, edm::EventPrincipal::streamID(), and edm::StreamID::value().

Referenced by readIt().

                                                        {
     primaryFileSequence_->readEvent(eventPrincipal);
     if(secondaryFileSequence_ && !branchIDsToReplace_[InEvent].empty()) {
       bool found = secondaryFileSequence_->skipToItem(eventPrincipal.run(),
                                                       eventPrincipal.luminosityBlock(),
                                                       eventPrincipal.id().event());
       if(found) {
         EventPrincipal& secondaryEventPrincipal = *secondaryEventPrincipals_[eventPrincipal.streamID().value()];
         secondaryFileSequence_->readEvent(secondaryEventPrincipal);
         checkConsistency(eventPrincipal, secondaryEventPrincipal);
         checkHistoryConsistency(eventPrincipal, secondaryEventPrincipal);
         eventPrincipal.recombine(secondaryEventPrincipal, branchIDsToReplace_[InEvent]);
         eventPrincipal.mergeProvenanceRetrievers(secondaryEventPrincipal);
         secondaryEventPrincipal.clearPrincipal();
       } else {
         throw Exception(errors::MismatchedInputFiles, "PoolSource::readEvent_") <<
           eventPrincipal.id() << " is not found in the secondary input files\n";
       }
     }
   }

std::unique_ptr< FileBlock > edm::PoolSource::readFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 144 of file PoolSource.cc.

References benchmark_cfg::fb, edm::FileBlock::HasSecondaryFileSequence, primaryFileSequence_, and secondaryFileSequence_.

                         {
     std::unique_ptr<FileBlock> fb = primaryFileSequence_->readFile_();
     if(secondaryFileSequence_) {
       fb->setNotFastClonable(FileBlock::HasSecondaryFileSequence);
     }
     return std::move(fb);
   }

bool edm::PoolSource::readIt	(	EventID const &	id,
		EventPrincipal &	eventPrincipal,
		StreamContext &	streamContext
	)

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 238 of file PoolSource.cc.

References event(), newFWLiteAna::found, edm::InputSource::luminosityBlock(), primaryFileSequence_, readEvent_(), and edm::InputSource::run().

                                                                                                     {
     bool found = primaryFileSequence_->skipToItem(id.run(), id.luminosityBlock(), id.event());
     if(!found) return false;
     EventSourceSentry sentry(*this, streamContext);
     readEvent_(eventPrincipal);
     return true;
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 191 of file PoolSource.cc.

References edm::LuminosityBlockPrincipal::aux(), branchIDsToReplace_, relativeConstraints::empty, edm::hlt::Exception, newFWLiteAna::found, edm::LuminosityBlockPrincipal::index(), edm::InLumi, edm::LuminosityBlockPrincipal::luminosityBlock(), edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), edm::Principal::recombine(), edm::LuminosityBlockPrincipal::run(), secondaryFileSequence_, and secondaryLumiPrincipal_.

                                                                           {
     primaryFileSequence_->readLuminosityBlock_(lumiPrincipal);
     if(secondaryFileSequence_ && !branchIDsToReplace_[InLumi].empty()) {
       bool found = secondaryFileSequence_->skipToItem(lumiPrincipal.run(), lumiPrincipal.luminosityBlock(), 0U);
       if(found) {
         std::shared_ptr<LuminosityBlockAuxiliary> secondaryAuxiliary = secondaryFileSequence_->readLuminosityBlockAuxiliary_();
         checkConsistency(lumiPrincipal.aux(), *secondaryAuxiliary);
         secondaryLumiPrincipal_.reset(new LuminosityBlockPrincipal(secondaryAuxiliary,
                                                                    secondaryFileSequence_->fileProductRegistry(),
                                                                    processConfiguration(),
                                                                    nullptr,
                                                                    lumiPrincipal.index()));
         secondaryFileSequence_->readLuminosityBlock_(*secondaryLumiPrincipal_);
         checkHistoryConsistency(lumiPrincipal, *secondaryLumiPrincipal_);
         lumiPrincipal.recombine(*secondaryLumiPrincipal_, branchIDsToReplace_[InLumi]);
       } else {
         throw Exception(errors::MismatchedInputFiles, "PoolSource::readLuminosityBlock_")
           << " Run " << lumiPrincipal.run()
           << " LuminosityBlock " << lumiPrincipal.luminosityBlock()
           << " is not found in the secondary input files\n";
       }
     }
   }

std::shared_ptr< LuminosityBlockAuxiliary > edm::PoolSource::readLuminosityBlockAuxiliary_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 162 of file PoolSource.cc.

References primaryFileSequence_.

                                             {
     return primaryFileSequence_->readLuminosityBlockAuxiliary_();
   }

void edm::PoolSource::readOneRandom	(	EventPrincipal &	cache,
		CLHEP::HepRandomEngine *	engine
	)

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 290 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                {
     assert(!secondaryFileSequence_);
     primaryFileSequence_->readOneRandom(cache, engine);
   }

bool edm::PoolSource::readOneRandomWithID	(	EventPrincipal &	cache,
		LuminosityBlockID const &	lumiID,
		CLHEP::HepRandomEngine *	engine
	)

overrideprivatevirtual

Implements edm::VectorInputSource.

Definition at line 296 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                                                       {
     assert(!secondaryFileSequence_);
     return primaryFileSequence_->readOneRandomWithID(cache, lumiID, engine);
   }

bool edm::PoolSource::readOneSequential ( EventPrincipal & cache )

privatevirtual

Implements edm::VectorInputSource.

Definition at line 302 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                      {
     assert(!secondaryFileSequence_);
     return primaryFileSequence_->readOneSequential(cache);
   }

bool edm::PoolSource::readOneSequentialWithID	(	EventPrincipal &	cache,
		LuminosityBlockID const &	lumiID
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 308 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                             {
     assert(!secondaryFileSequence_);
     return primaryFileSequence_->readOneSequentialWithID(cache, lumiID);
   }

void edm::PoolSource::readOneSpecified	(	EventPrincipal &	cache,
		EventID const &	id
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 314 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                        {
     assert(!secondaryFileSequence_);
     primaryFileSequence_->readOneSpecified(cache, id);
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 167 of file PoolSource.cc.

References edm::RunPrincipal::aux(), branchIDsToReplace_, relativeConstraints::empty, edm::hlt::Exception, newFWLiteAna::found, edm::RunPrincipal::index(), edm::InRun, edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), edm::Principal::recombine(), edm::RunPrincipal::run(), secondaryFileSequence_, and secondaryRunPrincipal_.

                                                  {
     primaryFileSequence_->readRun_(runPrincipal);
     if(secondaryFileSequence_ && !branchIDsToReplace_[InRun].empty()) {
       bool found = secondaryFileSequence_->skipToItem(runPrincipal.run(), 0U, 0U);
       if(found) {
         std::shared_ptr<RunAuxiliary> secondaryAuxiliary = secondaryFileSequence_->readRunAuxiliary_();
         checkConsistency(runPrincipal.aux(), *secondaryAuxiliary);
         secondaryRunPrincipal_.reset(new RunPrincipal(secondaryAuxiliary,
                                                       secondaryFileSequence_->fileProductRegistry(),
                                                       processConfiguration(),
                                                       nullptr,
                                                       runPrincipal.index()));
         secondaryFileSequence_->readRun_(*secondaryRunPrincipal_);
         checkHistoryConsistency(runPrincipal, *secondaryRunPrincipal_);
         runPrincipal.recombine(*secondaryRunPrincipal_, branchIDsToReplace_[InRun]);
       } else {
         throw Exception(errors::MismatchedInputFiles, "PoolSource::readRun_")
           << " Run " << runPrincipal.run()
           << " is not found in the secondary input files\n";
       }
     }
   }

std::shared_ptr< RunAuxiliary > edm::PoolSource::readRunAuxiliary_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 157 of file PoolSource.cc.

References primaryFileSequence_.

                                 {
     return primaryFileSequence_->readRunAuxiliary_();
   }

SharedResourcesAcquirer * edm::PoolSource::resourceSharedWithDelayedReader_ ( ) const

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 268 of file PoolSource.cc.

References resourceSharedWithDelayedReaderPtr_.

                                                      {
     return resourceSharedWithDelayedReaderPtr_.get();
   }

ProcessingController::ReverseState edm::PoolSource::reverseState_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 348 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->reverseState();
   }

void edm::PoolSource::rewind_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 274 of file PoolSource.cc.

References primaryFileSequence_.

                       {
     primaryFileSequence_->rewind_();
   }

void edm::PoolSource::skip ( int offset )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 280 of file PoolSource.cc.

References primaryFileSequence_.

                              {
     primaryFileSequence_->skipEvents(offset);
   }

Member Data Documentation

std::array<std::vector<BranchID>, NumBranchTypes> edm::PoolSource::branchIDsToReplace_

private

Definition at line 74 of file PoolSource.h.

Referenced by readEvent_(), readLuminosityBlock_(), and readRun_().

std::unique_ptr<RootInputFileSequence> edm::PoolSource::primaryFileSequence_

private

Definition at line 69 of file PoolSource.h.

Referenced by closeFile_(), dropUnwantedBranches_(), endJob(), forwardState_(), getNextItemType(), goToEvent_(), preForkReleaseResources(), readEvent_(), readFile_(), readIt(), readLuminosityBlock_(), readLuminosityBlockAuxiliary_(), readOneRandom(), readOneRandomWithID(), readOneSequential(), readOneSequentialWithID(), readOneSpecified(), readRun_(), readRunAuxiliary_(), reverseState_(), rewind_(), and skip().

std::unique_ptr<SharedResourcesAcquirer> edm::PoolSource::resourceSharedWithDelayedReaderPtr_

private

Definition at line 76 of file PoolSource.h.

Referenced by resourceSharedWithDelayedReader_().

RootServiceChecker edm::PoolSource::rootServiceChecker_

private

Definition at line 68 of file PoolSource.h.

std::vector<std::unique_ptr<EventPrincipal> > edm::PoolSource::secondaryEventPrincipals_

private

Definition at line 73 of file PoolSource.h.

Referenced by readEvent_().

std::unique_ptr<RootInputFileSequence> edm::PoolSource::secondaryFileSequence_

private

Definition at line 70 of file PoolSource.h.

Referenced by dropUnwantedBranches_(), endJob(), getNextItemType(), readEvent_(), readFile_(), readLuminosityBlock_(), readOneRandom(), readOneRandomWithID(), readOneSequential(), readOneSequentialWithID(), readOneSpecified(), and readRun_().

std::shared_ptr<LuminosityBlockPrincipal> edm::PoolSource::secondaryLumiPrincipal_

private

Definition at line 72 of file PoolSource.h.

Referenced by readLuminosityBlock_().

std::shared_ptr<RunPrincipal> edm::PoolSource::secondaryRunPrincipal_

private

Definition at line 71 of file PoolSource.h.

Referenced by readRun_().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation