DataModeScoutingRun2Muon Class Reference

#include <DAQSourceModelsScouting.h>

Inheritance diagram for DataModeScoutingRun2Muon:

Public Member Functions
bool	checksumValid () override
bool	dataBlockCompleted () const override
bool	dataBlockInitialized () const override
uint64_t	dataBlockSize () const override
	DataModeScoutingRun2Muon (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
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
char *	readPayloadPos ()
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
	~DataModeScoutingRun2Muon () override
Public Member Functions inherited from DataMode
	DataMode (DAQSource *daqSource)
virtual bool	isMultiDir ()
void	setTesting (bool testing)
virtual	~DataMode ()=default

Private Member Functions
void	unpackOrbit (BXVector< l1t::Muon > *muons, char *buf, size_t len)

Private Attributes
std::vector< std::shared_ptr< const edm::DaqProvenanceHelper > >	daqProvenanceHelpers_
unsigned char *	dataBlockAddr_ = nullptr
size_t	dataBlockMax_ = 0
uint16_t	detectedFRDversion_ = 0
std::unique_ptr< ROOT::Math::LorentzVector< ROOT::Math::PxPyPzE4D< double > > >	dummyLVec_
std::unique_ptr< FRDEventMsgView >	event_
bool	eventCached_ = false
size_t	headerSize_ = 0

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

Detailed Description

Definition at line 79 of file DAQSourceModelsScouting.h.

Constructor & Destructor Documentation

DataModeScoutingRun2Muon()

DataModeScoutingRun2Muon::DataModeScoutingRun2Muon ( DAQSource *  daqSource )

inline

Definition at line 81 of file DAQSourceModelsScouting.h.

References dummyLVec_.

                                                 : DataMode(daqSource) {
    dummyLVec_ = std::make_unique<ROOT::Math::LorentzVector<ROOT::Math::PxPyPzE4D<double>>>();
  }

~DataModeScoutingRun2Muon()

DataModeScoutingRun2Muon::~DataModeScoutingRun2Muon ( )

inlineoverride

Definition at line 85 of file DAQSourceModelsScouting.h.

{};

Member Function Documentation

checksumValid()

bool DataModeScoutingRun2Muon::checksumValid ( )

overridevirtual

Implements DataMode.

Definition at line 130 of file DAQSourceModelsScouting.cc.

{ return true; }

dataBlockCompleted()

bool DataModeScoutingRun2Muon::dataBlockCompleted ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 121 of file DAQSourceModelsScouting.h.

{ return true; }

dataBlockInitialized()

bool DataModeScoutingRun2Muon::dataBlockInitialized ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 127 of file DAQSourceModelsScouting.h.

{ return true; }

dataBlockSize()

uint64_t DataModeScoutingRun2Muon::dataBlockSize ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 99 of file DAQSourceModelsScouting.h.

References event_.

{ return event_->size(); }

dataVersion()

int DataModeScoutingRun2Muon::dataVersion ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 90 of file DAQSourceModelsScouting.h.

References detectedFRDversion_.

{ return detectedFRDversion_; }

defineAdditionalFiles()

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

inlineoverridevirtual

Implements DataMode.

Definition at line 135 of file DAQSourceModelsScouting.h.

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

detectVersion()

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

inlineoverridevirtual

Implements DataMode.

Definition at line 91 of file DAQSourceModelsScouting.h.

References detectedFRDversion_.

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

fitToBuffer()

bool DataModeScoutingRun2Muon::fitToBuffer ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 125 of file DAQSourceModelsScouting.h.

{ return true; }

getChecksumError()

std::string DataModeScoutingRun2Muon::getChecksumError ( ) const

overridevirtual

Implements DataMode.

Definition at line 132 of file DAQSourceModelsScouting.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

{ return std::string(); }

headerSize()

uint32_t DataModeScoutingRun2Muon::headerSize ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 95 of file DAQSourceModelsScouting.h.

References detectedFRDversion_, and FRDHeaderVersionSize.

{ return FRDHeaderVersionSize[detectedFRDversion_]; }

isRealData()

bool DataModeScoutingRun2Muon::isRealData ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 116 of file DAQSourceModelsScouting.h.

References event_.

{ return event_->isRealData(); }

makeDaqProvenanceHelpers()

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

overridevirtual

Implements DataMode.

Definition at line 110 of file DAQSourceModelsScouting.cc.

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

makeDataBlockView()

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

inlineoverridevirtual

Implements DataMode.

Definition at line 101 of file DAQSourceModelsScouting.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 DataModeScoutingRun2Muon::makeDirectoryEntries ( std::vector< std::string > const &  baseDirs, std::string const &  runDir  )

inlineoverridevirtual

Implements DataMode.

Definition at line 133 of file DAQSourceModelsScouting.h.

{}

nextEventView()

bool DataModeScoutingRun2Muon::nextEventView ( )

overridevirtual

Implements DataMode.

Definition at line 118 of file DAQSourceModelsScouting.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 DataModeScoutingRun2Muon::readEvent ( edm::EventPrincipal &  eventPrincipal )

overridevirtual

Implements DataMode.

Definition at line 15 of file DAQSourceModelsScouting.cc.

References printConversionInfo::aux, eostools::move(), edm::EventAuxiliary::PhysicsTrigger, edm::EventPrincipal::put(), l1tstage2_dqm_sourceclient-live_cfg::rawData, 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);

  std::unique_ptr<BXVector<l1t::Muon>> rawData(new BXVector<l1t::Muon>);
  //allow any bx
  rawData->setBXRange(0, 4000);

  unpackOrbit(rawData.get(), (char*)event_->payload(), event_->eventSize());

  uint32_t hdrEventID = event_->event();
  edm::EventID eventID = edm::EventID(daqSource_->eventRunNumber(), daqSource_->currentLumiSection(), hdrEventID);
  edm::EventAuxiliary aux(
      eventID, daqSource_->processGUID(), tstamp, event_->isRealData(), edm::EventAuxiliary::PhysicsTrigger);

  aux.setProcessHistoryID(daqSource_->processHistoryID());
  daqSource_->makeEventWrapper(eventPrincipal, aux);

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

readPayloadPos()

char* DataModeScoutingRun2Muon::readPayloadPos ( )

inline

Definition at line 139 of file DAQSourceModelsScouting.h.

References event_.

{ return (char*)event_->payload(); }

requireHeader()

bool DataModeScoutingRun2Muon::requireHeader ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 123 of file DAQSourceModelsScouting.h.

{ return true; }

run()

uint32_t DataModeScoutingRun2Muon::run ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 118 of file DAQSourceModelsScouting.h.

References event_.

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

{ return event_->run(); }

setDataBlockInitialized()

void DataModeScoutingRun2Muon::setDataBlockInitialized ( bool  )

inlineoverridevirtual

Implements DataMode.

Definition at line 129 of file DAQSourceModelsScouting.h.

{};

setTCDSSearchRange()

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

inlineoverridevirtual

Implements DataMode.

Definition at line 131 of file DAQSourceModelsScouting.h.

{ return; }

unpackOrbit()

void DataModeScoutingRun2Muon::unpackOrbit ( BXVector< l1t::Muon > *  muons, char *  buf, size_t  len  )

private

Definition at line 42 of file DAQSourceModelsScouting.cc.

References cms::cuda::assert(), visDQMUpload::buf, scouting::block::bx, nano_mu_digi_cff::bx, scouting::masks::chrg, scouting::shifts::chrg, scouting::masks::chrgv, scouting::shifts::chrgv, gather_cfg::cout, scouting::shifts::eta, scouting::shifts::etaext, scouting::masks::etaexts, scouting::masks::etaextv, scouting::masks::etas, scouting::masks::etav, scouting::muon::f, RecoTauValidation_cfi::header, mps_fire::i, hcalRecHitTable_cff::ieta, scouting::masks::index, scouting::shifts::index, hcalRecHitTable_cff::iphi, scouting::masks::iso, scouting::shifts::iso, scouting::header_shifts::mAcount, scouting::header_masks::mAcount, scouting::header_shifts::mBcount, scouting::header_masks::mBcount, scouting::block::mu, HLT_2023v12_cff::muon, PDWG_BPHSkim_cff::muons, scouting::block::orbit, scouting::masks::phi, scouting::shifts::phi, scouting::masks::phiext, scouting::shifts::phiext, scouting::masks::pt, scouting::shifts::pt, scouting::masks::qual, scouting::shifts::qual, and scouting::muon::s.

                                                                                          {
  using namespace scouting;
  size_t pos = 0;
  uint32_t o_test = 0;
  while (pos < len) {
    assert(pos + 4 <= len);
    uint32_t header = *((uint32*)(buf + pos));
    uint32_t mAcount = (header & header_masks::mAcount) >> header_shifts::mAcount;
    uint32_t mBcount = (header & header_masks::mBcount) >> header_shifts::mBcount;

    block* bl = (block*)(buf + pos + 4);

    pos += 12 + (mAcount + mBcount) * 8;
    assert(pos <= len);

    uint32_t bx = bl->bx;

    uint32_t orbit = bl->orbit;
    o_test = orbit;

    //should cuts should be applied
    bool excludeIntermediate = true;

    for (size_t i = 0; i < (mAcount + mBcount); i++) {
      //unpack new muon
      //variables: index, ietaext, ipt, qual, iphiext, iso, chrg, iphi, ieta

      // remove intermediate if required
      // index==0 and ietaext==0 are a necessary and sufficient condition
      uint32_t index = (bl->mu[i].s >> shifts::index) & masks::index;
      int32_t ietaext = ((bl->mu[i].f >> shifts::etaext) & masks::etaextv);
      if (((bl->mu[i].f >> shifts::etaext) & masks::etaexts) != 0)
        ietaext -= 256;

      if (excludeIntermediate && index == 0 && ietaext == 0)
        continue;

      //extract pt and quality and apply cut if required
      uint32_t ipt = (bl->mu[i].f >> shifts::pt) & masks::pt;
      //cuts??
      //        if((ipt-1)<ptcut) {discarded++; continue;}
      uint32_t qual = (bl->mu[i].f >> shifts::qual) & masks::qual;
      //        if(qual < qualcut) {discarded++; continue;}

      //extract integer value for extrapolated phi
      int32_t iphiext = ((bl->mu[i].f >> shifts::phiext) & masks::phiext);

      // extract iso bits and charge
      uint32_t iso = (bl->mu[i].s >> shifts::iso) & masks::iso;
      int32_t chrg = 0;
      if (((bl->mu[i].s >> shifts::chrgv) & masks::chrgv) == 1) {
        chrg = ((bl->mu[i].s >> shifts::chrg) & masks::chrg) == 1 ? -1 : 1;
      }

      // extract eta and phi at muon station
      int32_t iphi = ((bl->mu[i].s >> shifts::phi) & masks::phi);
      int32_t ieta = (bl->mu[i].s >> shifts::eta) & masks::etav;
      if (((bl->mu[i].s >> shifts::eta) & masks::etas) != 0)
        ieta -= 256;

      l1t::Muon muon(
          *dummyLVec_, ipt, ieta, iphi, qual, chrg, chrg != 0, iso, -1, 0, false, 0, 0, 0, 0, ietaext, iphiext);
      muons->push_back(bx, muon);
    }
  }
  std::cout << "end read ... " << o_test << std::endl << std::flush;
}  //unpackOrbit

versionCheck()

bool DataModeScoutingRun2Muon::versionCheck ( ) const

inlineoverridevirtual

Implements DataMode.

Definition at line 97 of file DAQSourceModelsScouting.h.

References detectedFRDversion_, and FRDHeaderMaxVersion.

{ return detectedFRDversion_ <= FRDHeaderMaxVersion; }

Member Data Documentation

daqProvenanceHelpers_

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

private

Definition at line 144 of file DAQSourceModelsScouting.h.

dataBlockAddr_

unsigned char* DataModeScoutingRun2Muon::dataBlockAddr_ = nullptr

private

Definition at line 151 of file DAQSourceModelsScouting.h.

Referenced by makeDataBlockView().

dataBlockMax_

size_t DataModeScoutingRun2Muon::dataBlockMax_ = 0

private

Definition at line 152 of file DAQSourceModelsScouting.h.

Referenced by makeDataBlockView().

detectedFRDversion_

uint16_t DataModeScoutingRun2Muon::detectedFRDversion_ = 0

private

Definition at line 145 of file DAQSourceModelsScouting.h.

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

dummyLVec_

std::unique_ptr<ROOT::Math::LorentzVector<ROOT::Math::PxPyPzE4D<double> > > DataModeScoutingRun2Muon::dummyLVec_

private

Definition at line 149 of file DAQSourceModelsScouting.h.

Referenced by DataModeScoutingRun2Muon().

event_

std::unique_ptr<FRDEventMsgView> DataModeScoutingRun2Muon::event_

private

Definition at line 147 of file DAQSourceModelsScouting.h.

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

eventCached_

bool DataModeScoutingRun2Muon::eventCached_ = false

private

Definition at line 153 of file DAQSourceModelsScouting.h.

Referenced by makeDataBlockView().

headerSize_

size_t DataModeScoutingRun2Muon::headerSize_ = 0

private

Definition at line 146 of file DAQSourceModelsScouting.h.