RPCPackingModule Class Reference

#include <RPCPackingModule.h>

Inheritance diagram for RPCPackingModule:

Public Member Functions
void	produce (edm::Event &, const edm::EventSetup &) override
	get data, convert to raw event, attach again to Event More...
	RPCPackingModule (const edm::ParameterSet &)
	ctor More...
	~RPCPackingModule () override
	dtor More...
Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndRuns () const final

Static Public Member Functions
static std::vector< rpcrawtodigi::EventRecords >	eventRecords (int fedId, int trigger_BX, const RPCDigiCollection *, const RPCRecordFormatter &)

Private Member Functions
FEDRawData *	rawData (int fedId, unsigned int lvl1_ID, const RPCDigiCollection *, const RPCRecordFormatter &) const

Private Attributes
edm::EDGetTokenT< RPCDigiCollection >	dataLabel_
edm::ESWatcher< RPCEMapRcd >	recordWatcher_
const RPCReadOutMapping *	theCabling

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
typedef CacheContexts< T... >	CacheTypes
typedef CacheTypes::GlobalCache	GlobalCache
typedef AbilityChecker< T... >	HasAbility
typedef CacheTypes::LuminosityBlockCache	LuminosityBlockCache
typedef LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >	LuminosityBlockContext
typedef CacheTypes::LuminosityBlockSummaryCache	LuminosityBlockSummaryCache
typedef CacheTypes::RunCache	RunCache
typedef RunContextT< RunCache, GlobalCache >	RunContext
typedef CacheTypes::RunSummaryCache	RunSummaryCache

Detailed Description

Driver class for digi to raw data conversions

Definition at line 32 of file RPCPackingModule.h.

Constructor & Destructor Documentation

RPCPackingModule()

RPCPackingModule::RPCPackingModule ( const edm::ParameterSet &  pset )

explicit

ctor

Definition at line 32 of file RPCPackingModule.cc.

                                                           {
  dataLabel_ = consumes<RPCDigiCollection>(pset.getParameter<edm::InputTag>("InputLabel"));
  theCabling = new RPCReadOutMapping("");
  produces<FEDRawDataCollection>();
}

References muonDTDigis_cfi::pset.

~RPCPackingModule()

RPCPackingModule::~RPCPackingModule ( )

override

dtor

Definition at line 38 of file RPCPackingModule.cc.

{ delete theCabling; }

Member Function Documentation

eventRecords()

vector< EventRecords > RPCPackingModule::eventRecords ( int  fedId, int  trigger_BX, const RPCDigiCollection *  digis, const RPCRecordFormatter &  formatter  )

static

Definition at line 129 of file RPCPackingModule.cc.

                                                                                         {
  typedef DigiContainerIterator<RPCDetId, RPCDigi> DigiRangeIterator;
  vector<EventRecords> dataRecords;
 
  LogDebug("RPCRawDataPacker") << "Packing Fed id=" << fedId;
  for (DigiRangeIterator it = digis->begin(); it != digis->end(); it++) {
    RPCDetId rpcDetId = (*it).first;
    uint32_t rawDetId = rpcDetId.rawId();
    RPCDigiCollection::Range range = digis->get(rpcDetId);
    for (vector<RPCDigi>::const_iterator id = range.first; id != range.second; id++) {
      const RPCDigi& digi = (*id);
      vector<EventRecords> rawFromDigi = formatter.recordPack(rawDetId, digi, trigger_BX);
      dataRecords.insert(dataRecords.end(), rawFromDigi.begin(), rawFromDigi.end());
    }
  }
 
  //
  // merge data words
  //
  LogTrace("RPCRawDataPacker") << " size of   data: " << dataRecords.size();
  vector<EventRecords> merged = EventRecords::mergeRecords(dataRecords);
  LogTrace("") << " size of megred: " << merged.size();
 
  return merged;
}

References l1tstage2_dqm_sourceclient-live_cfg::fedId, LogDebug, LogTrace, FastTimerService_cff::range, DetId::rawId(), and RPCRecordFormatter::recordPack().

Referenced by omtf::RpcPacker::pack(), and rawData().

produce()

void RPCPackingModule::produce ( edm::Event &  ev, const edm::EventSetup &  es  )

override

get data, convert to raw event, attach again to Event

Definition at line 40 of file RPCPackingModule.cc.

                                                                    {
  Handle<RPCDigiCollection> digiCollection;
  ev.getByToken(dataLabel_, digiCollection);
  LogDebug("") << DebugDigisPrintout()(digiCollection.product());
 
  if (recordWatcher_.check(es)) {
    delete theCabling;
    LogTrace("") << "record has CHANGED!!, initialise readout map!";
    ESHandle<RPCEMap> readoutMapping;
    es.get<RPCEMapRcd>().get(readoutMapping);
    theCabling = readoutMapping->convert();
    LogTrace("") << " READOUT MAP VERSION: " << theCabling->version() << endl;
  }
 
  auto buffers = std::make_unique<FEDRawDataCollection>();
 
  //  pair<int,int> rpcFEDS=FEDNumbering::getRPCFEDIds();
  pair<int, int> rpcFEDS(790, 792);
  for (int id = rpcFEDS.first; id <= rpcFEDS.second; ++id) {
    RPCRecordFormatter formatter(id, theCabling);
    unsigned int lvl1_ID = ev.id().event();
    FEDRawData* rawData = RPCPackingModule::rawData(id, lvl1_ID, digiCollection.product(), formatter);
    FEDRawData& fedRawData = buffers->FEDData(id);
 
    fedRawData = *rawData;
    delete rawData;
  }
  ev.put(std::move(buffers));
}

References RPCEMap::convert(), apvshotsanalyzer_cfi::digiCollection, ev, l1t_dqm_sourceclient-live_cfg::fedRawData, edm::EventSetup::get(), get, LogDebug, LogTrace, eostools::move(), rawData(), and l1tstage2_dqm_sourceclient-live_cfg::rawData.

rawData()

FEDRawData * RPCPackingModule::rawData ( int  fedId, unsigned int  lvl1_ID, const RPCDigiCollection *  digis, const RPCRecordFormatter &  formatter  ) const

private

Definition at line 70 of file RPCPackingModule.cc.

                                                                                 {
  //
  // get merged records
  //
  int trigger_BX = 200;  // FIXME - set event by event but correct bx assigment in digi
  vector<EventRecords> merged = RPCPackingModule::eventRecords(fedId, trigger_BX, digis, formatter);
 
  //
  // create data words
  //
  vector<Word64> dataWords;
  EmptyWord empty;
  typedef vector<EventRecords>::const_iterator IR;
  for (IR ir = merged.begin(), irEnd = merged.end(); ir != irEnd; ++ir) {
    Word64 w = (((Word64(ir->recordBX().data()) << 16) | ir->recordSLD().data()) << 16 | ir->recordCD().data()) << 16 |
               empty.data();
    dataWords.push_back(w);
  }
 
  //
  // create raw data
  //
  int nHeaders = 1;
  int nTrailers = 1;
  int dataSize = (nHeaders + nTrailers + dataWords.size()) * sizeof(Word64);
  FEDRawData* raw = new FEDRawData(dataSize);
 
  //
  // add header
  //
  unsigned char* pHeader = raw->data();
  int evt_ty = 3;
  int source_ID = fedId;
  FEDHeader::set(pHeader, evt_ty, lvl1_ID, trigger_BX, source_ID);
 
  //
  // add datawords
  //
  for (unsigned int idata = 0; idata < dataWords.size(); idata++) {
    Word64* word = reinterpret_cast<Word64*>(pHeader + (idata + 1) * sizeof(Word64));
    *word = dataWords[idata];
  }
 
  //
  // add trailer
  //
  unsigned char* pTrailer = pHeader + raw->size() - sizeof(Word64);
  int crc = 0;
  int evt_stat = 15;
  int tts = 0;
  int datasize = raw->size() / sizeof(Word64);
  FEDTrailer::set(pTrailer, datasize, crc, evt_stat, tts);
 
  return raw;
}

References FEDRawData::data(), std::empty(), eventRecords(), l1tstage2_dqm_sourceclient-live_cfg::fedId, FEDHeader::set(), FEDTrailer::set(), FEDRawData::size(), and w.

Referenced by produce().

Member Data Documentation

dataLabel_

edm::EDGetTokenT<RPCDigiCollection> RPCPackingModule::dataLabel_

private

Definition at line 52 of file RPCPackingModule.h.

recordWatcher_

edm::ESWatcher<RPCEMapRcd> RPCPackingModule::recordWatcher_

private

Definition at line 53 of file RPCPackingModule.h.

theCabling

const RPCReadOutMapping* RPCPackingModule::theCabling

private

Definition at line 54 of file RPCPackingModule.h.