#include "DecrepitRelicInputSourceImplementation.h"

Inheritance diagram for art::DecrepitRelicInputSourceImplementation:

Classes
struct	Config

Public Types
enum	ProcessingMode { Runs, RunsAndSubRuns, RunsSubRunsAndEvents }

Public Member Functions
	DecrepitRelicInputSourceImplementation (DecrepitRelicInputSourceImplementation const &)=delete

DecrepitRelicInputSourceImplementation &	operator= (DecrepitRelicInputSourceImplementation const &)=delete

	DecrepitRelicInputSourceImplementation (fhicl::TableFragment< Config > const &, ModuleDescription const &)

virtual	~DecrepitRelicInputSourceImplementation () noexcept=0

input::ItemType	nextItemType () override

std::unique_ptr< EventPrincipal >	readEvent (cet::exempt_ptr< SubRunPrincipal const > srp) override

std::unique_ptr< EventPrincipal >	readEvent (EventID const &) override
	Read a specific event. More...

std::unique_ptr< SubRunPrincipal >	readSubRun (cet::exempt_ptr< RunPrincipal const > rp) override
	Read next subRun. More...

std::unique_ptr< RunPrincipal >	readRun () override
	Read next run. More...

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

void	closeFile () override
	close current file More...

void	skipEvents (int offset) override

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

void	issueReports (EventID const &eventID)
	issue an event report More...

void	repeat_ ()
	Reset the remaining number of events/subRuns to the maximum number. More...

int	maxEvents () const

int	remainingEvents () const

int	maxSubRuns () const

int	remainingSubRuns () const

void	doBeginJob () override
	Called by framework at beginning of job. More...

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

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

ProcessingMode	processingMode () const
	RunsSubRunsAndEvents (default), RunsAndSubRuns, or Runs. More...

auto const &	moduleDescription () const

auto const &	processConfiguration () const

virtual std::unique_ptr< RangeSetHandler >	runRangeSetHandler ()=0

virtual std::unique_ptr< RangeSetHandler >	subRunRangeSetHandler ()=0

Protected Member Functions
void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

input::ItemType	state () const

virtual void	finish ()

cet::exempt_ptr< RunPrincipal >	runPrincipalExemptPtr ()

cet::exempt_ptr< SubRunPrincipal >	subRunPrincipalExemptPtr ()

std::unique_ptr< RunPrincipal >	runPrincipal ()

std::unique_ptr< SubRunPrincipal >	subRunPrincipal ()

std::unique_ptr< EventPrincipal >	eventPrincipal ()

void	setRunPrincipal (std::unique_ptr< RunPrincipal > &&rp)

void	setSubRunPrincipal (std::unique_ptr< SubRunPrincipal > &&srp)

void	setEventPrincipal (std::unique_ptr< EventPrincipal > &&ep)

void	resetRunPrincipal ()

void	resetSubRunPrincipal ()

void	resetEventPrincipal ()

void	reset ()

Private Member Functions
bool	eventLimitReached () const

bool	subRunLimitReached () const

bool	limitReached () const

virtual input::ItemType	getNextItemType ()=0

input::ItemType	nextItemType_ ()

virtual std::unique_ptr< RunPrincipal >	readRun_ ()=0

virtual std::unique_ptr< SubRunPrincipal >	readSubRun_ ()=0

virtual std::unique_ptr< EventPrincipal >	readEvent_ ()=0

virtual std::unique_ptr< FileBlock >	readFile_ ()

virtual void	closeFile_ ()

virtual void	skip (int)

virtual void	rewind_ ()

virtual void	beginJob ()

virtual void	endJob ()

Private Attributes
int	maxEvents_

int	maxSubRuns_

int const	reportFrequency_

int	remainingEvents_ {maxEvents_}

int	remainingSubRuns_ {maxSubRuns_}

int	readCount_ {}

ProcessingMode	processingMode_ {RunsSubRunsAndEvents}

Timestamp	time_ {Timestamp::invalidTimestamp()}

bool	doneReadAhead_ {false}

input::ItemType	state_ {input::IsInvalid}

std::unique_ptr< RunPrincipal >	runPrincipal_ {nullptr}

std::unique_ptr< SubRunPrincipal >	subRunPrincipal_ {nullptr}

std::unique_ptr< EventPrincipal >	eventPrincipal_ {nullptr}

