#include <RawInputSource.h>

Inheritance diagram for edm::RawInputSource:

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

virtual	~RawInputSource ()

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

Protected Member Functions
std::auto_ptr< Event >	makeEvent (RunNumber_t run, LuminosityBlockNumber_t lumi, EventNumber_t event, Timestamp const &tstamp)

virtual std::auto_ptr< Event >	readOneEvent ()=0

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

Private Member Functions
virtual ItemType	getNextItemType ()

virtual EventPrincipal *	readEvent_ ()

virtual EventPrincipal *	readIt (EventID const &eventID)

virtual boost::shared_ptr < LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary_ ()

virtual boost::shared_ptr < RunAuxiliary >	readRunAuxiliary_ ()

virtual void	skip (int offset)

Private Attributes
bool	eventCached_

LuminosityBlockNumber_t	luminosityBlockNumber_

bool	newLumi_

bool	newRun_

RunNumber_t	runNumber_

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::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Detailed Description

Definition at line 18 of file RawInputSource.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 14 of file RawInputSource.cc.

References edm::Timestamp::beginOfTime(), and edm::InputSource::setTimestamp().

                                                                                              :
     InputSource(pset, desc),
     runNumber_(RunNumber_t()),
     luminosityBlockNumber_(),
     newRun_(false),
     newLumi_(false),
     eventCached_(false) {
       setTimestamp(Timestamp::beginOfTime());
   }

edm::RawInputSource::~RawInputSource ( )

virtual

Definition at line 24 of file RawInputSource.cc.

24 {

25 }

Member Function Documentation

InputSource::ItemType edm::RawInputSource::getNextItemType ( )

privatevirtual

Implements edm::InputSource.

Definition at line 67 of file RawInputSource.cc.

References alignCSCRings::e, eventCached_, edm::InputSource::IsEvent, edm::InputSource::IsFile, edm::InputSource::IsInvalid, edm::InputSource::IsLumi, edm::InputSource::IsRun, edm::InputSource::IsStop, luminosityBlockNumber_, newLumi_, newRun_, readOneEvent(), runNumber_, and edm::InputSource::state().

                                   {
     if(state() == IsInvalid) {
       return IsFile;
     }
     if(newRun_) {
       return IsRun;
     }
     if(newLumi_) {
       return IsLumi;
     }
     if(eventCached_) {
       return IsEvent;
     }
     std::auto_ptr<Event> e(readOneEvent());
     if(e.get() == 0) {
       return IsStop;
     } else {
       e->commit_();
     }
     if(e->run() != runNumber_) {
       newRun_ = newLumi_ = true;
       runNumber_ = e->run();
       luminosityBlockNumber_ = e->luminosityBlock();
       return IsRun;
     } else if(e->luminosityBlock() != luminosityBlockNumber_) {
       luminosityBlockNumber_ = e->luminosityBlock();
       newLumi_ = true;
       return IsLumi;
     }
     return IsEvent;
   }

std::auto_ptr< Event > edm::RawInputSource::makeEvent	(	RunNumber_t	run,
		LuminosityBlockNumber_t	lumi,
		EventNumber_t	event,
		Timestamp const &	tstamp
	)

protected

Definition at line 49 of file RawInputSource.cc.

References printConversionInfo::aux, alignCSCRings::e, eventCached_, edm::InputSource::eventPrincipalCache(), edm::EventPrincipal::fillEventPrincipal(), edm::Timestamp::invalidTimestamp(), edm::InputSource::luminosityBlockAuxiliary(), edm::InputSource::moduleDescription(), newLumi_, newRun_, edm::EventAuxiliary::PhysicsTrigger, edm::InputSource::processGUID(), edm::InputSource::runAuxiliary(), edm::InputSource::setLuminosityBlockAuxiliary(), and edm::InputSource::setRunAuxiliary().

Referenced by edm::DQMHttpSource::readOneEvent().

                                                                                                                        {
     if(!runAuxiliary()) {
       newRun_ = newLumi_ = true;
       setRunAuxiliary(new RunAuxiliary(run, tstamp, Timestamp::invalidTimestamp()));
     }
     if(!luminosityBlockAuxiliary()) {
       setLuminosityBlockAuxiliary(new LuminosityBlockAuxiliary(run, lumi, tstamp, Timestamp::invalidTimestamp()));
       newLumi_ = true;
     }
     EventSourceSentry sentry(*this);
     EventAuxiliary aux(EventID(run, lumi, event), processGUID(), tstamp, true, EventAuxiliary::PhysicsTrigger);
     eventPrincipalCache()->fillEventPrincipal(aux, boost::shared_ptr<LuminosityBlockPrincipal>());
     eventCached_ = true;
     std::auto_ptr<Event> e(new Event(*eventPrincipalCache(), moduleDescription()));
     return e;
   }

EventPrincipal * edm::RawInputSource::readEvent_ ( )

privatevirtual

Implements edm::InputSource.

Definition at line 41 of file RawInputSource.cc.

References eventCached_, edm::InputSource::eventPrincipalCache(), edm::InputSource::luminosityBlockPrincipal(), and edm::EventPrincipal::setLuminosityBlockPrincipal().

                              {
     assert(eventCached_);
     eventCached_ = false;
     eventPrincipalCache()->setLuminosityBlockPrincipal(luminosityBlockPrincipal());
     return eventPrincipalCache();
   }

EventPrincipal * edm::RawInputSource::readIt ( EventID const & eventID )

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 100 of file RawInputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

                                        {
       throw Exception(errors::LogicError, "RawInputSource::readEvent_(EventID const& eventID)")
         << "Random access read cannot be used for RawInputSource.\n"
         << "Contact a Framework developer.\n";
   }

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

privatevirtual

Implements edm::InputSource.

Definition at line 34 of file RawInputSource.cc.

References edm::Timestamp::invalidTimestamp(), luminosityBlockNumber_, newLumi_, runNumber_, and edm::InputSource::timestamp().

                                                 {
     newLumi_ = false;
     return boost::shared_ptr<LuminosityBlockAuxiliary>(new LuminosityBlockAuxiliary(
         runNumber_, luminosityBlockNumber_, timestamp(), Timestamp::invalidTimestamp()));
   }

virtual std::auto_ptr<Event> edm::RawInputSource::readOneEvent ( )

protectedpure virtual

Implemented in edm::DQMHttpSource.

Referenced by getNextItemType().

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

privatevirtual

Implements edm::InputSource.

Definition at line 28 of file RawInputSource.cc.

References edm::Timestamp::invalidTimestamp(), newRun_, runNumber_, and edm::InputSource::timestamp().

                                     {
     newRun_ = false;
     return boost::shared_ptr<RunAuxiliary>(new RunAuxiliary(runNumber_, timestamp(), Timestamp::invalidTimestamp()));
   }

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

privatevirtual

Reimplemented from edm::InputSource.

Definition at line 108 of file RawInputSource.cc.

References edm::hlt::Exception, and edm::errors::LogicError.

                           {
       throw Exception(errors::LogicError, "RawInputSource::skip(int offset)")
         << "Random access skip cannot be used for RawInputSource\n"
         << "Contact a Framework developer.\n";
   }