art::Source< T > Class Template Reference

#include "Source.h"

Inheritance diagram for art::Source< T >:

Public Types
using	SourceDetail = T
enum	ProcessingMode { Runs, RunsAndSubRuns, RunsSubRunsAndEvents }

Public Member Functions
	Source (Source< T > const &)=delete
Source< T > &	operator= (Source< T > const &)=delete
	Source (fhicl::ParameterSet const &p, InputSourceDescription &d)
input::ItemType	nextItemType () override
std::unique_ptr< FileBlock >	readFile () override
void	closeFile () override
std::unique_ptr< RunPrincipal >	readRun () override
std::unique_ptr< SubRunPrincipal >	readSubRun (cet::exempt_ptr< RunPrincipal const > rp) override
std::unique_ptr< EventPrincipal >	readEvent (cet::exempt_ptr< SubRunPrincipal const > srp) override
std::unique_ptr< art::RangeSetHandler >	runRangeSetHandler () override
std::unique_ptr< art::RangeSetHandler >	subRunRangeSetHandler () override
auto const &	moduleDescription () const
auto const &	processConfiguration () const
virtual std::unique_ptr< EventPrincipal >	readEvent (EventID const &id)
virtual void	skipEvents (int n)
virtual void	rewind ()
virtual void	doBeginJob ()
virtual void	doEndJob ()

Private Member Functions
void	finishProductRegistration_ (InputSourceDescription &d)
bool	readNext_ ()
void	checkForNextFile_ ()
void	readNextAndRequireRun_ ()
void	readNextAndRefuseEvent_ ()
void	throwIfInsane_ (bool result, RunPrincipal *newR, SubRunPrincipal *newSR, EventPrincipal *newE) const

Static Private Member Functions
static void	throwDataCorruption_ (const char *msg)

Private Attributes
cet::exempt_ptr< ActivityRegistry >	act_
ProductRegistryHelper	h_ {}
ProductTables	presentProducts_ {ProductTables::invalid()}
SourceHelper	sourceHelper_
SourceDetail	detail_
input::ItemType	state_ {input::IsInvalid}
detail::FileNamesHandler< Source_wantFileServices< T >::value >	fh_
std::string	currentFileName_ {}
std::unique_ptr< RunPrincipal >	newRP_ {nullptr}
std::unique_ptr< SubRunPrincipal >	newSRP_ {nullptr}
std::unique_ptr< EventPrincipal >	newE_ {nullptr}
cet::exempt_ptr< RunPrincipal >	cachedRP_ {nullptr}
cet::exempt_ptr< SubRunPrincipal >	cachedSRP_ {nullptr}
bool	pendingSubRun_ {false}
bool	pendingEvent_ {false}
bool	subRunIsNew_ {false}
SubRunNumber_t	remainingSubRuns_ {1}
bool	haveSRLimit_ {false}
EventNumber_t	remainingEvents_ {1}
bool	haveEventLimit_ {false}

Detailed Description

template<class T>
class art::Source< T >

Definition at line 113 of file Source.h.

Member Typedef Documentation

template<class T >

using art::Source< T >::SourceDetail = T

Definition at line 164 of file Source.h.

Member Enumeration Documentation

enum art::InputSource::ProcessingMode

inherited

Enumerator
Runs
RunsAndSubRuns
RunsSubRunsAndEvents

Definition at line 52 of file InputSource.h.

{ Runs, RunsAndSubRuns, RunsSubRunsAndEvents };

Constructor & Destructor Documentation

template<class T >

art::Source< T >::Source ( Source< T > const &  )

delete

template<class T >

art::Source< T >::Source ( fhicl::ParameterSet const &  p, InputSourceDescription &  d  )

explicit

Definition at line 246 of file Source.h.

