RPCTwinMuxDigiToRaw Class Reference

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

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

Detailed Description

Definition at line 23 of file RPCTwinMuxDigiToRaw.h.

Constructor & Destructor Documentation

RPCTwinMuxDigiToRaw()

RPCTwinMuxDigiToRaw::RPCTwinMuxDigiToRaw

(

edm::ParameterSet const &

config

)

Definition at line 31 of file RPCTwinMuxDigiToRaw.cc.

    : 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"));
}

References digi_token_.

~RPCTwinMuxDigiToRaw()

RPCTwinMuxDigiToRaw::~RPCTwinMuxDigiToRaw ( )

override

Definition at line 41 of file RPCTwinMuxDigiToRaw.cc.

{}

Member Function Documentation

beginRun()

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

override

Definition at line 54 of file RPCTwinMuxDigiToRaw.cc.

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

References amc, edm::ESWatcher< T >::check(), es_tm_link_map_watcher_, fed_amcs_, get, RPCAMCLinkMap::getMap(), singleTopDQM_cfi::setup, and tier0::unique().

fillDescriptions()

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

static

Definition at line 43 of file RPCTwinMuxDigiToRaw.cc.

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

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

produce()

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

override

Definition at line 71 of file RPCTwinMuxDigiToRaw.cc.

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

References bx_max_, bx_min_, evf::compute_crc(), data, digi_token_, event_type_, fed_amcs_, EcalFEDMonitor_cfi::FEDRawDataCollection, get, RPCTwinMuxPacker::getRPCTwinMuxRecords(), ignore_eod_, eostools::move(), FEDHeader::set(), FEDTrailer::set(), rpctwinmux::TwinMuxHeader::setRPCBXWindow(), singleTopDQM_cfi::setup, findQualityFiles::size, and ufov_.

Member Data Documentation

bx_max_

int RPCTwinMuxDigiToRaw::bx_max_

protected

Definition at line 36 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

bx_min_

int RPCTwinMuxDigiToRaw::bx_min_

protected

Definition at line 36 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

digi_token_

edm::EDGetTokenT<RPCDigiCollection> RPCTwinMuxDigiToRaw::digi_token_

protected

Definition at line 34 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce(), and RPCTwinMuxDigiToRaw().

es_tm_link_map_watcher_

edm::ESWatcher<RPCTwinMuxLinkMapRcd> RPCTwinMuxDigiToRaw::es_tm_link_map_watcher_

protected

Definition at line 41 of file RPCTwinMuxDigiToRaw.h.

Referenced by beginRun().

event_type_

int RPCTwinMuxDigiToRaw::event_type_

protected

Definition at line 38 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

fed_amcs_

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

protected

Definition at line 42 of file RPCTwinMuxDigiToRaw.h.

Referenced by beginRun(), and produce().

ignore_eod_

bool RPCTwinMuxDigiToRaw::ignore_eod_

protected

Definition at line 37 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().

ufov_

unsigned int RPCTwinMuxDigiToRaw::ufov_

protected

Definition at line 39 of file RPCTwinMuxDigiToRaw.h.

Referenced by produce().