#include <RPCTwinMuxDigiToRaw.h>

Inheritance diagram for RPCTwinMuxDigiToRaw:

Public Member Functions
void	beginRun (edm::Run const &run, edm::EventSetup const &setup) override

void	produce (edm::Event &event, edm::EventSetup const &setup) override

	RPCTwinMuxDigiToRaw (edm::ParameterSet const &config)

	~RPCTwinMuxDigiToRaw ()

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 &	itemsToGetFromEvent () 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 void	fillDescriptions (edm::ConfigurationDescriptions &descs)

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

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Protected Attributes
int	bx_max_

int	bx_min_

edm::EDGetTokenT< RPCDigiCollection >	digi_token_

edm::ESWatcher< RPCTwinMuxLinkMapRcd >	es_tm_link_map_watcher_

int	event_type_

std::map< int, std::vector< RPCAMCLink > >	fed_amcs_

bool	ignore_eod_

unsigned int	ufov_

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

Definition at line 23 of file RPCTwinMuxDigiToRaw.h.

Constructor & Destructor Documentation

RPCTwinMuxDigiToRaw::RPCTwinMuxDigiToRaw ( edm::ParameterSet const & config )

Definition at line 31 of file RPCTwinMuxDigiToRaw.cc.

References digi_token_, and edm::ParameterSet::getParameter().

     : bx_min_(config.getParameter<int>("bxMin"))
     , bx_max_(config.getParameter<int>("bxMax"))
     , ignore_eod_(config.getParameter<bool>("ignoreEOD"))
     , event_type_(config.getParameter<int>("eventType"))
     , ufov_(config.getParameter<unsigned int>("uFOV"))
 {
     produces<FEDRawDataCollection>();
     digi_token_ = consumes<RPCDigiCollection>(config.getParameter<edm::InputTag>("inputTag"));
 }

RPCTwinMuxDigiToRaw::~RPCTwinMuxDigiToRaw ( )

Definition at line 42 of file RPCTwinMuxDigiToRaw.cc.

43 {}

Member Function Documentation

void RPCTwinMuxDigiToRaw::beginRun	(	edm::Run const &	run,
		edm::EventSetup const &	setup
	)

overridevirtual

Reimplemented from edm::stream::EDProducerBase.

Definition at line 57 of file RPCTwinMuxDigiToRaw.cc.

References amc, edm::ESWatcher< T >::check(), es_tm_link_map_watcher_, fed_amcs_, edm::EventSetup::get(), RPCAMCLink::getFED(), RPCAMCLinkMap::getMap(), RPCAMCLink::setAMCInput(), and tier0::unique().

 {
     if (es_tm_link_map_watcher_.check(setup)) {
         edm::ESHandle<RPCAMCLinkMap> es_tm_link_map;
         setup.get<RPCTwinMuxLinkMapRcd>().get(es_tm_link_map);
         fed_amcs_.clear();
         for (auto const & tm_link : es_tm_link_map->getMap()) {
             RPCAMCLink amc(tm_link.first);
             amc.setAMCInput();
             fed_amcs_[amc.getFED()].push_back(amc);
         }
         for (auto & fed_amcs : fed_amcs_) {
             std::sort(fed_amcs.second.begin(), fed_amcs.second.end());
             fed_amcs.second.erase(std::unique(fed_amcs.second.begin(), fed_amcs.second.end()), fed_amcs.second.end());
         }
     }
 }

void RPCTwinMuxDigiToRaw::fillDescriptions ( edm::ConfigurationDescriptions & descs )

static

Definition at line 45 of file RPCTwinMuxDigiToRaw.cc.

References edm::ConfigurationDescriptions::add(), and edm::ParameterSetDescription::add().

 {
     edm::ParameterSetDescription desc;
     desc.add<edm::InputTag>("inputTag", edm::InputTag("simMuonRPCDigis", ""));
     desc.add<int>("bxMin", -2);
     desc.add<int>("bxMax", 2);
     desc.add<bool>("ignoreEOD", true);
     desc.add<int>("eventType", 1);
     desc.add<unsigned int>("uFOV", 1);
     descs.add("RPCTwinMuxDigiToRaw", desc);
 }

