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

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

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
boost::shared_ptr < ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

boost::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)
	Called by framework at beginning of lumi block. More...

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

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

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

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

void	doPostForkReacquireResources (boost::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...

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

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...

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

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

bool	randomAccess () const

boost::shared_ptr < LuminosityBlockPrincipal >	readAndCacheLumi (HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

boost::shared_ptr< RunPrincipal >	readAndCacheRun (HistoryAppender &historyAppender)
	Read next run (new run) More...

void	readAndMergeLumi (boost::shared_ptr< LuminosityBlockPrincipal > lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (boost::shared_ptr< RunPrincipal > rp)
	Read next run (same as a prior run) More...

EventPrincipal *	readEvent (EventPrincipal &ep)

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

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

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

boost::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...

ProcessingController::ReverseState	reverseState () const

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

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

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

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 EventPrincipal *	readEvent_ (EventPrincipal &eventPrincipal)

virtual std::unique_ptr < FileBlock >	readFile_ ()

virtual EventPrincipal *	readIt (EventID const &id, EventPrincipal &eventPrincipal)

virtual boost::shared_ptr < LuminosityBlockPrincipal >	readLuminosityBlock_ (boost::shared_ptr< LuminosityBlockPrincipal > lumiPrincipal)

virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

virtual EventPrincipal *	readOneRandom (EventPrincipal &cache)

virtual EventPrincipal *	readOneRandomWithID (EventPrincipal &cache, LuminosityBlockID const &lumiID)

virtual EventPrincipal *	readOneSequential (EventPrincipal &cache)

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

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

virtual boost::shared_ptr < RunPrincipal >	readRun_ (boost::shared_ptr< RunPrincipal > runPrincipal)

virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()

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_

RootServiceChecker	rootServiceChecker_

std::unique_ptr< EventPrincipal >	secondaryEventPrincipal_

std::unique_ptr < RootInputFileSequence >	secondaryFileSequence_

boost::shared_ptr < LuminosityBlockPrincipal >	secondaryLumiPrincipal_

boost::shared_ptr< RunPrincipal >	secondaryRunPrincipal_

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

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

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

bool	eventCached () const

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

bool	newLumi () const

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

boost::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 29 of file PoolSource.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 54 of file PoolSource.cc.

References begin, branchIDsToReplace_, relativeConstraints::empty, end, HDQMDatabaseProducer::fullList, i, edm::InEvent, edm::InLumi, edm::InRun, edm::NumBranchTypes, edm::InputSource::primary(), primaryFileSequence_, edm::ProductRegistry::productListUpdator(), edm::InputSource::productRegistryUpdate(), secondaryFileSequence_, and findQualityFiles::size.

                                                                                      :
     VectorInputSource(pset, desc),
     rootServiceChecker_(),
     primaryFileSequence_(new RootInputFileSequence(pset, *this, catalog(), 
                                                    primary() ? InputType::Primary : InputType::SecondarySource)),
     secondaryFileSequence_(catalog(1).empty() ? 0 :
                            new RootInputFileSequence(pset, *this, catalog(1), InputType::SecondaryFile)),
     secondaryRunPrincipal_(),
     secondaryLumiPrincipal_(),
     secondaryEventPrincipal_(secondaryFileSequence_ ? new EventPrincipal(secondaryFileSequence_->fileProductRegistry(), secondaryFileSequence_->fileBranchIDListHelper(), processConfiguration(), nullptr) : 0),
     branchIDsToReplace_() {
     if(secondaryFileSequence_) {
       assert(primary());
       std::array<std::set<BranchID>, NumBranchTypes> idsToReplace;
       ProductRegistry::ProductList const& secondary = secondaryFileSequence_->fileProductRegistry()->productList();
       ProductRegistry::ProductList const& primary = primaryFileSequence_->fileProductRegistry()->productList();
       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());
           //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.dropped()=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());
       }
       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);
           }
         }
       }
     }
   }

edm::PoolSource::~PoolSource ( )

virtual

Definition at line 101 of file PoolSource.cc.

101 {}

Member Function Documentation

void edm::PoolSource::closeFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 119 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 266 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 104 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 272 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 289 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->forwardState();
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 209 of file PoolSource.cc.

References primaryFileSequence_.

                               {
     return primaryFileSequence_->getNextItemType();;
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 231 of file PoolSource.cc.

References primaryFileSequence_.

                                                {
     return primaryFileSequence_->goToEvent(eventID);
   }

void edm::PoolSource::preForkReleaseResources ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 214 of file PoolSource.cc.

References primaryFileSequence_.

                                       {
     primaryFileSequence_->closeFile_();
   }

bool edm::PoolSource::randomAccess_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 284 of file PoolSource.cc.

                                   {
     return true;
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 179 of file PoolSource.cc.

References branchIDsToReplace_, relativeConstraints::empty, edm::EventID::event(), edm::hlt::Exception, newFWLiteAna::found, edm::EventPrincipal::id(), edm::InEvent, edm::EventPrincipal::luminosityBlock(), edm::EventPrincipal::mergeMappers(), edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::Principal::recombine(), edm::EventPrincipal::run(), secondaryEventPrincipal_, and secondaryFileSequence_.

Referenced by readIt().

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

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 111 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);
   }

EventPrincipal * edm::PoolSource::readIt	(	EventID const &	id,
		EventPrincipal &	eventPrincipal
	)

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 202 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 0;
     return readEvent_(eventPrincipal);
   }

boost::shared_ptr< LuminosityBlockPrincipal > edm::PoolSource::readLuminosityBlock_ ( boost::shared_ptr< LuminosityBlockPrincipal > lumiPrincipal )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 156 of file PoolSource.cc.

References branchIDsToReplace_, relativeConstraints::empty, edm::hlt::Exception, newFWLiteAna::found, edm::InLumi, edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), secondaryFileSequence_, and secondaryLumiPrincipal_.

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

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

privatevirtual

Implements edm::InputSource.

Definition at line 129 of file PoolSource.cc.

References primaryFileSequence_.

                                             {
     return primaryFileSequence_->readLuminosityBlockAuxiliary_();
   }

EventPrincipal * edm::PoolSource::readOneRandom ( EventPrincipal & cache )

privatevirtual

Implements edm::VectorInputSource.

Definition at line 236 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

EventPrincipal * edm::PoolSource::readOneRandomWithID	(	EventPrincipal &	cache,
		LuminosityBlockID const &	lumiID
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 242 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 248 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 254 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 260 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

boost::shared_ptr< RunPrincipal > edm::PoolSource::readRun_ ( boost::shared_ptr< RunPrincipal > runPrincipal )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 134 of file PoolSource.cc.

References branchIDsToReplace_, relativeConstraints::empty, edm::hlt::Exception, newFWLiteAna::found, edm::InRun, edm::errors::MismatchedInputFiles, primaryFileSequence_, edm::InputSource::processConfiguration(), secondaryFileSequence_, and secondaryRunPrincipal_.

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

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

privatevirtual

Implements edm::InputSource.

Definition at line 124 of file PoolSource.cc.

References primaryFileSequence_.

                                 {
     return primaryFileSequence_->readRunAuxiliary_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 294 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->reverseState();
   }

void edm::PoolSource::rewind_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 220 of file PoolSource.cc.

References primaryFileSequence_.

                       {
     primaryFileSequence_->rewind_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 226 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 68 of file PoolSource.h.

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

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

private

RootServiceChecker edm::PoolSource::rootServiceChecker_

private

Definition at line 62 of file PoolSource.h.

std::unique_ptr<EventPrincipal> edm::PoolSource::secondaryEventPrincipal_

private

Definition at line 67 of file PoolSource.h.

Referenced by readEvent_().

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

private

Definition at line 64 of file PoolSource.h.

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

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

private

Definition at line 66 of file PoolSource.h.

Referenced by readLuminosityBlock_().

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

private

Definition at line 65 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