DataModeFRD Class Reference

#include <DAQSourceModelsFRD.h>

Inheritance diagram for DataModeFRD:

Public Member Functions
bool	checksumValid () override
bool	dataBlockCompleted () const override
bool	dataBlockInitialized () const override
uint64_t	dataBlockSize () const override
	DataModeFRD (DAQSource *daqSource)
int	dataVersion () const override
std::pair< bool, std::vector< std::string > >	defineAdditionalFiles (std::string const &primaryName, bool) const override
void	detectVersion (unsigned char *fileBuf, uint32_t fileHeaderOffset) override
edm::Timestamp	fillFEDRawDataCollection (FEDRawDataCollection &rawData, bool &tcdsInRange, unsigned char *&tcds_pointer)
bool	fitToBuffer () const override
std::string	getChecksumError () const override
uint32_t	headerSize () const override
bool	isRealData () const override
std::vector< std::shared_ptr< const edm::DaqProvenanceHelper > > &	makeDaqProvenanceHelpers () override
void	makeDataBlockView (unsigned char *addr, size_t maxSize, std::vector< uint64_t > const &fileSizes, size_t fileHeaderSize) override
void	makeDirectoryEntries (std::vector< std::string > const &baseDirs, std::vector< int > const &numSources, std::string const &runDir) override
bool	nextEventView () override
void	readEvent (edm::EventPrincipal &eventPrincipal) override
bool	requireHeader () const override
uint32_t	run () const override
void	setDataBlockInitialized (bool) override
void	setTCDSSearchRange (uint16_t MINTCDSuTCAFEDID, uint16_t MAXTCDSuTCAFEDID) override
bool	versionCheck () const override
	~DataModeFRD () override
Public Member Functions inherited from DataMode
	DataMode (DAQSource *daqSource)
virtual bool	isMultiDir ()
void	setTesting (bool testing)
virtual	~DataMode ()=default

Private Attributes
uint32_t	crc_ = 0
std::vector< std::shared_ptr< const edm::DaqProvenanceHelper > >	daqProvenanceHelpers_
unsigned char *	dataBlockAddr_ = nullptr
size_t	dataBlockMax_ = 0
uint16_t	detectedFRDversion_ = 0
std::unique_ptr< edm::streamer::FRDEventMsgView >	event_
bool	eventCached_ = false
size_t	fileHeaderSize_ = 0
size_t	headerSize_ = 0
uint16_t	MAXTCDSuTCAFEDID_ = FEDNumbering::MAXTCDSuTCAFEDID
uint16_t	MINTCDSuTCAFEDID_ = FEDNumbering::MINTCDSuTCAFEDID

Additional Inherited Members
Protected Attributes inherited from DataMode
DAQSource *	daqSource_
bool	testing_ = false

Detailed Description

Definition at line 10 of file DAQSourceModelsFRD.h.

Constructor & Destructor Documentation

DataModeFRD()

DataModeFRD::DataModeFRD ( DAQSource *  daqSource )

inline

Definition at line 12 of file DAQSourceModelsFRD.h.

: DataMode(daqSource) {}

~DataModeFRD()

DataModeFRD::~DataModeFRD ( )

inlineoverride

Definition at line 13 of file DAQSourceModelsFRD.h.

{}

Member Function Documentation

checksumValid()

bool DataModeFRD::checksumValid ( )

overridevirtual

Implements DataMode.

Definition at line 138 of file DAQSourceModelsFRD.cc.

References crc32c().

                                {
  crc_ = 0;
  if (event_->version() >= 5) {
    crc_ = crc32c(crc_, (const unsigned char*)event_->payload(), event_->eventSize());
    if (crc_ != event_->crc32c())
      return false;
  }
  return true;
}

dataBlockCompleted()

bool DataModeFRD::dataBlockCompleted ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 53 of file DAQSourceModelsFRD.h.

{ return true; }

dataBlockInitialized()

bool DataModeFRD::dataBlockInitialized ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 58 of file DAQSourceModelsFRD.h.

{ return true; }

dataBlockSize()

uint64_t DataModeFRD::dataBlockSize ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 31 of file DAQSourceModelsFRD.h.

References event_.

{ return event_->size(); }

dataVersion()

int DataModeFRD::dataVersion ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 22 of file DAQSourceModelsFRD.h.

References detectedFRDversion_.

{ return detectedFRDversion_; }

defineAdditionalFiles()

std::pair<bool, std::vector<std::string> > DataModeFRD::defineAdditionalFiles ( std::string const &  primaryName, bool    ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 71 of file DAQSourceModelsFRD.h.

                                                                                                               {
    return std::make_pair(true, std::vector<std::string>());
  }

detectVersion()

void DataModeFRD::detectVersion ( unsigned char *  fileBuf, uint32_t  fileHeaderOffset  )

inlineoverridevirtual

Implements DataMode.

Definition at line 23 of file DAQSourceModelsFRD.h.

References detectedFRDversion_.

                                                                                 {
    detectedFRDversion_ = *((uint16_t*)(fileBuf + fileHeaderOffset));
  }

fillFEDRawDataCollection()

edm::Timestamp DataModeFRD::fillFEDRawDataCollection	(	FEDRawDataCollection &	rawData,
		bool &	tcdsInRange,
		unsigned char *&	tcds_pointer
	)

Definition at line 71 of file DAQSourceModelsFRD.cc.

References cms::cuda::assert(), FEDRawData::data(), Exception, l1tstage2_dqm_sourceclient-live_cfg::fedId, FEDTrailer::fragmentLength(), FEDHeader::length, FEDTrailer::length, FEDNumbering::MAXFEDID, FEDNumbering::MAXTCDSuTCAFEDID, FEDNumbering::MINTCDSuTCAFEDID, l1tstage2_dqm_sourceclient-live_cfg::rawData, FEDRawData::resize(), FEDHeader::sourceID(), and hcalRecHitTable_cff::time.

                                                                                   {
  edm::TimeValue_t time;
  timeval stv;
  gettimeofday(&stv, nullptr);
  time = stv.tv_sec;
  time = (time << 32) + stv.tv_usec;
  edm::Timestamp tstamp(time);

  uint32_t eventSize = event_->eventSize();
  unsigned char* event = (unsigned char*)event_->payload();
  tcds_pointer = nullptr;
  tcdsInRange = false;
  uint16_t selectedTCDSFed = 0;
  while (eventSize > 0) {
    assert(eventSize >= FEDTrailer::length);
    eventSize -= FEDTrailer::length;
    const FEDTrailer fedTrailer(event + eventSize);
    const uint32_t fedSize = fedTrailer.fragmentLength() << 3;  //trailer length counts in 8 bytes
    assert(eventSize >= fedSize - FEDHeader::length);
    eventSize -= (fedSize - FEDHeader::length);
    const FEDHeader fedHeader(event + eventSize);
    const uint16_t fedId = fedHeader.sourceID();
    if (fedId > FEDNumbering::MAXFEDID) {
      throw cms::Exception("DAQSource::fillFEDRawDataCollection") << "Out of range FED ID : " << fedId;
    } else if (fedId >= MINTCDSuTCAFEDID_ && fedId <= MAXTCDSuTCAFEDID_) {
      if (!selectedTCDSFed) {
        selectedTCDSFed = fedId;
        tcds_pointer = event + eventSize;
        if (fedId >= FEDNumbering::MINTCDSuTCAFEDID && fedId <= FEDNumbering::MAXTCDSuTCAFEDID) {
          tcdsInRange = true;
        }
      } else
        throw cms::Exception("DAQSource::fillFEDRawDataCollection")
            << "Second TCDS FED ID " << fedId << " found. First ID: " << selectedTCDSFed;
    }
    //take event ID from GTPE FED
    FEDRawData& fedData = rawData.FEDData(fedId);
    fedData.resize(fedSize);
    memcpy(fedData.data(), event + eventSize, fedSize);
  }
  assert(eventSize == 0);

  return tstamp;
}

fitToBuffer()

bool DataModeFRD::fitToBuffer ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 57 of file DAQSourceModelsFRD.h.

{ return false; }

getChecksumError()

std::string DataModeFRD::getChecksumError ( ) const

overridevirtual

Implements DataMode.

Definition at line 148 of file DAQSourceModelsFRD.cc.

References contentValuesCheck::ss.

                                              {
  std::stringstream ss;
  ss << "Found a wrong crc32c checksum: expected 0x" << std::hex << event_->crc32c() << " but calculated 0x" << crc_;
  return ss.str();
}

headerSize()

uint32_t DataModeFRD::headerSize ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 27 of file DAQSourceModelsFRD.h.

References detectedFRDversion_, and edm::streamer::FRDHeaderVersionSize.

{ return edm::streamer::FRDHeaderVersionSize[detectedFRDversion_]; }

isRealData()

bool DataModeFRD::isRealData ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 48 of file DAQSourceModelsFRD.h.

References event_.

{ return event_->isRealData(); }

makeDaqProvenanceHelpers()

std::vector< std::shared_ptr< const edm::DaqProvenanceHelper > > & DataModeFRD::makeDaqProvenanceHelpers ( )

overridevirtual

Implements DataMode.

Definition at line 118 of file DAQSourceModelsFRD.cc.

                                                                                              {
  //set FRD data collection
  daqProvenanceHelpers_.clear();
  daqProvenanceHelpers_.emplace_back(std::make_shared<const edm::DaqProvenanceHelper>(
      edm::TypeID(typeid(FEDRawDataCollection)), "FEDRawDataCollection", "FEDRawDataCollection", "DAQSource"));
  return daqProvenanceHelpers_;
}

makeDataBlockView()

void DataModeFRD::makeDataBlockView ( unsigned char *  addr, size_t  maxSize, std::vector< uint64_t > const &  fileSizes, size_t  fileHeaderSize  )

inlineoverridevirtual

Implements DataMode.

Definition at line 33 of file DAQSourceModelsFRD.h.

References generateTowerEtThresholdLUT::addr, dataBlockAddr_, dataBlockMax_, eventCached_, reco_skim_cfg_mod::maxSize, and nextEventView().

                                                         {
    dataBlockAddr_ = addr;
    dataBlockMax_ = maxSize;
    eventCached_ = false;
    nextEventView();
    eventCached_ = true;
  }

makeDirectoryEntries()

void DataModeFRD::makeDirectoryEntries ( std::vector< std::string > const &  baseDirs, std::vector< int > const &  numSources, std::string const &  runDir  )

inlineoverridevirtual

Implements DataMode.

Definition at line 67 of file DAQSourceModelsFRD.h.

                                                              {}

nextEventView()

bool DataModeFRD::nextEventView ( )

overridevirtual

Implements DataMode.

Definition at line 126 of file DAQSourceModelsFRD.cc.

References Exception.

Referenced by makeDataBlockView().

                                {
  if (eventCached_)
    return true;
  event_ = std::make_unique<FRDEventMsgView>(dataBlockAddr_);
  if (event_->size() > dataBlockMax_) {
    throw cms::Exception("DAQSource::getNextEvent")
        << " event id:" << event_->event() << " lumi:" << event_->lumi() << " run:" << event_->run()
        << " of size:" << event_->size() << " bytes does not fit into a chunk of size:" << dataBlockMax_ << " bytes";
  }
  return true;
}

readEvent()

void DataModeFRD::readEvent ( edm::EventPrincipal &  eventPrincipal )

overridevirtual

Implements DataMode.

Definition at line 34 of file DAQSourceModelsFRD.cc.

References printConversionInfo::aux, Options::const, Exception, FEDHeader::length, evf::evtn::makeEventAuxiliary(), eostools::move(), edm::EventAuxiliary::PhysicsTrigger, edm::EventPrincipal::put(), l1tstage2_dqm_sourceclient-live_cfg::rawData, and FEDHeader::triggerType().

                                                             {
  std::unique_ptr<FEDRawDataCollection> rawData(new FEDRawDataCollection);
  bool tcdsInRange;
  unsigned char* tcds_pointer = nullptr;
  edm::Timestamp tstamp = fillFEDRawDataCollection(*rawData, tcdsInRange, tcds_pointer);

  if (daqSource_->useL1EventID()) {
    uint32_t L1EventID = event_->event();
    edm::EventID eventID = edm::EventID(daqSource_->eventRunNumber(), daqSource_->currentLumiSection(), L1EventID);
    edm::EventAuxiliary aux(
        eventID, daqSource_->processGUID(), tstamp, event_->isRealData(), edm::EventAuxiliary::PhysicsTrigger);
    aux.setProcessHistoryID(daqSource_->processHistoryID());
    daqSource_->makeEventWrapper(eventPrincipal, aux);
  } else if (tcds_pointer == nullptr) {
    uint32_t L1EventID = event_->event();
    throw cms::Exception("DAQSource::read") << "No TCDS FED in event with FEDHeader EID -: " << L1EventID;
  } else {
    const FEDHeader fedHeader(tcds_pointer);
    tcds::Raw_v1 const* tcds = reinterpret_cast<tcds::Raw_v1 const*>(tcds_pointer + FEDHeader::length);
    edm::EventAuxiliary aux =
        evf::evtn::makeEventAuxiliary(tcds,
                                      daqSource_->eventRunNumber(),      //TODO_ eventRunNumber_
                                      daqSource_->currentLumiSection(),  //currentLumiSection_
                                      event_->isRealData(),
                                      static_cast<edm::EventAuxiliary::ExperimentType>(fedHeader.triggerType()),
                                      daqSource_->processGUID(),
                                      !daqSource_->fileListLoopMode(),
                                      !tcdsInRange);
    aux.setProcessHistoryID(daqSource_->processHistoryID());
    daqSource_->makeEventWrapper(eventPrincipal, aux);
  }

  std::unique_ptr<edm::WrapperBase> edp(new edm::Wrapper<FEDRawDataCollection>(std::move(rawData)));
  eventPrincipal.put(
      daqProvenanceHelpers_[0]->branchDescription(), std::move(edp), daqProvenanceHelpers_[0]->dummyProvenance());
}

requireHeader()

bool DataModeFRD::requireHeader ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 55 of file DAQSourceModelsFRD.h.

{ return true; }

run()

uint32_t DataModeFRD::run ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 50 of file DAQSourceModelsFRD.h.

References event_.

Referenced by Types.EventID::cppID(), and Types.LuminosityBlockID::cppID().

{ return event_->run(); }

setDataBlockInitialized()

void DataModeFRD::setDataBlockInitialized ( bool  )

inlineoverridevirtual

Implements DataMode.

Definition at line 60 of file DAQSourceModelsFRD.h.

{}

setTCDSSearchRange()

void DataModeFRD::setTCDSSearchRange ( uint16_t  MINTCDSuTCAFEDID, uint16_t  MAXTCDSuTCAFEDID  )

inlineoverridevirtual

Implements DataMode.

Definition at line 62 of file DAQSourceModelsFRD.h.

References MAXTCDSuTCAFEDID_, and MINTCDSuTCAFEDID_.

                                                                                         {
    MINTCDSuTCAFEDID_ = MINTCDSuTCAFEDID;
    MAXTCDSuTCAFEDID_ = MAXTCDSuTCAFEDID;
  }

versionCheck()

bool DataModeFRD::versionCheck ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 29 of file DAQSourceModelsFRD.h.

References detectedFRDversion_, and edm::streamer::FRDHeaderMaxVersion.

{ return detectedFRDversion_ <= edm::streamer::FRDHeaderMaxVersion; }

Member Data Documentation

crc_

uint32_t DataModeFRD::crc_ = 0

private

Definition at line 80 of file DAQSourceModelsFRD.h.

daqProvenanceHelpers_

std::vector<std::shared_ptr<const edm::DaqProvenanceHelper> > DataModeFRD::daqProvenanceHelpers_

private

Definition at line 76 of file DAQSourceModelsFRD.h.

dataBlockAddr_

unsigned char* DataModeFRD::dataBlockAddr_ = nullptr

private

Definition at line 81 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView().

dataBlockMax_

size_t DataModeFRD::dataBlockMax_ = 0

private

Definition at line 82 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView().

detectedFRDversion_

uint16_t DataModeFRD::detectedFRDversion_ = 0

private

Definition at line 77 of file DAQSourceModelsFRD.h.

Referenced by dataVersion(), detectVersion(), headerSize(), and versionCheck().

event_

std::unique_ptr<edm::streamer::FRDEventMsgView> DataModeFRD::event_

private

Definition at line 79 of file DAQSourceModelsFRD.h.

Referenced by dataBlockSize(), isRealData(), and run().

eventCached_

bool DataModeFRD::eventCached_ = false

private

Definition at line 86 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView().

fileHeaderSize_

size_t DataModeFRD::fileHeaderSize_ = 0

private

Definition at line 83 of file DAQSourceModelsFRD.h.

headerSize_

size_t DataModeFRD::headerSize_ = 0

private

Definition at line 78 of file DAQSourceModelsFRD.h.

MAXTCDSuTCAFEDID_

uint16_t DataModeFRD::MAXTCDSuTCAFEDID_ = FEDNumbering::MAXTCDSuTCAFEDID

private

Definition at line 85 of file DAQSourceModelsFRD.h.

Referenced by setTCDSSearchRange().

MINTCDSuTCAFEDID_

uint16_t DataModeFRD::MINTCDSuTCAFEDID_ = FEDNumbering::MINTCDSuTCAFEDID

private

Definition at line 84 of file DAQSourceModelsFRD.h.

Referenced by setTCDSSearchRange().