cet::exempt_ptr< RunPrincipal >	cachedRunPrincipal_ {nullptr}

cet::exempt_ptr< SubRunPrincipal >	cachedSubRunPrincipal_ {nullptr}

Detailed Description

Definition at line 67 of file DecrepitRelicInputSourceImplementation.h.

Member Enumeration Documentation

enum art::InputSource::ProcessingMode

inherited

Enumerator
Runs
RunsAndSubRuns
RunsSubRunsAndEvents

Definition at line 52 of file InputSource.h.

52 { Runs, RunsAndSubRuns, RunsSubRunsAndEvents };

art::InputSource::RunsSubRunsAndEvents

Definition: InputSource.h:52

art::InputSource::Runs

Definition: InputSource.h:52

art::InputSource::RunsAndSubRuns

Definition: InputSource.h:52

Constructor & Destructor Documentation

art::DecrepitRelicInputSourceImplementation::DecrepitRelicInputSourceImplementation ( DecrepitRelicInputSourceImplementation const & )

delete

art::DecrepitRelicInputSourceImplementation::DecrepitRelicInputSourceImplementation	(	fhicl::TableFragment< Config > const &	config,
		ModuleDescription const &	desc
	)

Definition at line 58 of file DecrepitRelicInputSourceImplementation.cc.

References art::errors::Configuration, art::DecrepitRelicInputSourceImplementation::Config::defaultMode(), maxEvents_, maxSubRuns_, processingMode(), processingMode_, reportFrequency_, art::InputSource::Runs, and art::InputSource::RunsAndSubRuns.

     : InputSource{desc}
     , maxEvents_{config().maxEvents()}
     , maxSubRuns_{config().maxSubRuns()}
     , reportFrequency_{config().reportFrequency()}
   {
     if (reportFrequency_ < 0) {
       throw art::Exception(art::errors::Configuration)
         << "reportFrequency has a negative value, which is not meaningful.";
     }
     std::string const runMode{"Runs"};
     std::string const runSubRunMode{"RunsAndSubRuns"};
     std::string const processingMode = config().processingMode();
     if (processingMode == runMode) {
       processingMode_ = Runs;
     } else if (processingMode == runSubRunMode) {
       processingMode_ = RunsAndSubRuns;
     } else if (processingMode != Config::defaultMode()) {
       throw art::Exception(art::errors::Configuration)
         << "DecrepitRelicInputSourceImplementation::"
            "DecrepitRelicInputSourceImplementation()\n"
         << "The 'processingMode' parameter for sources has an illegal value '"
         << processingMode << "'\n"
         << "Legal values are '" << Config::defaultMode() << "', '"
         << runSubRunMode << "', or '" << runMode << "'.\n";
     }
   }

art::DecrepitRelicInputSourceImplementation::~DecrepitRelicInputSourceImplementation ( )

pure virtualnoexcept

Definition at line 52 of file DecrepitRelicInputSourceImplementation.cc.

53 {}

Member Function Documentation

void art::DecrepitRelicInputSourceImplementation::beginJob ( )

privatevirtual

Reimplemented in art::EmptyEvent.

Definition at line 343 of file DecrepitRelicInputSourceImplementation.cc.

Referenced by closeFile_(), and doBeginJob().

344 {}

void art::DecrepitRelicInputSourceImplementation::closeFile ( )

overridevirtual

close current file

Implements art::InputSource.

Definition at line 225 of file DecrepitRelicInputSourceImplementation.cc.

References closeFile_().

   {
     return closeFile_();
   }

virtual void art::DecrepitRelicInputSourceImplementation::closeFile_ ( )

inlineprivatevirtual

Reimplemented in art::RootInput.

Definition at line 301 of file DecrepitRelicInputSourceImplementation.h.

References beginJob(), endJob(), rewind_(), and skip().

Referenced by closeFile().

302 {}

void art::DecrepitRelicInputSourceImplementation::doBeginJob ( )

overridevirtual

Called by framework at beginning of job.

Reimplemented from art::InputSource.

Definition at line 202 of file DecrepitRelicInputSourceImplementation.cc.

References beginJob().

Referenced by remainingSubRuns().

   {
     beginJob();
   }

void art::DecrepitRelicInputSourceImplementation::doEndJob ( )

overridevirtual

Called by framework at end of job.

Reimplemented from art::InputSource.

Definition at line 208 of file DecrepitRelicInputSourceImplementation.cc.

References endJob().

Referenced by remainingSubRuns().

   {
     endJob();
   }

void art::DecrepitRelicInputSourceImplementation::endJob ( )

privatevirtual

Reimplemented in art::RootInput, and art::EmptyEvent.

Definition at line 347 of file DecrepitRelicInputSourceImplementation.cc.

Referenced by closeFile_(), and doEndJob().

348 {}

bool art::DecrepitRelicInputSourceImplementation::eventLimitReached ( ) const

inlineprivate

Definition at line 280 of file DecrepitRelicInputSourceImplementation.h.

References remainingEvents_.

Referenced by limitReached(), nextItemType(), and readEvent().

     {
       return remainingEvents_ == 0;
     }

std::unique_ptr<EventPrincipal> art::DecrepitRelicInputSourceImplementation::eventPrincipal ( )

inlineprotected

Definition at line 248 of file DecrepitRelicInputSourceImplementation.h.

References eventPrincipal_, setEventPrincipal(), setRunPrincipal(), and setSubRunPrincipal().

Referenced by art::RootInput::readEvent_().

     {
       return std::move(eventPrincipal_);
     }

virtual void art::DecrepitRelicInputSourceImplementation::finish ( )

inlineprotectedvirtual

Reimplemented in art::RootInput.

Definition at line 219 of file DecrepitRelicInputSourceImplementation.h.

Referenced by nextItemType().

220 {}

virtual input::ItemType art::DecrepitRelicInputSourceImplementation::getNextItemType ( )

privatepure virtual

Implemented in art::RootInput, and art::EmptyEvent.

Referenced by limitReached(), and nextItemType_().

void art::DecrepitRelicInputSourceImplementation::issueReports ( EventID const & eventID )

issue an event report

Definition at line 313 of file DecrepitRelicInputSourceImplementation.cc.

References readCount_.

Referenced by readEvent(), and rewind().

   {
     time_t t = time(0);
     char ts[] = "dd-Mon-yyyy hh:mm:ss TZN     ";
     strftime(ts, strlen(ts) + 1, "%d-%b-%Y %H:%M:%S %Z", localtime(&t));
     mf::LogVerbatim("ArtReport")
       << "Begin processing the " << readCount_ << suffix(readCount_)
       << " record. " << eventID << " at " << ts;
     // At some point we may want to initiate checkpointing here
   }

bool art::DecrepitRelicInputSourceImplementation::limitReached ( ) const

inlineprivate

Definition at line 290 of file DecrepitRelicInputSourceImplementation.h.

References eventLimitReached(), getNextItemType(), nextItemType_(), readEvent_(), readFile_(), readRun_(), readSubRun_(), and subRunLimitReached().

Referenced by readFile(), readRun(), and readSubRun().

     {
       return eventLimitReached() || subRunLimitReached();
     }

int art::DecrepitRelicInputSourceImplementation::maxEvents ( ) const

inline

Accessor for maximum number of events to be read. -1 is used for unlimited.

Definition at line 153 of file DecrepitRelicInputSourceImplementation.h.

References maxEvents_.

     {
       return maxEvents_;
     }

int art::DecrepitRelicInputSourceImplementation::maxSubRuns ( ) const

inline

Accessor for maximum number of subRuns to be read. -1 is used for unlimited.

Definition at line 169 of file DecrepitRelicInputSourceImplementation.h.

References maxSubRuns_.

     {
       return maxSubRuns_;
     }

auto const& art::InputSource::moduleDescription ( ) const

inlineinherited

Definition at line 59 of file InputSource.h.

Referenced by art::EmptyEvent::readRun_(), and art::EmptyEvent::readSubRun_().

     {
       return moduleDescription_;
     }

input::ItemType art::DecrepitRelicInputSourceImplementation::nextItemType ( )

overridevirtual

Implements art::InputSource.

Reimplemented in art::RootInput.

Definition at line 140 of file DecrepitRelicInputSourceImplementation.cc.

References doneReadAhead_, eventLimitReached(), finish(), art::input::IsEvent, art::input::IsFile, art::input::IsInvalid, art::input::IsRun, art::input::IsStop, art::input::IsSubRun, nextItemType_(), processingMode(), readRun_(), readSubRun_(), runPrincipal_, art::InputSource::Runs, art::InputSource::RunsSubRunsAndEvents, state_, subRunLimitReached(), and subRunPrincipal_.