References art::Source< T >::act_, d, art::Source< T >::detail_, art::Source< T >::fh_, art::Source< T >::finishProductRegistration_(), art::Source< T >::h_, art::Source< T >::haveEventLimit_, art::Source< T >::haveSRLimit_, art::errors::LogicError, art::InputSourceDescription::moduleDescription, art::Source< T >::remainingEvents_, art::Source< T >::remainingSubRuns_, and art::Source< T >::sourceHelper_.

  : InputSource{d.moduleDescription}
  , act_{&d.activityRegistry}
  , sourceHelper_{d.moduleDescription}
  , detail_{p, h_, sourceHelper_}
  , fh_{
      p.get<std::vector<std::string>>("fileNames", std::vector<std::string>())}
{
  // Handle maxSubRuns parameter.
  int64_t maxSubRuns_par = p.get<int64_t>("maxSubRuns", -1);
  if (maxSubRuns_par > -1) {
    remainingSubRuns_ = maxSubRuns_par;
    haveSRLimit_ = true;
  }
  // Handle maxEvents parameter.
  int64_t maxEvents_par = p.get<int64_t>("maxEvents", -1);
  if (maxEvents_par > -1) {
    remainingEvents_ = maxEvents_par;
    haveEventLimit_ = true;
  }
  // Verify we got a real ActivityRegistry.
  if (!act_) {
    throw Exception(errors::LogicError) << "no ActivityRegistry\n";
  }
  // Finish product registration.
  finishProductRegistration_(d);
}

Member Function Documentation

template<class T >

void art::Source< T >::checkForNextFile_ ( )

private

Definition at line 444 of file Source.h.

References art::Source< T >::currentFileName_, art::Source< T >::detail_, art::Source< T >::fh_, art::input::IsFile, art::input::IsStop, art::Source< T >::state_, and fhicl::detail::atom::value().

Referenced by art::Source< T >::nextItemType(), art::Source< T >::readNextAndRefuseEvent_(), and art::Source< T >::readNextAndRequireRun_().

{
  state_ = input::IsStop; // Default -- may change below.
  if (Source_generator<T>::value) {
    std::conditional_t<detail::has_hasMoreData<T>::value,
                       detail::do_call_hasMoreData<T>,
                       detail::do_not_call_hasMoreData<T>>
      generatorHasMoreData;
    if (generatorHasMoreData(detail_)) {
      state_ = input::IsFile;
    }
  } else {
    currentFileName_ = fh_.next();
    if (!currentFileName_.empty()) {
      state_ = input::IsFile;
    }
  }
}

template<class T >

void art::Source< T >::closeFile ( )

overridevirtual

Implements art::InputSource.

Definition at line 592 of file Source.h.

References art::Source< T >::cachedRP_, art::Source< T >::cachedSRP_, and art::Source< T >::detail_.

{
  detail_.closeCurrentFile();
  // Cached pointers are no longer valid since the PrincipalCache is
  // cleared after file close.
  cachedRP_ = nullptr;
  cachedSRP_ = nullptr;
}

void art::InputSource::doBeginJob ( )

virtualinherited

Reimplemented in art::DecrepitRelicInputSourceImplementation.

Definition at line 31 of file InputSource.cc.

{}

void art::InputSource::doEndJob ( )

virtualinherited

Reimplemented in art::DecrepitRelicInputSourceImplementation.

Definition at line 35 of file InputSource.cc.

{}

template<class T >

void art::Source< T >::finishProductRegistration_ ( InputSourceDescription &  d )

private

Definition at line 645 of file Source.h.

References art::Source< T >::h_, art::ModuleDescription::id(), art::ModuleDescription::invalidID(), art::InputSourceDescription::moduleDescription, art::Source< T >::presentProducts_, art::ModuleDescription::processConfiguration(), art::InputSourceDescription::productRegistry, art::ProductRegistryHelper::registerProducts(), art::SourceHelper::setPresentProducts(), and art::Source< T >::sourceHelper_.

Referenced by art::Source< T >::Source().

{
  // These _xERROR_ strings should never appear in branch names; they
  // are here as tracers to help identify any failures in coding.
  ProductDescriptions descriptions{};
  h_.registerProducts(
    d.productRegistry,
    descriptions,
    ModuleDescription{fhicl::ParameterSet{}.id(), // Dummy
                      "_NAMEERROR_",
                      "_LABELERROR_",
                      d.moduleDescription.processConfiguration(),
                      ModuleDescription::invalidID()});
  presentProducts_ = ProductTables{descriptions};
  sourceHelper_.setPresentProducts(cet::make_exempt_ptr(&presentProducts_));
}

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_;
    }

template<class T >

art::input::ItemType art::Source< T >::nextItemType ( )

overridevirtual

Implements art::InputSource.

Definition at line 465 of file Source.h.

References art::Source< T >::cachedSRP_, art::Source< T >::checkForNextFile_(), art::Source< T >::currentFileName_, art::errors::DataCorruption, art::Source< T >::fh_, art::input::IsEvent, art::input::IsFile, art::input::IsInvalid, art::input::IsRun, art::input::IsStop, art::input::IsSubRun, art::Source< T >::newE_, art::Source< T >::pendingEvent_, art::Source< T >::pendingSubRun_, art::Source< T >::readNext_(), art::Source< T >::readNextAndRefuseEvent_(), art::Source< T >::readNextAndRequireRun_(), art::Source< T >::remainingEvents_, art::Source< T >::remainingSubRuns_, and art::Source< T >::state_.

{
  if (remainingEvents_ == 0) {
    state_ = input::IsStop;
  }
  switch (state_) {
    case input::IsInvalid:
      if (Source_generator<T>::value) {
        state_ = input::IsFile; // Once.
      } else {
        checkForNextFile_();
      }
      break;
    case input::IsFile:
      readNextAndRequireRun_();
      break;
    case input::IsRun:
      if (pendingSubRun_ || (pendingEvent_ && cachedSRP_)) {
        state_ = input::IsSubRun;
        pendingSubRun_ = false;
      } else if (pendingEvent_)
        throw Exception(errors::DataCorruption)
          << "Input file '" << currentFileName_ << "' contains an Event "
          << newE_->id() << " that belongs to no SubRun\n";
      else {
        readNextAndRequireRun_();
      }
      break;
    case input::IsSubRun:
      if (pendingEvent_) {
        state_ = input::IsEvent;
        pendingEvent_ = false;
      } else {
        readNextAndRefuseEvent_();
      }
      break;
    case input::IsEvent:
      if (!readNext_()) {
        checkForNextFile_();
      }
      break;
    case input::IsStop:
      break;
  }
  if ((state_ == input::IsRun || state_ == input::IsSubRun) &&
      remainingSubRuns_ == 0) {
    state_ = input::IsStop;
  }
  if (state_ == input::IsStop) {
    // 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.
    fh_.finish();
  }
  return state_;
}

template<class T >

Source<T>& art::Source< T >::operator= ( Source< T > 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();
    }

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

virtualinherited

Reimplemented in art::DecrepitRelicInputSourceImplementation.

Definition at line 4 of file InputSource.cc.

References art::errors::Configuration.

{
  throw art::Exception(art::errors::Configuration)
    << "The application has tried to peform random access on an input source\n"
    << "that does not support random access. Please reconfigure the program\n"
    << "to use an input source that supports random access (e.g. RootInput)\n";
}

template<class T >

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

overridevirtual

Implements art::InputSource.

Definition at line 635 of file Source.h.

References art::Source< T >::haveEventLimit_, art::Source< T >::newE_, and art::Source< T >::remainingEvents_.

{
  if (haveEventLimit_) {
    --remainingEvents_;
  }
  return std::move(newE_);
}

template<class T >

std::unique_ptr< art::FileBlock > art::Source< T >::readFile ( )

overridevirtual

Implements art::InputSource.

Definition at line 579 of file Source.h.

References art::Source< T >::currentFileName_, art::Source< T >::detail_, and art::errors::LogicError.

{
  FileBlock* newF{nullptr};
  detail_.readFile(currentFileName_, newF);
  if (!newF) {
    throw Exception(errors::LogicError)
      << "detail_::readFile() failed to return a valid FileBlock object\n";
  }
  return std::unique_ptr<FileBlock>(newF);
}

template<class T >

bool art::Source< T >::readNext_ ( )

private

Definition at line 396 of file Source.h.

References art::Source< T >::cachedRP_, art::Source< T >::cachedSRP_, art::Source< T >::detail_, art::input::IsEvent, art::input::IsRun, art::input::IsSubRun, art::Source< T >::newE_, art::Source< T >::newRP_, art::Source< T >::newSRP_, art::Source< T >::pendingEvent_, art::Source< T >::pendingSubRun_, art::Source< T >::state_, art::Source< T >::subRunIsNew_, and art::Source< T >::throwIfInsane_().

Referenced by art::Source< T >::nextItemType(), art::Source< T >::readNextAndRefuseEvent_(), and art::Source< T >::readNextAndRequireRun_().

{
  std::unique_ptr<RunPrincipal> newR{nullptr};
  std::unique_ptr<SubRunPrincipal> newSR{nullptr};
  std::unique_ptr<EventPrincipal> newE{nullptr};

  bool result{false};
  {
    RunPrincipal* nR{nullptr};
    SubRunPrincipal* nSR{nullptr};
    EventPrincipal* nE{nullptr};
    result = detail_.readNext(cachedRP_.get(), cachedSRP_.get(), nR, nSR, nE);
    newR.reset(nR);
    newSR.reset(nSR);
    newE.reset(nE);
    throwIfInsane_(result, newR.get(), newSR.get(), newE.get());
  }

  if (result) {
    subRunIsNew_ = newSR && ((!cachedSRP_) || newSR->id() != cachedSRP_->id());
    pendingSubRun_ = newSR.get() != nullptr;
    pendingEvent_ = newE.get() != nullptr;
    if (newR) {
      newRP_ = std::move(newR);
    }
    if (newSR) {
      auto rp = newRP_ ? newRP_.get() : cachedRP_.get();
      newSR->setRunPrincipal(rp);
      newSRP_ = std::move(newSR);
    }
    if (newE) {
      auto srp = newSRP_ ? newSRP_.get() : cachedSRP_.get();
      newE->setSubRunPrincipal(srp);
      newE_ = std::move(newE);
    }
    if (newRP_) {
      state_ = input::IsRun;
    } else if (newSRP_) {
      state_ = input::IsSubRun;
    } else if (newE_) {
      state_ = input::IsEvent;
    }
  }
  return result;
}

template<class T >

void art::Source< T >::readNextAndRefuseEvent_ ( )

private

Definition at line 550 of file Source.h.

References art::Source< T >::checkForNextFile_(), art::Source< T >::currentFileName_, art::errors::DataCorruption, art::input::IsEvent, art::Source< T >::readNext_(), and art::Source< T >::state_.

Referenced by art::Source< T >::nextItemType().

{
  if (readNext_()) {
    if (state_ == input::IsEvent) {
      throw Exception(errors::DataCorruption)
        << "Input file '" << currentFileName_
        << "' has an Event where a Run or SubRun is expected\n";
    }
  } else {
    checkForNextFile_();
  }
}

template<class T >

void art::Source< T >::readNextAndRequireRun_ ( )

private

Definition at line 530 of file Source.h.

References art::Source< T >::cachedRP_, art::Source< T >::checkForNextFile_(), art::Source< T >::currentFileName_, art::errors::DataCorruption, art::input::IsRun, art::input::IsSubRun, art::Source< T >::readNext_(), and art::Source< T >::state_.

Referenced by art::Source< T >::nextItemType().

{
  if (readNext_()) {
    if (state_ != input::IsRun) {
      if (cachedRP_) {
        state_ = input::IsRun; // Regurgitate existing cached run.
      } else {
        throw Exception(errors::DataCorruption)
          << "Input file '" << currentFileName_ << "' has a"
          << (state_ == input::IsSubRun ? " SubRun" : "n Event")
          << " where a Run is expected\n";
      }
    }
  } else {
    checkForNextFile_();
  }
}

template<class T >

std::unique_ptr< art::RunPrincipal > art::Source< T >::readRun ( )

overridevirtual

Implements art::InputSource.

Definition at line 603 of file Source.h.

References art::Source< T >::cachedRP_, art::errors::LogicError, and art::Source< T >::newRP_.

{
  if (!newRP_)
    throw Exception(errors::LogicError)
      << "Error in Source<T>\n"
      << "readRun() called when no RunPrincipal exists\n"
      << "Please report this to the art developers\n";
  cachedRP_ = newRP_.get();
  return std::move(newRP_);
}

template<class T >

std::unique_ptr< art::SubRunPrincipal > art::Source< T >::readSubRun ( cet::exempt_ptr< RunPrincipal const >  rp )

overridevirtual

Implements art::InputSource.

Definition at line 616 of file Source.h.

References art::Source< T >::cachedSRP_, art::Source< T >::haveSRLimit_, art::errors::LogicError, art::Source< T >::newSRP_, art::Source< T >::remainingSubRuns_, and art::Source< T >::subRunIsNew_.

{
  if (!newSRP_)
    throw Exception(errors::LogicError)
      << "Error in Source<T>\n"
      << "readSubRun() called when no SubRunPrincipal exists\n"
      << "Please report this to the art developers\n";
  if (subRunIsNew_) {
    if (haveSRLimit_) {
      --remainingSubRuns_;
    }
    subRunIsNew_ = false;
  }
  cachedSRP_ = newSRP_.get();
  return std::move(newSRP_);
}

void art::InputSource::rewind ( )

virtualinherited

Reimplemented in art::DecrepitRelicInputSourceImplementation.

Definition at line 22 of file InputSource.cc.

References art::errors::Configuration.

{
  throw art::Exception(art::errors::Configuration)
    << "The application has tried to rewind an input source\n"
    << "that does not support rewinding. Please reconfigure the program\n"
    << "to use an input source that supports random access (e.g. RootInput)\n";
}

template<class T >

std::unique_ptr< art::RangeSetHandler > art::Source< T >::runRangeSetHandler ( )

overridevirtual

Implements art::InputSource.

Definition at line 565 of file Source.h.

References art::Source< T >::cachedRP_.

{
  return std::make_unique<OpenRangeSetHandler>(cachedRP_->run());
}

void art::InputSource::skipEvents ( int  n )

virtualinherited

Reimplemented in art::DecrepitRelicInputSourceImplementation.

Definition at line 13 of file InputSource.cc.

References art::errors::Configuration.

{
  throw art::Exception(art::errors::Configuration)
    << "The application has tried to peform random access on an input source\n"
    << "that does not support random access. Please reconfigure the program\n"
    << "to use an input source that supports random access (e.g. RootInput)\n";
}

template<class T >

std::unique_ptr< art::RangeSetHandler > art::Source< T >::subRunRangeSetHandler ( )

overridevirtual

Implements art::InputSource.

Definition at line 572 of file Source.h.

References art::Source< T >::cachedSRP_.

{
  return std::make_unique<OpenRangeSetHandler>(cachedSRP_->run());
}

template<class T >

void art::Source< T >::throwDataCorruption_ ( const char *  msg )

staticprivate

Definition at line 276 of file Source.h.

References art::errors::DataCorruption.

Referenced by art::Source< T >::throwIfInsane_().

{
  throw Exception(errors::DataCorruption) << msg;
}

template<class T >

void art::Source< T >::throwIfInsane_ ( bool  result, RunPrincipal *  newR, SubRunPrincipal *  newSR, EventPrincipal *  newE  ) const

private

Definition at line 283 of file Source.h.

References art::Source< T >::cachedRP_, art::Source< T >::cachedSRP_, art::RunPrincipal::id(), art::SubRunPrincipal::id(), art::EventPrincipal::id(), art::SubRunID::isValid(), art::RunID::isValid(), art::EventID::isValid(), art::errors::LogicError, art::SubRunID::runID(), art::SubRunPrincipal::runPrincipalExemptPtr(), art::EventID::subRunID(), art::EventPrincipal::subRunPrincipalExemptPtr(), and art::Source< T >::throwDataCorruption_().

Referenced by art::Source< T >::readNext_().

{
  std::ostringstream errMsg;
  if (result) {
    if (!newR && !newSR && !newE) {
      throw Exception{errors::LogicError}
        << "readNext returned true but created no new data\n";
    }

    if (!cachedRP_ && !newR) {
      throw Exception(errors::LogicError)
        << "readNext returned true but no RunPrincipal has been set, and no "
           "cached RunPrincipal exists.\n"
           "This can happen if a new input file has been opened and the "
           "RunPrincipal has not been appropriately assigned.";
    }

    if (!cachedSRP_ && !newSR) {
      throw Exception(errors::LogicError)
        << "readNext returned true but no SubRunPrincipal has been set, and no "
           "cached SubRunPrincipal exists.\n"
           "This can happen if a new input file has been opened and the "
           "SubRunPrincipal has not been appropriately assigned.";
    }

    if (cachedRP_ && newR && cachedRP_.get() == newR) {
      errMsg << "readNext returned a new Run which is the old Run for "
             << cachedRP_->id()
             << ".\nIf you don't have a new run, don't return one!\n";
    }
    if (cachedSRP_ && newSR && cachedSRP_.get() == newSR) {
      errMsg << "readNext returned a new SubRun which is the old SubRun for "
             << cachedSRP_->id()
             << ".\nIf you don't have a new subRun, don't return one!\n";
    }
    // Either or both of the above cases could be true and we need
    // to make both of them safe before we throw:
    if (!errMsg.str().empty())
      throw Exception(errors::LogicError) << errMsg.str();
    if (cachedRP_ && cachedSRP_) {
      if (!newR && newSR && newSR->id() == cachedSRP_->id())
        throwDataCorruption_("readNext returned a 'new' SubRun "
                             "that was the same as the previous "
                             "SubRun\n");
      if (newR && newR->id() == cachedRP_->id())
        throwDataCorruption_("readNext returned a 'new' Run "
                             "that was the same as the previous "
                             "Run\n");
      if (newR && !newSR && newE)
        throwDataCorruption_("readNext returned a new Run and "
                             "Event without a SubRun\n");
      if (newR && newSR && newSR->id() == cachedSRP_->id())
        throwDataCorruption_("readNext returned a new Run with "
                             "a SubRun from the wrong Run\n");
    }
    RunID rID;
    SubRunID srID;
    EventID eID;
    if (newR) {
      rID = newR->id();
      if (!rID.isValid()) {
        throwDataCorruption_(
          "readNext returned a Run with an invalid RunID.\n");
      }
    } else if (cachedRP_) {
      rID = cachedRP_->id();
    }
    if (newSR) {
      srID = newSR->id();
      if (rID != srID.runID()) {
        errMsg << "readNext returned a SubRun " << srID
               << " which is a mismatch to " << rID << "\n";
        throwDataCorruption_(errMsg.str().c_str());
      }
      if (!srID.isValid()) {
        throwDataCorruption_(
          "readNext returned a SubRun with an invalid SubRunID.\n");
      }
      if (newSR->runPrincipalExemptPtr()) {
        throwDataCorruption_(
          "readNext returned a SubRun with a non-null embedded Run.\n");
      }
    } else if (cachedSRP_) {
      srID = cachedSRP_->id();
    }
    if (newE) {
      eID = newE->id();
      if (srID != eID.subRunID()) {
        errMsg << "readNext returned an Event " << eID
               << " which is a mismatch to " << srID << "\n";
        throwDataCorruption_(errMsg.str().c_str());
      }
      if (!eID.isValid()) {
        throwDataCorruption_(
          "readNext returned an Event with an invalid EventID.\n");
      }
      if (newE->subRunPrincipalExemptPtr()) {
        throwDataCorruption_(
          "readNext returned an Event with a non-null embedded SubRun.\n");
      }
    }
  } else {
    if (newR || newSR || newE)
      throw Exception(errors::LogicError)
        << "readNext returned false but created new data\n";
  }
}

Member Data Documentation

template<class T >

cet::exempt_ptr<ActivityRegistry> art::Source< T >::act_

private

Definition at line 184 of file Source.h.

Referenced by art::Source< T >::Source().

template<class T >

cet::exempt_ptr<RunPrincipal> art::Source< T >::cachedRP_ {nullptr}

private

Definition at line 201 of file Source.h.

Referenced by art::Source< T >::closeFile(), art::Source< T >::readNext_(), art::Source< T >::readNextAndRequireRun_(), art::Source< T >::readRun(), art::Source< T >::runRangeSetHandler(), and art::Source< T >::throwIfInsane_().

template<class T >

cet::exempt_ptr<SubRunPrincipal> art::Source< T >::cachedSRP_ {nullptr}

private

Definition at line 202 of file Source.h.

Referenced by art::Source< T >::closeFile(), art::Source< T >::nextItemType(), art::Source< T >::readNext_(), art::Source< T >::readSubRun(), art::Source< T >::subRunRangeSetHandler(), and art::Source< T >::throwIfInsane_().

template<class T >

std::string art::Source< T >::currentFileName_ {}

private

Definition at line 193 of file Source.h.

Referenced by art::Source< T >::checkForNextFile_(), art::Source< T >::nextItemType(), art::Source< T >::readFile(), art::Source< T >::readNextAndRefuseEvent_(), and art::Source< T >::readNextAndRequireRun_().

template<class T >

SourceDetail art::Source< T >::detail_

private

Definition at line 189 of file Source.h.

Referenced by art::Source< T >::checkForNextFile_(), art::Source< T >::closeFile(), art::Source< T >::readFile(), art::Source< T >::readNext_(), and art::Source< T >::Source().

template<class T >

detail::FileNamesHandler<Source_wantFileServices<T>::value> art::Source< T >::fh_

private

Definition at line 192 of file Source.h.

Referenced by art::Source< T >::checkForNextFile_(), art::Source< T >::nextItemType(), and art::Source< T >::Source().

template<class T >

ProductRegistryHelper art::Source< T >::h_ {}

private

Definition at line 186 of file Source.h.

Referenced by art::Source< T >::finishProductRegistration_(), and art::Source< T >::Source().

template<class T >

bool art::Source< T >::haveEventLimit_ {false}

private

Definition at line 212 of file Source.h.

Referenced by art::Source< T >::readEvent(), and art::Source< T >::Source().

template<class T >

bool art::Source< T >::haveSRLimit_ {false}

private

Definition at line 210 of file Source.h.

Referenced by art::Source< T >::readSubRun(), and art::Source< T >::Source().

template<class T >

std::unique_ptr<EventPrincipal> art::Source< T >::newE_ {nullptr}

private

Definition at line 197 of file Source.h.

Referenced by art::Source< T >::nextItemType(), art::Source< T >::readEvent(), and art::Source< T >::readNext_().

template<class T >

std::unique_ptr<RunPrincipal> art::Source< T >::newRP_ {nullptr}

private

Definition at line 195 of file Source.h.

Referenced by art::Source< T >::readNext_(), and art::Source< T >::readRun().

template<class T >

std::unique_ptr<SubRunPrincipal> art::Source< T >::newSRP_ {nullptr}

private

Definition at line 196 of file Source.h.

Referenced by art::Source< T >::readNext_(), and art::Source< T >::readSubRun().

template<class T >

bool art::Source< T >::pendingEvent_ {false}

private

Definition at line 205 of file Source.h.

Referenced by art::Source< T >::nextItemType(), and art::Source< T >::readNext_().

template<class T >

bool art::Source< T >::pendingSubRun_ {false}

private

Definition at line 204 of file Source.h.

Referenced by art::Source< T >::nextItemType(), and art::Source< T >::readNext_().

template<class T >

ProductTables art::Source< T >::presentProducts_ {ProductTables::invalid()}

private

Definition at line 187 of file Source.h.

Referenced by art::Source< T >::finishProductRegistration_().

template<class T >

EventNumber_t art::Source< T >::remainingEvents_ {1}

private

Definition at line 211 of file Source.h.

Referenced by art::Source< T >::nextItemType(), art::Source< T >::readEvent(), and art::Source< T >::Source().

template<class T >

SubRunNumber_t art::Source< T >::remainingSubRuns_ {1}

private

Definition at line 209 of file Source.h.

Referenced by art::Source< T >::nextItemType(), art::Source< T >::readSubRun(), and art::Source< T >::Source().

template<class T >

SourceHelper art::Source< T >::sourceHelper_

private

Definition at line 188 of file Source.h.

Referenced by art::Source< T >::finishProductRegistration_(), and art::Source< T >::Source().

template<class T >

input::ItemType art::Source< T >::state_ {input::IsInvalid}

private

Definition at line 190 of file Source.h.

Referenced by art::Source< T >::checkForNextFile_(), art::Source< T >::nextItemType(), art::Source< T >::readNext_(), art::Source< T >::readNextAndRefuseEvent_(), and art::Source< T >::readNextAndRequireRun_().

template<class T >

bool art::Source< T >::subRunIsNew_ {false}

private

Definition at line 207 of file Source.h.

Referenced by art::Source< T >::readNext_(), and art::Source< T >::readSubRun().

---

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

• art/Framework/IO/Sources/Source.h