#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 (size_t number, T eventOperator)

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

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

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

template<typename T , typename Collection >
size_t	loopSpecified (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...

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

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	markLumi ()
	Mark lumi as read. More...

int	markRun ()
	Mark run as read. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

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

ItemType	nextItemType ()

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

void	readAndCacheLumi (bool merge, HistoryAppender &historyAppender)
	Read next luminosity block. More...

void	readAndCacheRun (bool merge, HistoryAppender &historyAppender)
	Read next run. More...

EventPrincipal *	readEvent (boost::shared_ptr< LuminosityBlockPrincipal > lbCache)

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

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

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	postForkReacquireResources (boost::shared_ptr< edm::multicore::MessageReceiverForSource >)

virtual void	preForkReleaseResources ()

virtual bool	randomAccess_ () const

virtual EventPrincipal *	readEvent_ ()

virtual boost::shared_ptr < FileBlock >	readFile_ ()

virtual EventPrincipal *	readIt (EventID const &id)

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

virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

virtual EventPrincipal *	readOneRandom ()

virtual EventPrincipal *	readOneRandomWithID (LuminosityBlockID const &lumiID)

virtual EventPrincipal *	readOneSequential ()

virtual EventPrincipal *	readOneSequentialWithID (LuminosityBlockID const &lumiID)

virtual EventPrincipal *	readOneSpecified (EventID const &id)

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

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_

unsigned int	numberOfEventsBeforeBigSkip_

std::unique_ptr < RootInputFileSequence >	primaryFileSequence_

boost::shared_ptr < edm::multicore::MessageReceiverForSource >	receiver_

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)

EventPrincipal *	eventPrincipalCache ()

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

PrincipalCache const &	principalCache () const

PrincipalCache &	principalCache ()

ProductRegistry &	productRegistryUpdate () const

void	reset () const

void	resetLuminosityBlockAuxiliary () const