void RPCTwinMuxDigiToRaw::produce	(	edm::Event &	event,
		edm::EventSetup const &	setup
	)

overridevirtual

Implements edm::stream::EDProducerBase.

Definition at line 75 of file RPCTwinMuxDigiToRaw.cc.

References edm::EventBase::bunchCrossing(), bx_max_, bx_min_, evf::compute_crc(), FEDRawData::data(), data, DEFINE_FWK_MODULE, digi_token_, edm::EventID::event(), event_type_, fed_amcs_, edm::EventSetup::get(), RPCAMCLink::getAMCNumber(), RPCTwinMuxPacker::getRPCTwinMuxRecords(), edm::EventBase::id(), ignore_eod_, eostools::move(), FEDRawData::resize(), FEDTrailer::set(), FEDHeader::set(), rpctwinmux::TwinMuxHeader::setRPCBXWindow(), findQualityFiles::size, and ufov_.

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

 {
     // Get EventSetup Electronics Maps
     edm::ESHandle<RPCInverseAMCLinkMap> es_tm_link_map_;
     edm::ESHandle<RPCInverseLBLinkMap> es_lb_link_map;
 
     setup.get<RPCInverseTwinMuxLinkMapRcd>().get(es_tm_link_map_);
     setup.get<RPCInverseLBLinkMapRcd>().get(es_lb_link_map);
 
     // Get Digi Collection
     edm::Handle<RPCDigiCollection> digi_collection;
     event.getByToken(digi_token_, digi_collection);
 
     // Create output
     std::unique_ptr<FEDRawDataCollection> data_collection(new FEDRawDataCollection());
 
     std::map<RPCAMCLink, std::vector<std::pair<int, rpctwinmux::RPCRecord> > > amc_bx_tmrecord;
     RPCTwinMuxPacker::getRPCTwinMuxRecords(*es_lb_link_map, *es_tm_link_map_
                                            , bx_min_, bx_max_, event.bunchCrossing()
                                            , *digi_collection
                                            , amc_bx_tmrecord
                                            , ignore_eod_);
 
     std::map<int, FEDRawData> fed_data;
     // Loop over the FEDs
     for (std::pair<int, std::vector<RPCAMCLink> > const & fed_amcs : fed_amcs_) {
         FEDRawData & data = data_collection->FEDData(fed_amcs.first);
         unsigned int size(0);
 
         // FED Header + BLOCK Header (1 word + 1 word)
         data.resize((size + 2) * 8);
         // FED Header
         FEDHeader::set(data.data() + size * 8, event_type_, event.id().event(), event.bunchCrossing(), fed_amcs.first);
         ++size;
         // BLOCK Header
         rpctwinmux::BlockHeader block_header(ufov_, fed_amcs.second.size(), event.eventAuxiliary().orbitNumber());
         std::memcpy(data.data() + size * 8, &block_header.getRecord(), 8);
         ++size;
 
         // BLOCK AMC Content - 1 word each
         data.resize((size + fed_amcs.second.size()) * 8);
         unsigned int block_content_size(0);
         for (RPCAMCLink const & amc : fed_amcs.second) {
             std::map<RPCAMCLink, std::vector<std::pair<int, rpctwinmux::RPCRecord> > >::const_iterator bx_tmrecord(amc_bx_tmrecord.find(amc));
             unsigned int block_amc_size(3 + 2 * (bx_tmrecord == amc_bx_tmrecord.end() ? 0 : bx_tmrecord->second.size()));
             block_content_size += block_amc_size;
             rpctwinmux::BlockAMCContent amc_content(true
                                                     , true, true
                                                     , true, true, true, true, block_amc_size
                                                     , 0, amc.getAMCNumber()
                                                     , 0);
             std::memcpy(data.data() + size * 8, &amc_content.getRecord(), 8);
             ++size;
         }
 
         // AMC Payload - 2 words header, 1 word trailer, 2 words per RPCRecord
         data.resize((size + block_content_size) * 8);
         for (RPCAMCLink const & amc : fed_amcs.second) {
             // TwinMux Header
             std::map<RPCAMCLink, std::vector<std::pair<int, rpctwinmux::RPCRecord> > >::const_iterator bx_tmrecord(amc_bx_tmrecord.find(amc));
             unsigned int block_amc_size(3 + 2 * (bx_tmrecord == amc_bx_tmrecord.end() ? 0 : bx_tmrecord->second.size()));
 
             rpctwinmux::TwinMuxHeader tm_header(amc.getAMCNumber(), event.id().event(), event.bunchCrossing()
                                                 , block_amc_size
                                                 , event.eventAuxiliary().orbitNumber()
                                                 , 0);
             tm_header.setRPCBXWindow(bx_min_, bx_min_);
             std::memcpy(data.data() + size * 8, tm_header.getRecord(), 16);
             size += 2;
 
             if (bx_tmrecord != amc_bx_tmrecord.end()) {
                 for (std::vector<std::pair<int, rpctwinmux::RPCRecord> >::const_iterator tmrecord = bx_tmrecord->second.begin()
                          ; tmrecord != bx_tmrecord->second.end() ; ++tmrecord) {
                     std::memcpy(data.data() + size * 8, tmrecord->second.getRecord(), 16);
                     size += 2;
                 }
             }
 
             rpctwinmux::TwinMuxTrailer tm_trailer(0x0, event.id().event(),  3 + 2 * block_amc_size);
             std::memcpy(data.data() + size * 8, &tm_trailer.getRecord(), 8);
             ++size;
             // CRC32 not calculated (for now)
         }
 
         // BLOCK Trailer + FED Trailer (1 word + 1 word)
         data.resize((size + 2) * 8);
         // BLOCK Trailer
         rpctwinmux::BlockTrailer block_trailer(0x0, 0, event.id().event(), event.bunchCrossing());
         std::memcpy(data.data() + size * 8, &block_trailer.getRecord(), 8);
         ++size;
         // CRC32 not calculated (for now)
 
         // FED Trailer
         ++size;
         FEDTrailer::set(data.data() + (size - 1) * 8, size, 0x0, 0, 0);
         std::uint16_t crc(evf::compute_crc(data.data(), size * 8));
         FEDTrailer::set(data.data() + (size - 1) * 8, size, crc, 0, 0);
     }
 
     event.put(std::move(data_collection));
 }

Member Data Documentation

int RPCTwinMuxDigiToRaw::bx_max_

protected

Definition at line 38 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

int RPCTwinMuxDigiToRaw::bx_min_

protected

Definition at line 38 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

edm::EDGetTokenT<RPCDigiCollection> RPCTwinMuxDigiToRaw::digi_token_

protected

Definition at line 36 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce(), and RPCTwinMuxDigiToRaw().

edm::ESWatcher<RPCTwinMuxLinkMapRcd> RPCTwinMuxDigiToRaw::es_tm_link_map_watcher_

protected

Definition at line 43 of file RPCTwinMuxDigiToRaw.h.

Referenced by beginRun().

int RPCTwinMuxDigiToRaw::event_type_

protected

Definition at line 40 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

std::map<int, std::vector<RPCAMCLink> > RPCTwinMuxDigiToRaw::fed_amcs_

protected

Definition at line 44 of file RPCTwinMuxDigiToRaw.h.

Referenced by beginRun(), and produce().

bool RPCTwinMuxDigiToRaw::ignore_eod_

protected

Definition at line 39 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

unsigned int RPCTwinMuxDigiToRaw::ufov_

protected

Definition at line 41 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

Public Member Functions

Static Public Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation