#include <RPCPackingModule.h>

Inheritance diagram for RPCPackingModule:

Public Member Functions
virtual void	produce (edm::Event &, const edm::EventSetup &)
	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::EDProducer
	EDProducer ()

ModuleDescription const &	moduleDescription () const

virtual	~EDProducer ()

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

	ProducerBase ()

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

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

virtual	~ProducerBase ()

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

	EDConsumerBase ()

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

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

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

std::vector < ProductHolderIndexAndSkipBit > const &	itemsToGetFromEvent () const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesDependentUpon (const std::string &iProcessName, std::vector< const char * > &oModuleLabels) const

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

bool	registeredToConsume (ProductHolderIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	updateLookup (BranchType iBranchType, ProductHolderIndexHelper const &)

virtual	~EDConsumerBase ()

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::EDProducer
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 &)

Private Attributes
edm::EDGetTokenT < RPCDigiCollection >	dataLabel_

unsigned long	eventCounter_

const RPCReadOutMapping *	theCabling

Additional Inherited Members
Public Types inherited from edm::EDProducer
typedef EDProducer	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 23 of file RPCPackingModule.h.

Constructor & Destructor Documentation

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

explicit

ctor

Definition at line 35 of file RPCPackingModule.cc.

References dataLabel_, edm::ParameterSet::getParameter(), and theCabling.

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

RPCPackingModule::~RPCPackingModule ( )

virtual

dtor

Definition at line 45 of file RPCPackingModule.cc.

References theCabling.

 {
   delete theCabling;
 }

Member Function Documentation

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

static

Definition at line 147 of file RPCPackingModule.cc.

References HLT_25ns14e33_v1_cff::fedId, 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
	)

virtual

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

Implements edm::EDProducer.

Definition at line 51 of file RPCPackingModule.cc.

References edm::ESWatcher< T >::check(), dataLabel_, reco_application_2006_simpleTBanalysis_cfg::digiCollection, edm::EventID::event(), eventCounter_, edm::EventSetup::get(), edm::Event::getByToken(), edm::EventBase::id(), LogDebug, LogTrace, edm::Handle< T >::product(), edm::Event::put(), rawData(), theCabling, and RPCReadOutMapping::version().

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

 {
   eventCounter_++;
   LogInfo("RPCPackingModule") << "[RPCPackingModule::produce] " 
                               << "event counter: " << eventCounter_;
 
   Handle< RPCDigiCollection > digiCollection;
   ev.getByToken(dataLabel_,digiCollection);
   LogDebug("") << DebugDigisPrintout()(digiCollection.product());
 
   static edm::ESWatcher<RPCEMapRcd> recordWatcher; 
   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_ptr<FEDRawDataCollection> buffers( new 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( buffers );  
 }

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

private

Definition at line 90 of file RPCPackingModule.cc.

References rpcrawtodigi::DataRecord::data(), FEDRawData::data(), relativeConstraints::empty, eventRecords(), HLT_25ns14e33_v1_cff::fedId, 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;
 }