#include <LHESource.h>

Inheritance diagram for LHESource:

Public Member Functions
	LHESource (const edm::ParameterSet &params, const edm::InputSourceDescription &desc)

virtual	~LHESource ()

Public Member Functions inherited from edm::ProducerSourceFromFiles
virtual bool	noFiles () const override

	ProducerSourceFromFiles (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)

virtual	~ProducerSourceFromFiles ()

Public Member Functions inherited from edm::ProducerSourceBase
EventNumber_t	event () const

unsigned int	eventCreationDelay () const

EventID const &	eventID () const

LuminosityBlockNumber_t	luminosityBlock () const

unsigned int	numberEventsInLumi () const

unsigned int	numberEventsInRun () const

unsigned int	numberEventsInThisLumi () const

unsigned int	numberEventsInThisRun () const

TimeValue_t	presentTime () const

	ProducerSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)

RunNumber_t	run () const

unsigned int	timeBetweenEvents () const

virtual	~ProducerSourceBase ()

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

Private Member Functions
virtual void	beginRun (edm::Run &run) override

virtual void	endJob () override

virtual void	endRun (edm::Run &run) override

void	nextEvent ()

virtual void	produce (edm::Event &)

virtual edm::EventPrincipal *	readEvent_ (edm::EventPrincipal &eventPrincipal) override

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

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

virtual bool	setRunAndEventInfo (edm::EventID &, edm::TimeValue_t &) override

Private Attributes
edm::LHEProvenanceHelper	lheProvenanceHelper_

boost::shared_ptr< lhef::LHEEvent >	partonLevel

edm::ProcessHistoryID	phid_

std::auto_ptr< lhef::LHEReader >	reader

boost::shared_ptr < lhef::LHERunInfo >	runInfo

boost::shared_ptr < lhef::LHERunInfo >	runInfoLast

boost::ptr_deque < LHERunInfoProduct >	runInfoProducts

boost::shared_ptr < edm::RunPrincipal >	runPrincipal_

bool	wasMerged

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

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

Static Public Member Functions inherited from edm::ProducerSourceBase
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 &)

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 31 of file LHESource.h.

Constructor & Destructor Documentation

LHESource::LHESource	(	const edm::ParameterSet &	params,
		const edm::InputSourceDescription &	desc
	)

explicit

Definition at line 33 of file LHESource.cc.

References edm::LHEProvenanceHelper::lheAugment(), edm::LHEProvenanceHelper::lheInit(), lheProvenanceHelper_, nextEvent(), phid_, edm::InputSource::productRegistryUpdate(), and runInfo.

                                                             :
     ProducerSourceFromFiles(params, desc, false),
     reader(new LHEReader(fileNames(), params.getUntrackedParameter<unsigned int>("skipEvents", 0))),
     wasMerged(false),
     lheProvenanceHelper_(edm::TypeID(typeid(LHEEventProduct)), edm::TypeID(typeid(LHERunInfoProduct))),
     phid_(),
         runPrincipal_()
 {
         nextEvent();
         lheProvenanceHelper_.lheAugment(runInfo.get());
     // Initialize metadata, and save the process history ID for use every event.
     phid_ = lheProvenanceHelper_.lheInit(productRegistryUpdate());
 
         // These calls are not wanted, because the principals are used for putting the products.
     //produces<LHEEventProduct>();
     //produces<LHERunInfoProduct, edm::InRun>();
 }

LHESource::~LHESource ( )

virtual

Definition at line 52 of file LHESource.cc.

53 {

54 }

Member Function Documentation

void LHESource::beginRun ( edm::Run & run )

overrideprivatevirtual

Reimplemented from edm::ProducerSourceBase.

Definition at line 98 of file LHESource.cc.

References LHERunInfoProduct::addComment(), LHERunInfoProduct::addHeader(), lheProvenanceHelper_, runInfo, runInfoLast, runInfoProducts, runPrincipal_, edm::LHEProvenanceHelper::runProductBranchDescription_, and wasMerged.

 {
     if (runInfoLast) {
         runInfo = runInfoLast;
 
         std::auto_ptr<LHERunInfoProduct> product(
                 new LHERunInfoProduct(*runInfo->getHEPRUP()));
         std::for_each(runInfo->getHeaders().begin(),
                       runInfo->getHeaders().end(),
                       boost::bind(
                         &LHERunInfoProduct::addHeader,
                         product.get(), _1));
         std::for_each(runInfo->getComments().begin(),
                       runInfo->getComments().end(),
                       boost::bind(&LHERunInfoProduct::addComment,
                         product.get(), _1));
 
         // keep a copy around in case of merging
         runInfoProducts.push_back(new LHERunInfoProduct(*product));
         wasMerged = false;
 
                 edm::WrapperOwningHolder rdp(new edm::Wrapper<LHERunInfoProduct>(product), edm::Wrapper<LHERunInfoProduct>::getInterface());
         runPrincipal_->put(lheProvenanceHelper_.runProductBranchDescription_, rdp);
 
         runInfo.reset();
     }
 }

void LHESource::endJob ( void )

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 56 of file LHESource.cc.

References reader.

 {
     reader.reset();
 }

void LHESource::endRun ( edm::Run & run )

overrideprivatevirtual

Reimplemented from edm::ProducerSourceBase.

Definition at line 126 of file LHESource.cc.

References lheProvenanceHelper_, runInfoProducts, runPrincipal_, and edm::LHEProvenanceHelper::runProductBranchDescription_.

 {
     if (!runInfoProducts.empty()) {
         std::auto_ptr<LHERunInfoProduct> product(
                     runInfoProducts.pop_front().release());
                 edm::WrapperOwningHolder rdp(new edm::Wrapper<LHERunInfoProduct>(product), edm::Wrapper<LHERunInfoProduct>::getInterface());
         runPrincipal_->put(lheProvenanceHelper_.runProductBranchDescription_, rdp);
     }
     runPrincipal_.reset();
 }

void LHESource::nextEvent ( )

private

Definition at line 61 of file LHESource.cc.

References edm::FromFiles::incrementFileIndex(), partonLevel, reader, runInfo, and runInfoLast.

Referenced by LHESource(), and setRunAndEventInfo().

 {
     if (partonLevel) {
         return;
         }
 
     bool newFileOpened = false;
     partonLevel = reader->next(&newFileOpened);
 
     if(newFileOpened) incrementFileIndex();
     if (!partonLevel) {
         return;
         }
 
     boost::shared_ptr<LHERunInfo> runInfoThis = partonLevel->getRunInfo();
     if (runInfoThis != runInfoLast) {
         runInfo = runInfoThis;
         runInfoLast = runInfoThis;
     }
 }

virtual void LHESource::produce ( edm::Event & )

inlineprivatevirtual

Implements edm::ProducerSourceBase.

Definition at line 45 of file LHESource.h.

45 {}

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

overrideprivatevirtual

Reimplemented from edm::ProducerSourceBase.

Definition at line 147 of file LHESource.cc.

References LHEEventProduct::addComment(), LHERunInfoProduct::addComment(), LHERunInfoProduct::addHeader(), LHEEventProduct::addWeight(), printConversionInfo::aux, edm::InputSource::eventCached(), edm::ProducerSourceBase::eventID(), edm::LHEProvenanceHelper::eventProductBranchDescription_, edm::LHEProvenanceHelper::eventProductProvenance_, edm::EventPrincipal::fillEventPrincipal(), lheProvenanceHelper_, partonLevel, phid_, edm::ProducerSourceBase::presentTime(), edm::InputSource::processGUID(), edm::InputSource::processingMode(), edm::EventPrincipal::put(), edm::InputSource::resetEventCached(), runInfo, runInfoProducts, edm::InputSource::RunsLumisAndEvents, edm::EventAuxiliary::setProcessHistoryID(), and wasMerged.

                                                        {
     assert(eventCached() || processingMode() != RunsLumisAndEvents);
     EventSourceSentry sentry(*this);
     edm::EventAuxiliary aux(eventID(), processGUID(), edm::Timestamp(presentTime()), false);
     aux.setProcessHistoryID(phid_);
     eventPrincipal.fillEventPrincipal(aux);
 
     std::auto_ptr<LHEEventProduct> product(
              new LHEEventProduct(*partonLevel->getHEPEUP(),
                      partonLevel->originalXWGTUP())
              );
     if (partonLevel->getPDF()) {
         product->setPDF(*partonLevel->getPDF());
         }       
     std::for_each(partonLevel->weights().begin(),
               partonLevel->weights().end(),
               boost::bind(&LHEEventProduct::addWeight,
                   product.get(), _1));
     std::for_each(partonLevel->getComments().begin(),
                   partonLevel->getComments().end(),
                   boost::bind(&LHEEventProduct::addComment,
                               product.get(), _1));
 
     edm::WrapperOwningHolder edp(new edm::Wrapper<LHEEventProduct>(product), edm::Wrapper<LHEEventProduct>::getInterface());
     eventPrincipal.put(lheProvenanceHelper_.eventProductBranchDescription_, edp, lheProvenanceHelper_.eventProductProvenance_);
 
     if (runInfo) {
         std::auto_ptr<LHERunInfoProduct> product(
                 new LHERunInfoProduct(*runInfo->getHEPRUP()));
         std::for_each(runInfo->getHeaders().begin(),
                       runInfo->getHeaders().end(),
                       boost::bind(
                         &LHERunInfoProduct::addHeader,
                         product.get(), _1));
         std::for_each(runInfo->getComments().begin(),
                       runInfo->getComments().end(),
                       boost::bind(&LHERunInfoProduct::addComment,
                         product.get(), _1));
 
         if (!runInfoProducts.empty()) {
             runInfoProducts.front().mergeProduct(*product);
             if (!wasMerged) {
                 runInfoProducts.pop_front();
                 runInfoProducts.push_front(product);
                 wasMerged = true;
             }
         }
 
         runInfo.reset();
     }
 
     partonLevel.reset();
 
     resetEventCached();
     return &eventPrincipal;
 }

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 92 of file LHESource.cc.

References edm::InputSource::luminosityBlockAuxiliary(), and phid_.

                                                                                           {
   luminosityBlockAuxiliary()->setProcessHistoryID(phid_);
   lumiPrincipal->fillLuminosityBlockPrincipal();
   return lumiPrincipal;
 }

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

overrideprivatevirtual

Reimplemented from edm::InputSource.

Definition at line 84 of file LHESource.cc.

References phid_, edm::InputSource::runAuxiliary(), edm::InputSource::runPrincipal(), and runPrincipal_.

                                                                  {
   runAuxiliary()->setProcessHistoryID(phid_);
   runPrincipal->fillRunPrincipal();
   runPrincipal_ = runPrincipal;
   return runPrincipal;
 }

bool LHESource::setRunAndEventInfo	(	edm::EventID &	,
		edm::TimeValue_t &
	)

overrideprivatevirtual

Implements edm::ProducerSourceBase.

Definition at line 137 of file LHESource.cc.

References nextEvent(), and partonLevel.

 {
     nextEvent();
     if (!partonLevel) {
         return false;
         }
         return true;
 }

Member Data Documentation

edm::LHEProvenanceHelper LHESource::lheProvenanceHelper_

private

Definition at line 57 of file LHESource.h.

Referenced by beginRun(), endRun(), LHESource(), and readEvent_().

boost::shared_ptr<lhef::LHEEvent> LHESource::partonLevel

private

Definition at line 53 of file LHESource.h.

Referenced by nextEvent(), readEvent_(), and setRunAndEventInfo().

edm::ProcessHistoryID LHESource::phid_

private

Definition at line 58 of file LHESource.h.

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

std::auto_ptr<lhef::LHEReader> LHESource::reader

private

Definition at line 49 of file LHESource.h.

Referenced by endJob(), and nextEvent().

boost::shared_ptr<lhef::LHERunInfo> LHESource::runInfo

private

Definition at line 52 of file LHESource.h.

Referenced by beginRun(), LHESource(), nextEvent(), and readEvent_().

boost::shared_ptr<lhef::LHERunInfo> LHESource::runInfoLast

private

Definition at line 51 of file LHESource.h.

Referenced by beginRun(), and nextEvent().

boost::ptr_deque<LHERunInfoProduct> LHESource::runInfoProducts

private

Definition at line 55 of file LHESource.h.

Referenced by beginRun(), endRun(), and readEvent_().

boost::shared_ptr<edm::RunPrincipal> LHESource::runPrincipal_

private

Definition at line 59 of file LHESource.h.

Referenced by beginRun(), endRun(), and readRun_().

bool LHESource::wasMerged

private

Definition at line 56 of file LHESource.h.

Referenced by beginRun(), and readEvent_().

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation