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
	EDProducer (const EDProducer &)=delete
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginProcessBlocks () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndProcessBlocks () const final
bool	hasAbilityToProduceInEndRuns () const final
const EDProducer &	operator= (const EDProducer &)=delete

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::ESGetToken< RPCEMap, RPCEMapRcd >	readoutMappingToken_
edm::ESWatcher< RPCEMapRcd >	recordWatcher_
const RPCReadOutMapping *	theCabling

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

Detailed Description

Driver class for digi to raw data conversions

Definition at line 34 of file RPCPackingModule.h.

Constructor & Destructor Documentation

RPCPackingModule()

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

explicit

ctor

Definition at line 31 of file RPCPackingModule.cc.

References muonDTDigis_cfi::pset.

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

~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 128 of file RPCPackingModule.cc.

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

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

                                                                                         {
  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;
}

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.

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

                                                                    {
  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.getHandle(readoutMappingToken_);
    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));
}

rawData()

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

private

Definition at line 69 of file RPCPackingModule.cc.

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

Referenced by produce().

                                                                                 {
  //
  // 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;
}

Member Data Documentation

dataLabel_

edm::EDGetTokenT<RPCDigiCollection> RPCPackingModule::dataLabel_

private

Definition at line 54 of file RPCPackingModule.h.

readoutMappingToken_

edm::ESGetToken<RPCEMap, RPCEMapRcd> RPCPackingModule::readoutMappingToken_

private

Definition at line 57 of file RPCPackingModule.h.

recordWatcher_

edm::ESWatcher<RPCEMapRcd> RPCPackingModule::recordWatcher_

private

Definition at line 55 of file RPCPackingModule.h.

theCabling

const RPCReadOutMapping* RPCPackingModule::theCabling

private

Definition at line 56 of file RPCPackingModule.h.