void	resetRunAuxiliary () const

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

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

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(), principalCache(),
                                                    primary() ? InputType::Primary : InputType::SecondarySource)),
     secondaryFileSequence_(catalog(1).empty() ? 0 :
                            new RootInputFileSequence(pset, *this, catalog(1), principalCache(), InputType::SecondaryFile)),
     secondaryRunPrincipal_(),
     secondaryLumiPrincipal_(),
     secondaryEventPrincipal_(secondaryFileSequence_ ? new EventPrincipal(secondaryFileSequence_->fileProductRegistry(), processConfiguration()) : 0),
     branchIDsToReplace_(),
     numberOfEventsBeforeBigSkip_(0) {
     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 102 of file PoolSource.cc.

102 {}

Member Function Documentation

void edm::PoolSource::closeFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 120 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 300 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 105 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 306 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 323 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->forwardState();
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 213 of file PoolSource.cc.

References edm::InputSource::decreaseRemainingEventsBy(), edm::InputSource::IsStop, numberOfEventsBeforeBigSkip_, or, primaryFileSequence_, edm::InputSource::principalCache(), receiver_, and edm::InputSource::remainingEvents().

                               {
     if(receiver_ &&
        0 == numberOfEventsBeforeBigSkip_) {
       receiver_->receive();
       unsigned long toSkip = receiver_->numberToSkip();
       if(0 != toSkip) {
         primaryFileSequence_->skipEvents(toSkip, principalCache());
         decreaseRemainingEventsBy(toSkip);
       }
       numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices();
       if(0 == numberOfEventsBeforeBigSkip_ or 0==remainingEvents()) {
         return IsStop;
       }
     }
     return primaryFileSequence_->getNextItemType();;
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 265 of file PoolSource.cc.

References primaryFileSequence_.

                                                {
     return primaryFileSequence_->goToEvent(eventID);
   }

void edm::PoolSource::postForkReacquireResources ( boost::shared_ptr< edm::multicore::MessageReceiverForSource > iReceiver )

privatevirtual

Definition at line 236 of file PoolSource.cc.

References edm::InputSource::decreaseRemainingEventsBy(), primaryFileSequence_, edm::InputSource::principalCache(), receiver_, and edm::InputSource::rewind().

                                                                                                         {
     receiver_ = iReceiver;
     receiver_->receive();
     primaryFileSequence_->reset(principalCache());
     rewind();
     decreaseRemainingEventsBy(receiver_->numberToSkip());
   }

void edm::PoolSource::preForkReleaseResources ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 231 of file PoolSource.cc.

References primaryFileSequence_.

                                       {
     primaryFileSequence_->closeFile_();
   }

bool edm::PoolSource::randomAccess_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 318 of file PoolSource.cc.

                                   {
     return true;
   }

EventPrincipal * edm::PoolSource::readEvent_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 180 of file PoolSource.cc.

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

Referenced by readIt().

                          {
     EventSourceSentry(*this);
     EventPrincipal* primaryPrincipal = primaryFileSequence_->readEvent(*eventPrincipalCache(), luminosityBlockPrincipal());
     if(secondaryFileSequence_ && !branchIDsToReplace_[InEvent].empty()) {
       bool found = secondaryFileSequence_->skipToItem(primaryPrincipal->run(),
                                                       primaryPrincipal->luminosityBlock(),
                                                       primaryPrincipal->id().event());
       if(found) {
         EventPrincipal* secondaryPrincipal = secondaryFileSequence_->readEvent(*secondaryEventPrincipal_, secondaryLumiPrincipal_);
         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";
       }
     }
     if(receiver_) {
       --numberOfEventsBeforeBigSkip_;
     }
     return primaryPrincipal;
   }

boost::shared_ptr< FileBlock > edm::PoolSource::readFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 112 of file PoolSource.cc.

References benchmark_cfg::fb, edm::FileBlock::HasSecondaryFileSequence, primaryFileSequence_, edm::InputSource::principalCache(), and secondaryFileSequence_.

                         {
     boost::shared_ptr<FileBlock> fb = primaryFileSequence_->readFile_(principalCache());
     if(secondaryFileSequence_) {
       fb->setNotFastClonable(FileBlock::HasSecondaryFileSequence);
     }
     return fb;
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 206 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_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 157 of file PoolSource.cc.

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

                                                                                     {
     if(secondaryFileSequence_ && !branchIDsToReplace_[InLumi].empty()) {
       boost::shared_ptr<LuminosityBlockPrincipal> primaryPrincipal = primaryFileSequence_->readLuminosityBlock_(lbCache);
       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(), secondaryRunPrincipal_));
         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_(lbCache);
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 130 of file PoolSource.cc.

References primaryFileSequence_.

                                             {
     return primaryFileSequence_->readLuminosityBlockAuxiliary_();
   }

EventPrincipal * edm::PoolSource::readOneRandom ( )

privatevirtual

Implements edm::VectorInputSource.

Definition at line 270 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 276 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

EventPrincipal * edm::PoolSource::readOneSequential ( )

privatevirtual

Implements edm::VectorInputSource.

Definition at line 282 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 288 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Implements edm::VectorInputSource.

Definition at line 294 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

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

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 135 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_(rpCache);
       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()));
         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_(rpCache);
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 125 of file PoolSource.cc.

References primaryFileSequence_.

                                 {
     return primaryFileSequence_->readRunAuxiliary_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 328 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->reverseState();
   }

void edm::PoolSource::rewind_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 246 of file PoolSource.cc.

References numberOfEventsBeforeBigSkip_, primaryFileSequence_, edm::InputSource::principalCache(), and receiver_.

                       {
     primaryFileSequence_->rewind_();
     if(receiver_) {
       unsigned int numberToSkip = receiver_->numberToSkip();
       if(0 != numberToSkip) {
         primaryFileSequence_->skipEvents(numberToSkip, principalCache());
       }
       numberOfEventsBeforeBigSkip_ = receiver_->numberOfConsecutiveIndices();
     }
 
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 260 of file PoolSource.cc.

References primaryFileSequence_, and edm::InputSource::principalCache().

                              {
     primaryFileSequence_->skipEvents(offset, principalCache());
   }

Member Data Documentation

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

private

Definition at line 69 of file PoolSource.h.

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

unsigned int edm::PoolSource::numberOfEventsBeforeBigSkip_

private

Definition at line 73 of file PoolSource.h.

Referenced by getNextItemType(), readEvent_(), and rewind_().

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

private

boost::shared_ptr<edm::multicore::MessageReceiverForSource> edm::PoolSource::receiver_

private

Definition at line 72 of file PoolSource.h.

Referenced by getNextItemType(), postForkReacquireResources(), readEvent_(), and rewind_().

RootServiceChecker edm::PoolSource::rootServiceChecker_

private

Definition at line 63 of file PoolSource.h.

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

private

Definition at line 68 of file PoolSource.h.

Referenced by readEvent_().

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

private

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

Referenced by readEvent_(), and readLuminosityBlock_().

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

private

Definition at line 66 of file PoolSource.h.

Referenced by readLuminosityBlock_(), and 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