#include <RPCPackingModule.h>

Inheritance diagram for RPCPackingModule:

Public Member Functions
virtual 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...

virtual	~RPCPackingModule ()
	dtor More...

Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default

Public Member Functions inherited from edm::stream::EDProducerBase
	EDProducerBase ()

ModuleDescription const &	moduleDescription () const

virtual	~EDProducerBase ()

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, std::unordered_multimap< std::string, edm::ProductResolverIndex > const &iIndicies, std::string const &moduleLabel)

virtual	~ProducerBase () noexcept(false)

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

virtual	~EDConsumerBase () noexcept(false)

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

Static Public Member Functions inherited from edm::stream::EDProducerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

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

Public Types inherited from edm::stream::EDProducerBase
typedef EDProducerAdaptorBase	ModuleType

Public Types inherited from edm::ProducerBase
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

Detailed Description

Driver class for digi to raw data conversions

Definition at line 26 of file RPCPackingModule.h.

Constructor & Destructor Documentation

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

explicit

ctor

Definition at line 33 of file RPCPackingModule.cc.

References edm::ParameterSet::getParameter().

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

RPCPackingModule::~RPCPackingModule ( )

virtual

dtor

Definition at line 42 of file RPCPackingModule.cc.

 {
   delete theCabling;
 }

Member Function Documentation

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

static

Definition at line 139 of file RPCPackingModule.cc.

References LogDebug, LogTrace, DetId::rawId(), and RPCRecordFormatter::recordPack().

Referenced by 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;
 }

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

overridevirtual

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

Definition at line 48 of file RPCPackingModule.cc.

References RPCEMap::convert(), hgcalDigitizer_cfi::digiCollection, edm::EventID::event(), edm::EventSetup::get(), edm::Event::getByToken(), edm::EventBase::id(), LogDebug, LogTrace, eostools::move(), edm::Handle< T >::product(), edm::Event::put(), and rawData().

Referenced by JSONExport.JsonExport::export(), HTMLExport.HTMLExport::export(), and HTMLExport.HTMLExportStatic::export().

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

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

private

Definition at line 82 of file RPCPackingModule.cc.

References rpcrawtodigi::DataRecord::data(), FEDRawData::data(), relativeConstraints::empty, eventRecords(), FEDTrailer::set(), FEDHeader::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

edm::EDGetTokenT<RPCDigiCollection> RPCPackingModule::dataLabel_

private

Definition at line 45 of file RPCPackingModule.h.

edm::ESWatcher<RPCEMapRcd> RPCPackingModule::recordWatcher_

private

Definition at line 46 of file RPCPackingModule.h.

const RPCReadOutMapping* RPCPackingModule::theCabling

private

Definition at line 47 of file RPCPackingModule.h.

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation