lris::LArRawInputDriver Class Reference

#include "LArRawInputDriver.h"

Public Member Functions
	LArRawInputDriver (fhicl::ParameterSet const &pset, art::ProductRegistryHelper &helper, art::SourceHelper const &pm)
void	closeCurrentFile ()
void	readFile (std::string const &name, art::FileBlock *&fb)
bool	readNext (art::RunPrincipal *const &inR, art::SubRunPrincipal *const &inSR, art::RunPrincipal *&outR, art::SubRunPrincipal *&outSR, art::EventPrincipal *&outE)

Private Types
typedef std::vector< std::string >	stringvec_t

Private Attributes
art::SourceHelper const &	principalMaker_
std::string	currentDir_
stringvec_t	inputfiles_
stringvec_t::const_iterator	nextfile_
stringvec_t::const_iterator	filesdone_
art::SubRunID	currentSubRunID_

Detailed Description

Definition at line 30 of file LArRawInputDriver.h.

Member Typedef Documentation

typedef std::vector<std::string> lris::LArRawInputDriver::stringvec_t

private

Definition at line 50 of file LArRawInputDriver.h.

Constructor & Destructor Documentation

lris::LArRawInputDriver::LArRawInputDriver	(	fhicl::ParameterSet const &	pset,
		art::ProductRegistryHelper &	helper,
		art::SourceHelper const &	pm
	)

Class to fill the constraints on a template argument to the class, FileReaderSource

Definition at line 216 of file LArRawInputDriver.cxx.

References art::InEvent, art::InRun, and art::ProductRegistryHelper::reconstitutes().

    : principalMaker_(pm)
    , currentDir_()
    , inputfiles_()
    , nextfile_(inputfiles_.begin())
    , filesdone_(inputfiles_.end())
    , currentSubRunID_()
  {
    helper.reconstitutes<raw::DAQHeader, art::InEvent>("daq");
    helper.reconstitutes<std::vector<raw::RawDigit>, art::InEvent>("daq");
    helper.reconstitutes<sumdata::RunData, art::InRun>("daq");
  }

Member Function Documentation

void lris::LArRawInputDriver::closeCurrentFile

(

)

Definition at line 231 of file LArRawInputDriver.cxx.

  {
    // Nothing to do (See EventFileSentry).
  }

void lris::LArRawInputDriver::readFile	(	std::string const &	name,
		art::FileBlock *&	fb
	)

Definition at line 236 of file LArRawInputDriver.cxx.

References currentDir_, currentSubRunID_, filesdone_, inputfiles_, and nextfile_.

  {
    // Get the list of event files for this directory.
    currentDir_ = name;
    inputfiles_ = getsortedfiles(currentDir_);
    nextfile_ = inputfiles_.begin();
    filesdone_ = inputfiles_.end();
    currentSubRunID_ = art::SubRunID();

    // Fill and return a new Fileblock.
    fb = new art::FileBlock(art::FileFormatVersion(1, "LArRawInput 2011a"), currentDir_);
  }

bool lris::LArRawInputDriver::readNext	(	art::RunPrincipal *const &	inR,
		art::SubRunPrincipal *const &	inSR,
		art::RunPrincipal *&	outR,
		art::SubRunPrincipal *&	outSR,
		art::EventPrincipal *&	outE
	)

Definition at line 249 of file LArRawInputDriver.cxx.

References currentDir_, currentSubRunID_, filesdone_, raw::DAQHeader::GetEvent(), raw::DAQHeader::GetRun(), raw::DAQHeader::GetTimeStamp(), inputfiles_, art::SourceHelper::makeEventPrincipal(), art::SourceHelper::makeRunPrincipal(), art::SourceHelper::makeSubRunPrincipal(), nextfile_, principalMaker_, art::put_product_in_principal(), art::SubRunID::run(), and art::SubRunID::subRun().

  {
    if (inputfiles_.empty() || nextfile_ == filesdone_) return false;

    // Create empty result, then fill it from current filename:
    std::unique_ptr<std::vector<raw::RawDigit>> rdcol(new std::vector<raw::RawDigit>);

    raw::DAQHeader daqHeader;
    bool firstEventInRun = (nextfile_ == inputfiles_.begin());

    process_LAr_file(currentDir_, *nextfile_++, *rdcol, daqHeader);
    std::unique_ptr<raw::DAQHeader> daqcol(new raw::DAQHeader(daqHeader));

    art::RunNumber_t rn = daqHeader.GetRun();
    art::Timestamp tstamp = daqHeader.GetTimeStamp();

    if (firstEventInRun) {
      std::unique_ptr<sumdata::RunData> rundata(new sumdata::RunData("argoneut"));
      currentSubRunID_ = art::SubRunID(rn, 1);
      outR = principalMaker_.makeRunPrincipal(rn, tstamp);
      outSR = principalMaker_.makeSubRunPrincipal(rn, currentSubRunID_.subRun(), tstamp);
      art::put_product_in_principal(std::move(rundata), *outR, "daq");
    }
    else if (rn != currentSubRunID_.run()) {
      throw cet::exception("InconsistentEventStream")
        << "Encountered run #" << rn << " while processing events from run #"
        << currentSubRunID_.run() << "\n";
    }

    outE = principalMaker_.makeEventPrincipal(
      currentSubRunID_.run(), currentSubRunID_.subRun(), daqHeader.GetEvent(), tstamp);

    // Put products in the event.
    art::put_product_in_principal(std::move(rdcol), *outE,
                                  "daq"); // Module label
    art::put_product_in_principal(std::move(daqcol), *outE,
                                  "daq"); // Module label

    return true;
  }

Member Data Documentation

std::string lris::LArRawInputDriver::currentDir_

private

Definition at line 53 of file LArRawInputDriver.h.

Referenced by readFile(), and readNext().

art::SubRunID lris::LArRawInputDriver::currentSubRunID_

private

Definition at line 57 of file LArRawInputDriver.h.

Referenced by readFile(), and readNext().

stringvec_t::const_iterator lris::LArRawInputDriver::filesdone_

private

Definition at line 56 of file LArRawInputDriver.h.

Referenced by readFile(), and readNext().

stringvec_t lris::LArRawInputDriver::inputfiles_

private

Definition at line 54 of file LArRawInputDriver.h.

Referenced by readFile(), and readNext().

stringvec_t::const_iterator lris::LArRawInputDriver::nextfile_

private

Definition at line 55 of file LArRawInputDriver.h.

Referenced by readFile(), and readNext().

art::SourceHelper const& lris::LArRawInputDriver::principalMaker_

private

Definition at line 52 of file LArRawInputDriver.h.

Referenced by readNext().

---

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

• lardata/v09_16_03/source/lardata/RawData/utils/LArRawInputDriver.h
• lardata/v09_16_03/source/lardata/RawData/utils/LArRawInputDriver.cxx