#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::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< 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.

12 : DataMode(daqSource) {}

DataMode::DataMode

DataMode(DAQSource *daqSource)

Definition: DAQSourceModels.h:34

◆ ~DataModeFRD()

DataModeFRD::~DataModeFRD ( )

inlineoverride

Definition at line 13 of file DAQSourceModelsFRD.h.

13 {};

Member Function Documentation

◆ checksumValid()

bool DataModeFRD::checksumValid ( )

overridevirtual

Implements DataMode.

Definition at line 136 of file DAQSourceModelsFRD.cc.

References crc32c(), crc_, and event_.

                                 {
   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.

53 { return true; }

◆ dataBlockInitialized()

bool DataModeFRD::dataBlockInitialized ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 58 of file DAQSourceModelsFRD.h.

58 { return true; }

◆ dataBlockSize()

uint64_t DataModeFRD::dataBlockSize ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 31 of file DAQSourceModelsFRD.h.

References event_.

31 { return event_->size(); }

DataModeFRD::event_

std::unique_ptr< FRDEventMsgView > event_

Definition: DAQSourceModelsFRD.h:77

◆ dataVersion()

int DataModeFRD::dataVersion ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 22 of file DAQSourceModelsFRD.h.

References detectedFRDversion_.

22 { return detectedFRDversion_; }

DataModeFRD::detectedFRDversion_

uint16_t detectedFRDversion_

Definition: DAQSourceModelsFRD.h:75

◆ defineAdditionalFiles()

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

inlineoverridevirtual

Implements DataMode.

Definition at line 69 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 69 of file DAQSourceModelsFRD.cc.

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

Referenced by readEvent().

                                                                                    {
   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.

57 { return false; }

◆ getChecksumError()

std::string DataModeFRD::getChecksumError ( ) const

overridevirtual

Implements DataMode.

Definition at line 146 of file DAQSourceModelsFRD.cc.

References crc_, event_, and 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 FRDHeaderVersionSize.

27 { return FRDHeaderVersionSize[detectedFRDversion_]; }

DataModeFRD::detectedFRDversion_

uint16_t detectedFRDversion_

Definition: DAQSourceModelsFRD.h:75

FRDHeaderVersionSize

constexpr std::array< uint32, FRDHeaderMaxVersion+1 > FRDHeaderVersionSize

Definition: FRDEventMessage.h:129

◆ isRealData()

bool DataModeFRD::isRealData ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 48 of file DAQSourceModelsFRD.h.

References event_.

48 { return event_->isRealData(); }

DataModeFRD::event_

std::unique_ptr< FRDEventMsgView > event_

Definition: DAQSourceModelsFRD.h:77

◆ makeDaqProvenanceHelpers()

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

overridevirtual

Implements DataMode.

Definition at line 116 of file DAQSourceModelsFRD.cc.

References daqProvenanceHelpers_.

                                                                                               {
   //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::string const &	runDir
	)

inlineoverridevirtual

Implements DataMode.

Definition at line 67 of file DAQSourceModelsFRD.h.

67 {}

◆ nextEventView()

bool DataModeFRD::nextEventView ( )

overridevirtual

Implements DataMode.

Definition at line 124 of file DAQSourceModelsFRD.cc.

References dataBlockAddr_, dataBlockMax_, event_, eventCached_, and 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 32 of file DAQSourceModelsFRD.cc.

References printConversionInfo::aux, runTheMatrix::const, DAQSource::currentLumiSection(), daqProvenanceHelpers_, DataMode::daqSource_, event_, DAQSource::eventRunNumber(), Exception, DAQSource::fileListLoopMode(), fillFEDRawDataCollection(), FEDHeader::length, evf::evtn::makeEventAuxiliary(), DAQSource::makeEventWrapper(), eostools::move(), edm::EventAuxiliary::PhysicsTrigger, edm::InputSource::processGUID(), DAQSource::processHistoryID(), edm::EventPrincipal::put(), l1tstage2_dqm_sourceclient-live_cfg::rawData, FEDHeader::triggerType(), and DAQSource::useL1EventID().

                                                              {
   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.

55 { 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().

50 { return event_->run(); }

DataModeFRD::event_

std::unique_ptr< FRDEventMsgView > event_

Definition: DAQSourceModelsFRD.h:77

◆ setDataBlockInitialized()

void DataModeFRD::setDataBlockInitialized ( bool )

inlineoverridevirtual

Implements DataMode.

Definition at line 60 of file DAQSourceModelsFRD.h.

60 {};

◆ 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 FRDHeaderMaxVersion.

29 { return detectedFRDversion_ <= FRDHeaderMaxVersion; }

FRDHeaderMaxVersion

constexpr size_t FRDHeaderMaxVersion

Definition: FRDEventMessage.h:128

DataModeFRD::detectedFRDversion_

uint16_t detectedFRDversion_

Definition: DAQSourceModelsFRD.h:75

Member Data Documentation

◆ crc_

uint32_t DataModeFRD::crc_ = 0

private

Definition at line 78 of file DAQSourceModelsFRD.h.

Referenced by checksumValid(), and getChecksumError().

◆ daqProvenanceHelpers_

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

private

Definition at line 74 of file DAQSourceModelsFRD.h.

Referenced by makeDaqProvenanceHelpers(), and readEvent().

◆ dataBlockAddr_

unsigned char* DataModeFRD::dataBlockAddr_ = nullptr

private

Definition at line 79 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView(), and nextEventView().

◆ dataBlockMax_

size_t DataModeFRD::dataBlockMax_ = 0

private

Definition at line 80 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView(), and nextEventView().

◆ detectedFRDversion_

uint16_t DataModeFRD::detectedFRDversion_ = 0

private

Definition at line 75 of file DAQSourceModelsFRD.h.

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

◆ event_

std::unique_ptr<FRDEventMsgView> DataModeFRD::event_

private

Definition at line 77 of file DAQSourceModelsFRD.h.

Referenced by checksumValid(), dataBlockSize(), fillFEDRawDataCollection(), getChecksumError(), isRealData(), nextEventView(), readEvent(), and run().

◆ eventCached_

bool DataModeFRD::eventCached_ = false

private

Definition at line 84 of file DAQSourceModelsFRD.h.

Referenced by makeDataBlockView(), and nextEventView().

◆ fileHeaderSize_

size_t DataModeFRD::fileHeaderSize_ = 0

private

Definition at line 81 of file DAQSourceModelsFRD.h.

◆ headerSize_

size_t DataModeFRD::headerSize_ = 0

private

Definition at line 76 of file DAQSourceModelsFRD.h.

◆ MAXTCDSuTCAFEDID_

uint16_t DataModeFRD::MAXTCDSuTCAFEDID_ = FEDNumbering::MAXTCDSuTCAFEDID

private

Definition at line 83 of file DAQSourceModelsFRD.h.

Referenced by fillFEDRawDataCollection(), and setTCDSSearchRange().

◆ MINTCDSuTCAFEDID_

uint16_t DataModeFRD::MINTCDSuTCAFEDID_ = FEDNumbering::MINTCDSuTCAFEDID

private

Definition at line 82 of file DAQSourceModelsFRD.h.

Referenced by fillFEDRawDataCollection(), and setTCDSSearchRange().

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ DataModeFRD()

◆ ~DataModeFRD()

Member Function Documentation

◆ checksumValid()

◆ dataBlockCompleted()

◆ dataBlockInitialized()

◆ dataBlockSize()

◆ dataVersion()

◆ defineAdditionalFiles()

◆ detectVersion()

◆ fillFEDRawDataCollection()

◆ fitToBuffer()

◆ getChecksumError()

◆ headerSize()

◆ isRealData()

◆ makeDaqProvenanceHelpers()

◆ makeDataBlockView()

◆ makeDirectoryEntries()

◆ nextEventView()

◆ readEvent()

◆ requireHeader()

◆ run()

◆ setDataBlockInitialized()

◆ setTCDSSearchRange()

◆ versionCheck()

Member Data Documentation

◆ crc_

◆ daqProvenanceHelpers_

◆ dataBlockAddr_

◆ dataBlockMax_

◆ detectedFRDversion_

◆ event_

◆ eventCached_

◆ fileHeaderSize_

◆ headerSize_

◆ MAXTCDSuTCAFEDID_

◆ MINTCDSuTCAFEDID_