Referenced by art::RootInput::nextItemType().

   {
     if (doneReadAhead_) {
       return state_;
     }
     doneReadAhead_ = true;
     input::ItemType oldState = state_;
     if (eventLimitReached()) {
       // If the maximum event limit has been reached, stop.
       state_ = input::IsStop;
     } else if (subRunLimitReached()) {
       // If the maximum subRun limit has been reached, stop
       // when reaching a new file, run, or subRun.
       if (oldState == input::IsInvalid || oldState == input::IsFile ||
           oldState == input::IsRun ||
           processingMode() != RunsSubRunsAndEvents) {
         state_ = input::IsStop;
       } else {
         input::ItemType newState = nextItemType_();
         if (newState == input::IsEvent) {
           assert(processingMode() == RunsSubRunsAndEvents);
           state_ = input::IsEvent;
         } else {
           state_ = input::IsStop;
         }
       }
     } else {
       input::ItemType newState = nextItemType_();
       if (newState == input::IsStop) {
         state_ = input::IsStop;
       } else if (newState == input::IsFile || oldState == input::IsInvalid) {
         state_ = input::IsFile;
       } else if (newState == input::IsRun || oldState == input::IsFile) {
         runPrincipal_ = readRun_();
         state_ = input::IsRun;
       } else if (newState == input::IsSubRun || oldState == input::IsRun) {
         assert(processingMode() != Runs);
         subRunPrincipal_ = readSubRun_();
         state_ = input::IsSubRun;
       } else {
         assert(processingMode() == RunsSubRunsAndEvents);
         state_ = input::IsEvent;
       }
     }
     if (state_ == input::IsStop) {
       subRunPrincipal_.reset();
       runPrincipal_.reset();
       // FIXME: upon the advent of a catalog system which can do
       // something intelligent with the difference between whole-file
       // success, partial-file success, partial-file failure and
       // whole-file failure (such as file-open failure), we will need to
       // communicate that difference here. The file disposition options
       // as they are now (and the mapping to any concrete implementation
       // we are are aware of currently) are not sufficient to the task,
       // so we deliberately do not distinguish here between partial-file
       // and whole-file success in particular.
       finish();
     }
     return state_;
   }

input::ItemType art::DecrepitRelicInputSourceImplementation::nextItemType_ ( )

private

Definition at line 124 of file DecrepitRelicInputSourceImplementation.cc.

References getNextItemType(), art::input::IsEvent, art::input::IsSubRun, processingMode(), readEvent_(), readSubRun_(), art::InputSource::Runs, and art::InputSource::RunsSubRunsAndEvents.

Referenced by limitReached(), and nextItemType().

   {
     input::ItemType itemType = getNextItemType();
     if (itemType == input::IsEvent &&
         processingMode() != RunsSubRunsAndEvents) {
       readEvent_();
       return nextItemType_();
     }
     if (itemType == input::IsSubRun && processingMode() == Runs) {
       readSubRun_();
       return nextItemType_();
     }
     return itemType;
   }

DecrepitRelicInputSourceImplementation& art::DecrepitRelicInputSourceImplementation::operator= ( DecrepitRelicInputSourceImplementation const & )

delete

auto const& art::InputSource::processConfiguration ( ) const

inlineinherited

Definition at line 64 of file InputSource.h.

References n.

Referenced by art::EmptyEvent::readRun_(), art::EmptyEvent::readSubRun_(), art::EmptyEvent::reallyReadEvent(), and art::RootInput::RootInput().

     {
       return moduleDescription_.processConfiguration();
     }

ProcessingMode art::DecrepitRelicInputSourceImplementation::processingMode ( ) const

inline

RunsSubRunsAndEvents (default), RunsAndSubRuns, or Runs.

Definition at line 197 of file DecrepitRelicInputSourceImplementation.h.

References processingMode_.

Referenced by DecrepitRelicInputSourceImplementation(), art::EmptyEvent::getNextItemType(), nextItemType(), nextItemType_(), art::EmptyEvent::readEvent_(), art::EmptyEvent::readSubRun_(), art::EmptyEvent::reallyReadEvent(), and art::RootInput::RootInput().

     {
       return processingMode_;
     }

std::unique_ptr< EventPrincipal > art::DecrepitRelicInputSourceImplementation::readEvent ( cet::exempt_ptr< SubRunPrincipal const > srp )

overridevirtual

Read next event Indicate inability to get a new event by returning a null unique_ptr.

Implements art::InputSource.

Reimplemented in art::RootInput.

Definition at line 273 of file DecrepitRelicInputSourceImplementation.cc.

References doneReadAhead_, eventLimitReached(), eventPrincipal_, art::input::IsEvent, issueReports(), readCount_, readEvent_(), remainingEvents_, reportFrequency_, setTimestamp(), and state_.

Referenced by art::RootInput::readEvent_().

   {
     assert(doneReadAhead_);
     assert(state_ == input::IsEvent);
     assert(!eventLimitReached());
     doneReadAhead_ = false;
 
     eventPrincipal_ = readEvent_();
     assert(srp->run() == eventPrincipal_->run());
     assert(srp->subRun() == eventPrincipal_->subRun());
     eventPrincipal_->setSubRunPrincipal(srp);
     if (eventPrincipal_.get() != nullptr) {
       if (remainingEvents_ > 0)
         --remainingEvents_;
       ++readCount_;
       setTimestamp(eventPrincipal_->time());
       if ((reportFrequency_ > 0) && !(readCount_ % reportFrequency_)) {
         issueReports(eventPrincipal_->id());
       }
     }
     return std::move(eventPrincipal_);
   }

std::unique_ptr< EventPrincipal > art::DecrepitRelicInputSourceImplementation::readEvent ( EventID const & )

overridevirtual

Read a specific event.

Reimplemented from art::InputSource.

Definition at line 298 of file DecrepitRelicInputSourceImplementation.cc.

References art::errors::LogicError.

   {
     throw art::Exception(art::errors::LogicError)
       << "DecrepitRelicInputSourceImplementation::readEvent()\n"
       << "Random access is not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

virtual std::unique_ptr<EventPrincipal> art::DecrepitRelicInputSourceImplementation::readEvent_ ( )

privatepure virtual

Implemented in art::RootInput, and art::EmptyEvent.

Referenced by limitReached(), nextItemType_(), and readEvent().

std::unique_ptr< FileBlock > art::DecrepitRelicInputSourceImplementation::readFile ( )

overridevirtual

Read next subRun.

Implements art::InputSource.

Reimplemented in art::RootInput.

Definition at line 255 of file DecrepitRelicInputSourceImplementation.cc.

References cachedSubRunPrincipal_, doneReadAhead_, art::input::IsSubRun, limitReached(), remainingSubRuns_, state_, and subRunPrincipal_.

Referenced by art::RootInput::readSubRun().

   {
     // Note: For the moment, we do not support saving and restoring the state of
     // the random number generator if random numbers are generated during
     // processing of subRuns (e.g. beginSubRun(), endSubRun())
     assert(doneReadAhead_);
     assert(state_ == input::IsSubRun);
     assert(!limitReached());
     doneReadAhead_ = false;
     --remainingSubRuns_;
     assert(subRunPrincipal_->run() == rp->run());
     subRunPrincipal_->setRunPrincipal(rp);
     cachedSubRunPrincipal_ = subRunPrincipal_.get();
     return std::move(subRunPrincipal_);
   }

virtual std::unique_ptr<SubRunPrincipal> art::DecrepitRelicInputSourceImplementation::readSubRun_ ( )

privatepure virtual

Implemented in art::RootInput, and art::EmptyEvent.

Referenced by limitReached(), nextItemType(), and nextItemType_().

int art::DecrepitRelicInputSourceImplementation::remainingEvents ( ) const

inline

Accessor for remaining number of events to be read. -1 is used for unlimited.

Definition at line 161 of file DecrepitRelicInputSourceImplementation.h.

References remainingEvents_.

     {
       return remainingEvents_;
     }

int art::DecrepitRelicInputSourceImplementation::remainingSubRuns ( ) const

inline

Accessor for remaining number of subRuns to be read. -1 is used for unlimited.

Definition at line 177 of file DecrepitRelicInputSourceImplementation.h.

References doBeginJob(), doEndJob(), and remainingSubRuns_.

     {
       return remainingSubRuns_;
     }

void art::DecrepitRelicInputSourceImplementation::repeat_ ( )

inline

Reset the remaining number of events/subRuns to the maximum number.

Definition at line 143 of file DecrepitRelicInputSourceImplementation.h.

References doneReadAhead_, maxEvents_, maxSubRuns_, remainingEvents_, and remainingSubRuns_.

Referenced by rewind().

     {
       remainingEvents_ = maxEvents_;
       remainingSubRuns_ = maxSubRuns_;
       doneReadAhead_ = false;
     }

void art::DecrepitRelicInputSourceImplementation::reset ( void )

inlineprotected

Definition at line 272 of file DecrepitRelicInputSourceImplementation.h.

References doneReadAhead_, art::input::IsInvalid, and state_.

     {
       doneReadAhead_ = false;
       state_ = input::IsInvalid;
     }

void art::DecrepitRelicInputSourceImplementation::resetEventPrincipal ( )

inlineprotected

Definition at line 267 of file DecrepitRelicInputSourceImplementation.h.

References eventPrincipal_.

     {
       eventPrincipal_.reset();
     }

void art::DecrepitRelicInputSourceImplementation::resetRunPrincipal ( )

inlineprotected

Definition at line 257 of file DecrepitRelicInputSourceImplementation.h.

References runPrincipal_.

Referenced by art::EmptyEvent::getNextItemType(), and art::EmptyEvent::rewind_().

     {
       runPrincipal_.reset();
     }

void art::DecrepitRelicInputSourceImplementation::resetSubRunPrincipal ( )

inlineprotected

Definition at line 262 of file DecrepitRelicInputSourceImplementation.h.

References subRunPrincipal_.

Referenced by art::EmptyEvent::getNextItemType(), and art::EmptyEvent::rewind_().

     {
       subRunPrincipal_.reset();
     }

void art::DecrepitRelicInputSourceImplementation::rewind ( )

inlineoverridevirtual

Begin again at the first event.

Reimplemented from art::InputSource.

Definition at line 130 of file DecrepitRelicInputSourceImplementation.h.

References doneReadAhead_, art::input::IsInvalid, issueReports(), repeat_(), rewind_(), and state_.

     {
       repeat_();
       doneReadAhead_ = false;
       state_ = input::IsInvalid;
       rewind_();
     }

void art::DecrepitRelicInputSourceImplementation::rewind_ ( )

privatevirtual

Reimplemented in art::RootInput, and art::EmptyEvent.

Definition at line 334 of file DecrepitRelicInputSourceImplementation.cc.

References art::errors::LogicError.

Referenced by closeFile_(), and rewind().

   {
     throw art::Exception(art::errors::LogicError)
       << "DecrepitRelicInputSourceImplementation::rewind()\n"
       << "Rewind is not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

std::unique_ptr<RunPrincipal> art::DecrepitRelicInputSourceImplementation::runPrincipal ( )

inlineprotected

Definition at line 234 of file DecrepitRelicInputSourceImplementation.h.

References cachedRunPrincipal_, and runPrincipal_.

Referenced by art::RootInput::readRun().

     {
       cachedRunPrincipal_ = runPrincipal_.get();
       return std::move(runPrincipal_);
     }

cet::exempt_ptr<RunPrincipal> art::DecrepitRelicInputSourceImplementation::runPrincipalExemptPtr ( )

inlineprotected

Definition at line 223 of file DecrepitRelicInputSourceImplementation.h.

References cachedRunPrincipal_.

Referenced by art::RootInput::nextItemType(), and art::RootInput::readSubRun_().

     {
       return cachedRunPrincipal_;
     }

virtual std::unique_ptr<RangeSetHandler> art::InputSource::runRangeSetHandler ( )

pure virtualinherited

Implemented in art::Source< T >, art::RootInput, and art::EmptyEvent.

void art::DecrepitRelicInputSourceImplementation::setEventPrincipal ( std::unique_ptr< EventPrincipal > && ep )

protected

Definition at line 105 of file DecrepitRelicInputSourceImplementation.cc.

References cachedSubRunPrincipal_, and eventPrincipal_.

Referenced by eventPrincipal(), and art::RootInput::nextItemType().

   {
     assert(cachedSubRunPrincipal_);
     eventPrincipal_ = std::move(ep);
     eventPrincipal_->setSubRunPrincipal(cachedSubRunPrincipal_);
   }

void art::DecrepitRelicInputSourceImplementation::setRunPrincipal ( std::unique_ptr< RunPrincipal > && rp )

protected

Definition at line 89 of file DecrepitRelicInputSourceImplementation.cc.

References runPrincipal_.

Referenced by eventPrincipal(), and art::RootInput::nextItemType().

   {
     runPrincipal_ = std::move(rp);
   }

void art::DecrepitRelicInputSourceImplementation::setSubRunPrincipal ( std::unique_ptr< SubRunPrincipal > && srp )

protected

Definition at line 96 of file DecrepitRelicInputSourceImplementation.cc.

References cachedRunPrincipal_, and subRunPrincipal_.

Referenced by eventPrincipal(), and art::RootInput::nextItemType().

   {
     assert(cachedRunPrincipal_);
     subRunPrincipal_ = std::move(srp);
     subRunPrincipal_->setRunPrincipal(cachedRunPrincipal_);
   }

void art::DecrepitRelicInputSourceImplementation::setTimestamp ( Timestamp const & theTime )

inlineprotected

To set the current time, as seen by the input source.

Definition at line 205 of file DecrepitRelicInputSourceImplementation.h.

References time_.

Referenced by readEvent(), and art::EmptyEvent::rewind_().

     {
       time_ = theTime;
     }

void art::DecrepitRelicInputSourceImplementation::skip ( int )

privatevirtual

Reimplemented in art::EmptyEvent.

Definition at line 325 of file DecrepitRelicInputSourceImplementation.cc.

References art::errors::LogicError.

Referenced by closeFile_(), and skipEvents().

   {
     throw art::Exception(art::errors::LogicError)
       << "DecrepitRelicInputSourceImplementation::skip()\n"
       << "Random access is not implemented for this type of Input Source\n"
       << "Contact a Framework Developer\n";
   }

void art::DecrepitRelicInputSourceImplementation::skipEvents ( int offset )

overridevirtual

Skip the number of events specified. Offset may be negative.

Reimplemented from art::InputSource.

Definition at line 307 of file DecrepitRelicInputSourceImplementation.cc.

References skip().

   {
     this->skip(offset);
   }

input::ItemType art::DecrepitRelicInputSourceImplementation::state ( ) const

inlineprotected

Definition at line 211 of file DecrepitRelicInputSourceImplementation.h.

References state_.

Referenced by art::RootInput::AccessState::state().

     {
       return state_;
     }

bool art::DecrepitRelicInputSourceImplementation::subRunLimitReached ( ) const

inlineprivate

Definition at line 285 of file DecrepitRelicInputSourceImplementation.h.

References remainingSubRuns_.

Referenced by limitReached(), and nextItemType().

     {
       return remainingSubRuns_ == 0;
     }

std::unique_ptr<SubRunPrincipal> art::DecrepitRelicInputSourceImplementation::subRunPrincipal ( )

inlineprotected

Definition at line 241 of file DecrepitRelicInputSourceImplementation.h.

References cachedSubRunPrincipal_, and subRunPrincipal_.

Referenced by art::RootInput::readSubRun().

     {
       cachedSubRunPrincipal_ = subRunPrincipal_.get();
       return std::move(subRunPrincipal_);
     }

cet::exempt_ptr<SubRunPrincipal> art::DecrepitRelicInputSourceImplementation::subRunPrincipalExemptPtr ( )

inlineprotected

Definition at line 228 of file DecrepitRelicInputSourceImplementation.h.

References cachedSubRunPrincipal_.

     {
       return cachedSubRunPrincipal_;
     }

virtual std::unique_ptr<RangeSetHandler> art::InputSource::subRunRangeSetHandler ( )

pure virtualinherited

Implemented in art::Source< T >, art::RootInput, and art::EmptyEvent.

Timestamp const& art::DecrepitRelicInputSourceImplementation::timestamp ( ) const

inline

Accessor for the current time, as seen by the input source.

Definition at line 190 of file DecrepitRelicInputSourceImplementation.h.

References time_.

Referenced by art::EmptyEvent::reallyReadEvent().

     {
       return time_;
     }

Member Data Documentation

cet::exempt_ptr<RunPrincipal> art::DecrepitRelicInputSourceImplementation::cachedRunPrincipal_ {nullptr}

private

Definition at line 323 of file DecrepitRelicInputSourceImplementation.h.

Referenced by readRun(), runPrincipal(), runPrincipalExemptPtr(), and setSubRunPrincipal().

cet::exempt_ptr<SubRunPrincipal> art::DecrepitRelicInputSourceImplementation::cachedSubRunPrincipal_ {nullptr}

private

Definition at line 324 of file DecrepitRelicInputSourceImplementation.h.

Referenced by readSubRun(), setEventPrincipal(), subRunPrincipal(), and subRunPrincipalExemptPtr().

bool art::DecrepitRelicInputSourceImplementation::doneReadAhead_ {false}

private

Definition at line 318 of file DecrepitRelicInputSourceImplementation.h.

Referenced by nextItemType(), readEvent(), readFile(), readRun(), readSubRun(), repeat_(), reset(), and rewind().

std::unique_ptr<EventPrincipal> art::DecrepitRelicInputSourceImplementation::eventPrincipal_ {nullptr}

private

Definition at line 322 of file DecrepitRelicInputSourceImplementation.h.

Referenced by eventPrincipal(), readEvent(), resetEventPrincipal(), and setEventPrincipal().

int art::DecrepitRelicInputSourceImplementation::maxEvents_

private

Definition at line 309 of file DecrepitRelicInputSourceImplementation.h.

Referenced by DecrepitRelicInputSourceImplementation(), maxEvents(), and repeat_().

int art::DecrepitRelicInputSourceImplementation::maxSubRuns_

private

Definition at line 310 of file DecrepitRelicInputSourceImplementation.h.

Referenced by DecrepitRelicInputSourceImplementation(), maxSubRuns(), and repeat_().

ProcessingMode art::DecrepitRelicInputSourceImplementation::processingMode_ {RunsSubRunsAndEvents}

private

Definition at line 316 of file DecrepitRelicInputSourceImplementation.h.

Referenced by DecrepitRelicInputSourceImplementation(), art::RootInputFile::getNextEntryTypeWanted(), processingMode(), and art::RootInputFile::setIfFastClonable().

int art::DecrepitRelicInputSourceImplementation::readCount_ {}

private

Definition at line 315 of file DecrepitRelicInputSourceImplementation.h.

Referenced by issueReports(), and readEvent().

int art::DecrepitRelicInputSourceImplementation::remainingEvents_ {maxEvents_}

private

Definition at line 313 of file DecrepitRelicInputSourceImplementation.h.

Referenced by eventLimitReached(), readEvent(), remainingEvents(), and repeat_().

int art::DecrepitRelicInputSourceImplementation::remainingSubRuns_ {maxSubRuns_}

private

Definition at line 314 of file DecrepitRelicInputSourceImplementation.h.

Referenced by readSubRun(), remainingSubRuns(), repeat_(), and subRunLimitReached().

int const art::DecrepitRelicInputSourceImplementation::reportFrequency_

private

Definition at line 311 of file DecrepitRelicInputSourceImplementation.h.

Referenced by DecrepitRelicInputSourceImplementation(), and readEvent().

std::unique_ptr<RunPrincipal> art::DecrepitRelicInputSourceImplementation::runPrincipal_ {nullptr}

private

Definition at line 320 of file DecrepitRelicInputSourceImplementation.h.

Referenced by nextItemType(), readRun(), resetRunPrincipal(), runPrincipal(), and setRunPrincipal().

input::ItemType art::DecrepitRelicInputSourceImplementation::state_ {input::IsInvalid}

private

Definition at line 319 of file DecrepitRelicInputSourceImplementation.h.

Referenced by nextItemType(), readEvent(), readFile(), readRun(), readSubRun(), reset(), art::RootInput::AccessState::resetState(), rewind(), art::RootInput::AccessState::state(), and state().

std::unique_ptr<SubRunPrincipal> art::DecrepitRelicInputSourceImplementation::subRunPrincipal_ {nullptr}

private

Definition at line 321 of file DecrepitRelicInputSourceImplementation.h.

Referenced by nextItemType(), readSubRun(), resetSubRunPrincipal(), setSubRunPrincipal(), and subRunPrincipal().

Timestamp art::DecrepitRelicInputSourceImplementation::time_ {Timestamp::invalidTimestamp()}

private

Definition at line 317 of file DecrepitRelicInputSourceImplementation.h.

Referenced by setTimestamp(), and timestamp().

The documentation for this class was generated from the following files:

art/Framework/Core/DecrepitRelicInputSourceImplementation.h
art/Framework/Core/DecrepitRelicInputSourceImplementation.cc

Classes

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation