arttest::EventProcessorTestSource Class Reference

Inheritance diagram for arttest::EventProcessorTestSource:

Public Member Functions
	EventProcessorTestSource (fhicl::ParameterSet const &ps, art::InputSourceDescription &isd)
std::unique_ptr< art::FileBlock >	readFile () override
void	closeFile () override
art::input::ItemType	nextItemType () override
std::unique_ptr< art::RunPrincipal >	readRun () override
std::unique_ptr< art::SubRunPrincipal >	readSubRun (cet::exempt_ptr< art::RunPrincipal const > rp) override
std::unique_ptr< art::EventPrincipal >	readEvent (cet::exempt_ptr< art::SubRunPrincipal const > srp) override
std::unique_ptr< art::RangeSetHandler >	runRangeSetHandler () override
std::unique_ptr< art::RangeSetHandler >	subRunRangeSetHandler () override
Public Member Functions inherited from art::InputSource
virtual	~InputSource () noexcept
	InputSource (ModuleDescription const &)
	InputSource (InputSource const &)=delete
	InputSource (InputSource &&)=delete
InputSource &	operator= (InputSource const &)=delete
InputSource &	operator= (InputSource &&)=delete
virtual void	doBeginJob ()
virtual void	doEndJob ()
virtual void	skipEvents (int n)
virtual void	rewind ()
ModuleDescription const &	moduleDescription () const
ProcessConfiguration const &	processConfiguration () const

Private Attributes
art::ProcessConfiguration const	pc_
std::ifstream	inputFile_ {}
std::string	currentName_ {}
std::vector< std::string >	fileNames_ {}
art::RunID	run_ {}
art::SubRunID	subRun_ {}
art::EventID	event_ {}

Additional Inherited Members
Public Types inherited from art::InputSource
enum	ProcessingMode { Runs, RunsAndSubRuns, RunsSubRunsAndEvents }

Detailed Description

Definition at line 123 of file EventProcessorTestSource_source.cc.

Constructor & Destructor Documentation

arttest::EventProcessorTestSource::EventProcessorTestSource ( fhicl::ParameterSet const &  ps, art::InputSourceDescription &  isd  )

inline

Definition at line 125 of file EventProcessorTestSource_source.cc.

      : InputSource{isd.moduleDescription}
      , pc_{isd.moduleDescription.processConfiguration()}
      , fileNames_{ps.get<std::vector<std::string>>("fileNames")}
    {}

Member Function Documentation

void arttest::EventProcessorTestSource::closeFile ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 142 of file EventProcessorTestSource_source.cc.

    {
      inputFile_.close();
    }

art::input::ItemType arttest::EventProcessorTestSource::nextItemType ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 148 of file EventProcessorTestSource_source.cc.

    {
      art::input::ItemType rc{art::input::IsStop};
      std::string action{};
      if (std::getline(inputFile_, action)) {
        if (action[0] == 'r') {
          auto const r = number(action);
          run_ = (r == art::IDNumber<art::Level::Run>::flush_value()) ?
                   art::RunID::flushRun() :
                   art::RunID{r};
          rc = art::input::IsRun;
        } else if (action[0] == 's') {
          auto const sr = number(action);
          subRun_ = (sr == art::IDNumber<art::Level::SubRun>::flush_value()) ?
                      art::SubRunID::flushSubRun() :
                      art::SubRunID{run_, sr};
          rc = art::input::IsSubRun;
        } else if (action[0] == 'e') {
          auto const e = number(action);
          event_ = (e == art::IDNumber<art::Level::Event>::flush_value()) ?
                     art::EventID::flushEvent() :
                     art::EventID{subRun_, e};
          // a special value for test purposes only
          if (event_.event() != 7) {
            rc = art::input::IsEvent;
          }
        } else {
          throw art::Exception{art::errors::Configuration}
            << "Test pattern \"" << action << "\" not recognized.";
        }
      } else if (!fileNames_.empty()) {
        currentName_ = fileNames_.front();
        fileNames_.erase(cbegin(fileNames_));
        return art::input::IsFile;
      }
      return rc;
    }

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

inlineoverridevirtual

Implements art::InputSource.

Definition at line 216 of file EventProcessorTestSource_source.cc.

    {
      if (event_.event() == throw_value('e')) {
        throw art::Exception{
          art::errors::FileReadError,
          "There was an exception while reading an event from the input file."};
      }

      art::EventAuxiliary const aux{event_, nullTimestamp(), true};
      auto ep = std::make_unique<art::EventPrincipal>(aux, pc_, nullptr);
      ep->setSubRunPrincipal(srp);
      return ep;
    }

std::unique_ptr<art::FileBlock> arttest::EventProcessorTestSource::readFile ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 133 of file EventProcessorTestSource_source.cc.

    {
      inputFile_.open(currentName_);
      return std::make_unique<art::FileBlock>(
        art::FileFormatVersion{1, "EventProcessorTestSource_2017a"},
        currentName_);
    }

std::unique_ptr<art::RunPrincipal> arttest::EventProcessorTestSource::readRun ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 187 of file EventProcessorTestSource_source.cc.

    {
      if (run_.run() == throw_value('r')) {
        throw art::Exception{
          art::errors::FileReadError,
          "There was an exception while reading a run from the input file."};
      }

      art::RunAuxiliary const aux{run_, nullTimestamp(), nullTimestamp()};
      auto rp = std::make_unique<art::RunPrincipal>(aux, pc_, nullptr);
      return rp;
    }

std::unique_ptr<art::SubRunPrincipal> arttest::EventProcessorTestSource::readSubRun ( cet::exempt_ptr< art::RunPrincipal const >  rp )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 201 of file EventProcessorTestSource_source.cc.

    {
      if (subRun_.subRun() == throw_value('s')) {
        throw art::Exception{
          art::errors::FileReadError,
          "There was an exception while reading a subrun from the input file."};
      }

      art::SubRunAuxiliary const aux{subRun_, nullTimestamp(), nullTimestamp()};
      auto srp = std::make_unique<art::SubRunPrincipal>(aux, pc_, nullptr);
      srp->setRunPrincipal(rp);
      return srp;
    }

std::unique_ptr<art::RangeSetHandler> arttest::EventProcessorTestSource::runRangeSetHandler ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 231 of file EventProcessorTestSource_source.cc.

    {
      return std::make_unique<art::OpenRangeSetHandler>(run_.run());
    }

std::unique_ptr<art::RangeSetHandler> arttest::EventProcessorTestSource::subRunRangeSetHandler ( )

inlineoverridevirtual

Implements art::InputSource.

Definition at line 237 of file EventProcessorTestSource_source.cc.

    {
      return std::make_unique<art::OpenRangeSetHandler>(subRun_.run());
    }

Member Data Documentation

std::string arttest::EventProcessorTestSource::currentName_ {}

private

Definition at line 245 of file EventProcessorTestSource_source.cc.

art::EventID arttest::EventProcessorTestSource::event_ {}

private

Definition at line 249 of file EventProcessorTestSource_source.cc.

std::vector<std::string> arttest::EventProcessorTestSource::fileNames_ {}

private

Definition at line 246 of file EventProcessorTestSource_source.cc.

std::ifstream arttest::EventProcessorTestSource::inputFile_ {}

private

Definition at line 244 of file EventProcessorTestSource_source.cc.

art::ProcessConfiguration const arttest::EventProcessorTestSource::pc_

private

Definition at line 243 of file EventProcessorTestSource_source.cc.

art::RunID arttest::EventProcessorTestSource::run_ {}

private

Definition at line 247 of file EventProcessorTestSource_source.cc.

art::SubRunID arttest::EventProcessorTestSource::subRun_ {}

private

Definition at line 248 of file EventProcessorTestSource_source.cc.

---

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

• art/art/test/Framework/EventProcessor/EventProcessorTestSource_source.cc