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

void	readMany (int number, EventPrincipalVector &result)

void	readManyRandom (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)

void	readManySequential (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)

void	readManySpecified (std::vector< EventID > const &events, EventPrincipalVector &result)

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

void	doEndRun (RunPrincipal &rp)
	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 const	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...

ProcessHistoryID const &	processHistoryID () const
	Accessor for the input process history ID of the current run. 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 ()
	Read next luminosity block. More...

void	readAndCacheRun ()
	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...

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

void	wakeUp ()
	Wake up 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)

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 void	readMany_ (int number, EventPrincipalVector &result)

virtual void	readManyRandom_ (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)

virtual void	readManySequential_ (int number, EventPrincipalVector &result, unsigned int &fileSeqNumber)

virtual void	readManySpecified_ (std::vector< EventID > const &events, EventPrincipalVector &result)

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
boost::array< std::vector < BranchID >, NumBranchTypes >	branchIDsToReplace_

unsigned int	numberOfEventsBeforeBigSkip_

boost::scoped_ptr < RootInputFileSequence >	primaryFileSequence_

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

RootServiceChecker	rootServiceChecker_

boost::scoped_ptr< EventPrincipal >	secondaryEventPrincipal_

boost::scoped_ptr < RootInputFileSequence >	secondaryFileSequence_

boost::shared_ptr < LuminosityBlockPrincipal >	secondaryLumiPrincipal_

boost::shared_ptr< RunPrincipal >	secondaryRunPrincipal_

Additional Inherited Members
Public Types inherited from edm::VectorInputSource
typedef std::vector < EventPrincipalVectorElement >	EventPrincipalVector

typedef boost::shared_ptr < EventPrincipal >	EventPrincipalVectorElement

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 *const	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	setLumiPrematurelyRead ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setRunPrematurelyRead ()

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 52 of file PoolSource.cc.

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

                                                                                      :
     VectorInputSource(pset, desc),
     rootServiceChecker_(),
     primaryFileSequence_(new RootInputFileSequence(pset, *this, catalog(), principalCache(), primary())),
     secondaryFileSequence_(catalog(1).empty() ? 0 :
                            new RootInputFileSequence(pset, *this, catalog(1), principalCache(), false)),
     secondaryRunPrincipal_(),
     secondaryLumiPrincipal_(),
     secondaryEventPrincipal_(secondaryFileSequence_ ? new EventPrincipal(secondaryFileSequence_->fileProductRegistry(), processConfiguration()) : 0),
     branchIDsToReplace_(),
     numberOfEventsBeforeBigSkip_(0)
   {
     if (secondaryFileSequence_) {
       boost::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 100 of file PoolSource.cc.

100 {}

Member Function Documentation

void edm::PoolSource::closeFile_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 117 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 290 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 103 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                      {
     if (secondaryFileSequence_) secondaryFileSequence_->endJob();
     primaryFileSequence_->endJob();
   }

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

static

Definition at line 296 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 313 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 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 261 of file PoolSource.cc.

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

                                                {
     return primaryFileSequence_->goToEvent(eventID, principalCache());
   }

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

privatevirtual

Definition at line 232 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 227 of file PoolSource.cc.

References primaryFileSequence_.

                                       {
     primaryFileSequence_->closeFile_();
   }

bool edm::PoolSource::randomAccess_ ( ) const

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 308 of file PoolSource.cc.

                                   {
     return true;
   }

EventPrincipal * edm::PoolSource::readEvent_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 177 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::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]);
         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 109 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 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_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 154 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 127 of file PoolSource.cc.

References primaryFileSequence_.

                                             {
     return primaryFileSequence_->readLuminosityBlockAuxiliary_();
   }

void edm::PoolSource::readMany_	(	int	number,
		EventPrincipalVector &	result
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 266 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                 {
     assert (!secondaryFileSequence_);
     primaryFileSequence_->readMany(number, result);
   }

void edm::PoolSource::readManyRandom_	(	int	number,
		EventPrincipalVector &	result,
		unsigned int &	fileSeqNumber
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 272 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                                    {
     assert (!secondaryFileSequence_);
     primaryFileSequence_->readManyRandom(number, result, fileSeqNumber);
   }

void edm::PoolSource::readManySequential_	(	int	number,
		EventPrincipalVector &	result,
		unsigned int &	fileSeqNumber
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 278 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                                        {
     assert (!secondaryFileSequence_);
     primaryFileSequence_->readManySequential(number, result, fileSeqNumber);
   }

void edm::PoolSource::readManySpecified_	(	std::vector< EventID > const &	events,
		EventPrincipalVector &	result
	)

privatevirtual

Implements edm::VectorInputSource.

Definition at line 284 of file PoolSource.cc.

References primaryFileSequence_, and secondaryFileSequence_.

                                                                                                {
     assert (!secondaryFileSequence_);
     primaryFileSequence_->readManySpecified(events, result);
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 132 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 122 of file PoolSource.cc.

References primaryFileSequence_.

                                 {
     return primaryFileSequence_->readRunAuxiliary_();
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 318 of file PoolSource.cc.

References primaryFileSequence_.

                                   {
     return primaryFileSequence_->reverseState();
   }

void edm::PoolSource::rewind_ ( )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 242 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 256 of file PoolSource.cc.

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

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

Member Data Documentation

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

private

Definition at line 68 of file PoolSource.h.

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

unsigned int edm::PoolSource::numberOfEventsBeforeBigSkip_

private

Definition at line 72 of file PoolSource.h.

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

boost::scoped_ptr<RootInputFileSequence> edm::PoolSource::primaryFileSequence_

private

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

private

Definition at line 71 of file PoolSource.h.

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

RootServiceChecker edm::PoolSource::rootServiceChecker_

private

Definition at line 62 of file PoolSource.h.

boost::scoped_ptr<EventPrincipal> edm::PoolSource::secondaryEventPrincipal_

private

Definition at line 67 of file PoolSource.h.

Referenced by readEvent_().

boost::scoped_ptr<RootInputFileSequence> edm::PoolSource::secondaryFileSequence_

private

Definition at line 64 of file PoolSource.h.

Referenced by dropUnwantedBranches_(), endJob(), PoolSource(), readEvent_(), readFile_(), readLuminosityBlock_(), readMany_(), readManyRandom_(), readManySequential_(), readManySpecified_(), and readRun_().

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

private

Definition at line 66 of file PoolSource.h.

Referenced by readEvent_(), and readLuminosityBlock_().

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

private

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