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 28 of file LArRawInputDriver.h.

Member Typedef Documentation

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

private

Definition at line 49 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 225 of file LArRawInputDriver.cxx.

    :
    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 241 of file LArRawInputDriver.cxx.

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

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

Definition at line 246 of file LArRawInputDriver.cxx.

  {
    // 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 261 of file LArRawInputDriver.cxx.

  {
    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 52 of file LArRawInputDriver.h.

art::SubRunID lris::LArRawInputDriver::currentSubRunID_

private

Definition at line 56 of file LArRawInputDriver.h.

stringvec_t::const_iterator lris::LArRawInputDriver::filesdone_

private

Definition at line 55 of file LArRawInputDriver.h.

stringvec_t lris::LArRawInputDriver::inputfiles_

private

Definition at line 53 of file LArRawInputDriver.h.

stringvec_t::const_iterator lris::LArRawInputDriver::nextfile_

private

Definition at line 54 of file LArRawInputDriver.h.

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

private

Definition at line 51 of file LArRawInputDriver.h.

---

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

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