lris::LArRawInputDriverShortBo Class Reference

#include <LArRawInputDriverShortBo.h>

Public Member Functions
	LArRawInputDriverShortBo (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 LArRawInputDriverShortBo.h.

Member Typedef Documentation

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

private

Definition at line 49 of file LArRawInputDriverShortBo.h.

Constructor & Destructor Documentation

lris::LArRawInputDriverShortBo::LArRawInputDriverShortBo	(	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 231 of file LArRawInputDriverShortBo.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::LArRawInputDriverShortBo::closeCurrentFile

(

)

Definition at line 247 of file LArRawInputDriverShortBo.cxx.

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

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

Definition at line 252 of file LArRawInputDriverShortBo.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::LArRawInputDriverShortBo::readNext	(	art::RunPrincipal *const &	inR,
		art::SubRunPrincipal *const &	inSR,
		art::RunPrincipal *&	outR,
		art::SubRunPrincipal *&	outSR,
		art::EventPrincipal *&	outE
	)

Definition at line 267 of file LArRawInputDriverShortBo.cxx.

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

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

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

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

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

    if (firstEventInRun)
      {
        std::unique_ptr<sumdata::RunData> rundatasb(new sumdata::RunData("bo") );
        currentSubRunID_ = art::SubRunID(rn, 1);
        outR = principalMaker_.makeRunPrincipal(rn, tstamp);
        outSR = principalMaker_.makeSubRunPrincipal(rn,
                                                    currentSubRunID_.subRun(),
                                                    tstamp);
        art::put_product_in_principal(std::move(rundatasb), *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(rdcolsb),
                                  *outE,
                                  "daq"); // Module label
    art::put_product_in_principal(std::move(daqcolsb),
                                  *outE,
                                  "daq"); // Module label

    return true;
  }

Member Data Documentation

std::string lris::LArRawInputDriverShortBo::currentDir_

private

Definition at line 52 of file LArRawInputDriverShortBo.h.

art::SubRunID lris::LArRawInputDriverShortBo::currentSubRunID_

private

Definition at line 56 of file LArRawInputDriverShortBo.h.

stringvec_t::const_iterator lris::LArRawInputDriverShortBo::filesdone_

private

Definition at line 55 of file LArRawInputDriverShortBo.h.

stringvec_t lris::LArRawInputDriverShortBo::inputfiles_

private

Definition at line 53 of file LArRawInputDriverShortBo.h.

stringvec_t::const_iterator lris::LArRawInputDriverShortBo::nextfile_

private

Definition at line 54 of file LArRawInputDriverShortBo.h.

art::SourceHelper const& lris::LArRawInputDriverShortBo::principalMaker_

private

Definition at line 51 of file LArRawInputDriverShortBo.h.

---

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

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