l1t::L1TRawToDigi Class Reference

Inheritance diagram for l1t::L1TRawToDigi:

Public Member Functions
	L1TRawToDigi (const edm::ParameterSet &)
	~L1TRawToDigi () override
Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginProcessBlocks () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndProcessBlocks () const final
bool	hasAbilityToProduceInEndRuns () const final

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Private Member Functions
void	beginLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override
void	beginRun (edm::Run const &, edm::EventSetup const &) override
void	endLuminosityBlock (edm::LuminosityBlock const &, edm::EventSetup const &) override
void	endRun (edm::Run const &, edm::EventSetup const &) override
void	produce (edm::Event &, const edm::EventSetup &) override

Private Attributes
int	amc13HeaderSize_
int	amc13TrailerSize_
int	amcHeaderSize_
int	amcTrailerSize_
bool	ctp7_mode_
bool	debug_
unsigned int	dmxFwId_
edm::EDGetTokenT< FEDRawDataCollection >	fedData_
std::vector< int >	fedIds_
unsigned int	fwId_
bool	fwOverride_
unsigned int	minFeds_
bool	mtf7_mode_
std::unique_ptr< PackingSetup >	prov_
int	slinkHeaderSize_
int	slinkTrailerSize_
bool	tmtCheck_
int	warnsa_
int	warnsb_

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 45 of file L1TRawToDigi.cc.

Constructor & Destructor Documentation

L1TRawToDigi()

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

explicit

Definition at line 94 of file L1TRawToDigi.cc.

      : fedIds_(config.getParameter<std::vector<int>>("FedIds")),
        minFeds_(config.getParameter<unsigned int>("MinFeds")),
        fwId_(config.getParameter<unsigned int>("FWId")),
        dmxFwId_(config.getParameter<unsigned int>("DmxFWId")),
        fwOverride_(config.getParameter<bool>("FWOverride")),
        tmtCheck_(config.getParameter<bool>("TMTCheck")),
        ctp7_mode_(config.getUntrackedParameter<bool>("CTP7")),
        mtf7_mode_(config.getUntrackedParameter<bool>("MTF7")) {
    fedData_ = consumes<FEDRawDataCollection>(config.getParameter<edm::InputTag>("InputLabel"));
 
    if (ctp7_mode_ and mtf7_mode_) {
      throw cms::Exception("L1TRawToDigi") << "Can only use one unpacking mode concurrently!";
    }
 
    prov_ = PackingSetupFactory::get()->make(config.getParameter<std::string>("Setup"));
    prov_->registerProducts(producesCollector());
 
    slinkHeaderSize_ = config.getUntrackedParameter<int>("lenSlinkHeader");
    slinkTrailerSize_ = config.getUntrackedParameter<int>("lenSlinkTrailer");
    amcHeaderSize_ = config.getUntrackedParameter<int>("lenAMCHeader");
    amcTrailerSize_ = config.getUntrackedParameter<int>("lenAMCTrailer");
    amc13HeaderSize_ = config.getUntrackedParameter<int>("lenAMC13Header");
    amc13TrailerSize_ = config.getUntrackedParameter<int>("lenAMC13Trailer");
 
    debug_ = config.getUntrackedParameter<bool>("debug");
    warnsa_ = 0;
    warnsb_ = 0;
  }

References amc13HeaderSize_, amc13TrailerSize_, amcHeaderSize_, amcTrailerSize_, ctp7_mode_, debug_, Exception, fedData_, l1t::PackingSetupFactory::get(), l1t::PackingSetupFactory::make(), mtf7_mode_, prov_, slinkHeaderSize_, slinkTrailerSize_, AlCaHLTBitMon_QueryRunRegistry::string, warnsa_, and warnsb_.

~L1TRawToDigi()

L1TRawToDigi::~L1TRawToDigi ( )

override

Definition at line 124 of file L1TRawToDigi.cc.

{}

Member Function Documentation

beginLuminosityBlock()

void l1t::L1TRawToDigi::beginLuminosityBlock ( edm::LuminosityBlock const &  , edm::EventSetup const &    )

inlineoverrideprivate

Definition at line 57 of file L1TRawToDigi.cc.

{};

beginRun()

void l1t::L1TRawToDigi::beginRun ( edm::Run const &  , edm::EventSetup const &    )

inlineoverrideprivate

Definition at line 55 of file L1TRawToDigi.cc.

{};

endLuminosityBlock()

void l1t::L1TRawToDigi::endLuminosityBlock ( edm::LuminosityBlock const &  , edm::EventSetup const &    )

inlineoverrideprivate

Definition at line 58 of file L1TRawToDigi.cc.

{};

endRun()

void l1t::L1TRawToDigi::endRun ( edm::Run const &  , edm::EventSetup const &    )

inlineoverrideprivate

Definition at line 56 of file L1TRawToDigi.cc.

{};

fillDescriptions()

void L1TRawToDigi::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 293 of file L1TRawToDigi.cc.

                                                                                {
    edm::ParameterSetDescription desc;
    // These parameters are part of the L1T/HLT interface, avoid changing if possible:
    desc.add<std::vector<int>>("FedIds", {})->setComment("required parameter:  default value is invalid");
    desc.add<std::string>("Setup", "")->setComment("required parameter:  default value is invalid");
    // These parameters have well defined  default values and are not currently
    // part of the L1T/HLT interface.  They can be cleaned up or updated at will:
    desc.add<unsigned int>("FWId", 0)->setComment(
        "Ignored unless FWOverride is true.  Calo Stage1:  32 bits: if the first eight bits are 0xff, will read the "
        "74x MC format.\n");
    desc.add<unsigned int>("DmxFWId", 0)
        ->setComment(
            "Ignored unless FWOverride is true.  Calo Stage1:  32 bits: if the first eight bits are 0xff, will read "
            "the 74x MC format.\n");
    desc.add<bool>("FWOverride", false)->setComment("Firmware version should be taken as FWId parameters");
    desc.add<bool>("TMTCheck", true)->setComment("Flag for turning on/off Calo Layer 2 TMT node check");
    desc.addUntracked<bool>("CTP7", false);
    desc.addUntracked<bool>("MTF7", false);
    desc.add<edm::InputTag>("InputLabel", edm::InputTag("rawDataCollector"));
    desc.addUntracked<int>("lenSlinkHeader", 8);
    desc.addUntracked<int>("lenSlinkTrailer", 8);
    desc.addUntracked<int>("lenAMCHeader", 8);
    desc.addUntracked<int>("lenAMCTrailer", 0);
    desc.addUntracked<int>("lenAMC13Header", 8);
    desc.addUntracked<int>("lenAMC13Trailer", 8);
    desc.addUntracked<bool>("debug", false)->setComment("turn on verbose output");
    desc.add<unsigned int>("MinFeds", 0)
        ->setComment("optional parameter:  warn if less than MinFeds non-empty FED ids unpacked.");
    descriptions.add("l1tRawToDigi", desc);
  }

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, HLT_FULL_cff::InputTag, and AlCaHLTBitMon_QueryRunRegistry::string.

produce()

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

overrideprivate

Definition at line 131 of file L1TRawToDigi.cc.

                                                                        {
    using namespace edm;
 
    std::unique_ptr<UnpackerCollections> coll = prov_->getCollections(event);
 
    edm::Handle<FEDRawDataCollection> feds;
    event.getByToken(fedData_, feds);
 
    if (!feds.isValid()) {
      LogError("L1T") << "Cannot unpack: no FEDRawDataCollection found";
      return;
    }
 
    unsigned valid_count = 0;
    for (const auto& fedId : fedIds_) {
      const FEDRawData& l1tRcd = feds->FEDData(fedId);
 
      LogDebug("L1T") << "Found FEDRawDataCollection with ID " << fedId << " and size " << l1tRcd.size();
 
      if ((int)l1tRcd.size() < slinkHeaderSize_ + slinkTrailerSize_ + amc13HeaderSize_ + amc13TrailerSize_ +
                                   amcHeaderSize_ + amcTrailerSize_) {
        if (l1tRcd.size() > 0) {
          LogError("L1T") << "Cannot unpack: invalid L1T raw data (size = " << l1tRcd.size() << ") for ID " << fedId
                          << ". Returning empty collections!";
        } else if (warnsa_ < 5) {
          warnsa_++;
          LogInfo("L1T") << "During unpacking, encountered empty L1T raw data (size = " << l1tRcd.size()
                         << ") for FED ID " << fedId << ".";
        }
        continue;
      } else {
        valid_count++;
      }
 
      const unsigned char* data = l1tRcd.data();
      FEDHeader header(data);
 
      if (header.check()) {
        LogDebug("L1T") << "Found SLink header:"
                        << " Trigger type " << header.triggerType() << " L1 event ID " << header.lvl1ID()
                        << " BX Number " << header.bxID() << " FED source " << header.sourceID() << " FED version "
                        << header.version();
      } else {
        LogWarning("L1T") << "Did not find a SLink header!";
      }
 
      FEDTrailer trailer(data + (l1tRcd.size() - slinkTrailerSize_));
 
      if (trailer.check()) {
        LogDebug("L1T") << "Found SLink trailer:"
                        << " Length " << trailer.fragmentLength() << " CRC " << trailer.crc() << " Status "
                        << trailer.evtStatus() << " Throttling bits " << trailer.ttsBits();
      } else {
        LogWarning("L1T") << "Did not find a SLink trailer!";
      }
 
      // FIXME Hard-coded firmware version for first 74x MC campaigns.
      // Will account for differences in the AMC payload, MP7 payload,
      // and unpacker setup.
      bool legacy_mc = fwOverride_ && ((fwId_ >> 24) == 0xff);
 
      amc13::Packet packet;
      if (!packet.parse((const uint64_t*)data,
                        (const uint64_t*)(data + slinkHeaderSize_),
                        (l1tRcd.size() - slinkHeaderSize_ - slinkTrailerSize_) / 8,
                        header.lvl1ID(),
                        header.bxID(),
                        legacy_mc,
                        mtf7_mode_)) {
        LogError("L1T") << "Could not extract AMC13 Packet.";
        return;
      }
 
      for (auto& amc : packet.payload()) {
        if (amc.size() == 0)
          continue;
 
        auto payload64 = amc.data();
        const uint32_t* start = (const uint32_t*)payload64.get();
        // Want to have payload size in 32 bit words, but AMC measures
        // it in 64 bit words → factor 2.
        const uint32_t* end = start + (amc.size() * 2);
 
        std::unique_ptr<Payload> payload;
        if (ctp7_mode_) {
          LogDebug("L1T") << "Using CTP7 mode";
          // CTP7 uses userData in AMC header
          payload = std::make_unique<CTP7Payload>(start, end, amc.header());
        } else if (mtf7_mode_) {
          LogDebug("L1T") << "Using MTF7 mode";
          payload = std::make_unique<MTF7Payload>(start, end);
        } else {
          LogDebug("L1T") << "Using MP7 mode";
          payload = std::make_unique<MP7Payload>(start, end, legacy_mc);
        }
        unsigned fw = payload->getAlgorithmFWVersion();
        unsigned board = amc.blockHeader().getBoardID();
        unsigned amc_no = amc.blockHeader().getAMCNumber();
 
        // Let parameterset value override FW version
        if (fwOverride_) {
          if (fedId == 1360)
            fw = fwId_;
          else if (fedId == 1366)
            fw = dmxFwId_;
        }
 
        auto unpackers = prov_->getUnpackers(fedId, board, amc_no, fw);
 
        // getBlock() returns a non-null unique_ptr on success
        std::unique_ptr<Block> block;
        while ((block = payload->getBlock()).get()) {
          // only unpack the Calo Layer 2 MP TMT node if it has processed this BX
          unsigned tmtId = board - l1t::stage2::layer2::mp::offsetBoardId + 1;
          unsigned bxId = header.bxID();
          unsigned unpackTMT = (!tmtCheck_ || ((tmtId - 1) == ((bxId - 1 + 3) % 9)));
          unsigned isCaloL2TMT =
              (fedId == l1t::stage2::layer2::fedId && (amc_no != l1t::stage2::layer2::demux::amcSlotNum));
 
          if (!isCaloL2TMT || unpackTMT) {
            if (debug_) {
              std::cout << ">>> block to unpack <<<" << std::endl
                        << "hdr:  " << std::hex << std::setw(8) << std::setfill('0') << block->header().raw()
                        << std::dec << " (ID " << block->header().getID() << ", size " << block->header().getSize()
                        << ", CapID 0x" << std::hex << std::setw(2) << std::setfill('0') << block->header().getCapID()
                        << ")" << std::dec << std::endl;
              for (const auto& word : block->payload()) {
                if (debug_)
                  std::cout << "data: " << std::hex << std::setw(8) << std::setfill('0') << word << std::dec
                            << std::endl;
              }
            }
 
            auto unpacker = unpackers.find(block->header().getID());
 
            block->amc(amc.header());
 
            if (unpacker == unpackers.end()) {
              LogDebug("L1T") << "Cannot find an unpacker for"
                              << "\n\tblock: ID " << block->header().getID() << ", size " << block->header().getSize()
                              << "\n\tAMC: # " << amc_no << ", board ID 0x" << std::hex << board << std::dec
                              << "\n\tFED ID " << fedId << ", and FW ID " << fw;
              // TODO Handle error
            } else if (!unpacker->second->unpack(*block, coll.get())) {
              LogDebug("L1T") << "Error unpacking data for block ID " << block->header().getID() << ", AMC # " << amc_no
                              << ", board ID " << board << ", FED ID " << fedId << ", and FW ID " << fw << "!";
              // TODO Handle error
            }
          }
        }
      }
    }
    if (valid_count < minFeds_) {
      if (warnsb_ < 5) {
        warnsb_++;
        LogWarning("L1T") << "Unpacked " << valid_count << " non-empty FED IDs but minimum is set to " << minFeds_
                          << "\n";
      }
    }
  }

References amc13HeaderSize_, amc13TrailerSize_, amcHeaderSize_, l1t::stage2::layer2::demux::amcSlotNum, amcTrailerSize_, groupFilesInBlocks::block, FEDTrailer::check(), gather_cfg::cout, FEDTrailer::crc(), ctp7_mode_, FEDRawData::data(), data, debug_, TauDecayModes::dec, dmxFwId_, mps_fire::end, FEDTrailer::evtStatus(), fedData_, l1t::stage2::layer2::fedId, l1tstage2_dqm_sourceclient-live_cfg::fedId, fedIds_, l1tstage2emulator_dqm_sourceclient-live_cfg::feds, FEDTrailer::fragmentLength(), fwId_, fwOverride_, get, RecoTauValidation_cfi::header, LogDebug, minFeds_, mtf7_mode_, l1t::stage2::layer2::mp::offsetBoardId, amc13::Packet::parse(), jets_cff::payload, amc13::Packet::payload(), prov_, FEDRawData::size(), slinkHeaderSize_, slinkTrailerSize_, tmtCheck_, FEDTrailer::ttsBits(), dt_dqm_sourceclient_common_cff::unpackers, warnsa_, and warnsb_.

Member Data Documentation

amc13HeaderSize_

int l1t::L1TRawToDigi::amc13HeaderSize_

private

Definition at line 75 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

amc13TrailerSize_

int l1t::L1TRawToDigi::amc13TrailerSize_

private

Definition at line 76 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

amcHeaderSize_

int l1t::L1TRawToDigi::amcHeaderSize_

private

Definition at line 73 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

amcTrailerSize_

int l1t::L1TRawToDigi::amcTrailerSize_

private

Definition at line 74 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

ctp7_mode_

bool l1t::L1TRawToDigi::ctp7_mode_

private

Definition at line 80 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

debug_

bool l1t::L1TRawToDigi::debug_

private

Definition at line 82 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

dmxFwId_

unsigned int l1t::L1TRawToDigi::dmxFwId_

private

Definition at line 65 of file L1TRawToDigi.cc.

Referenced by produce().

fedData_

edm::EDGetTokenT<FEDRawDataCollection> l1t::L1TRawToDigi::fedData_

private

Definition at line 58 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

fedIds_

std::vector<int> l1t::L1TRawToDigi::fedIds_

private

Definition at line 62 of file L1TRawToDigi.cc.

Referenced by produce().

fwId_

unsigned int l1t::L1TRawToDigi::fwId_

private

Definition at line 64 of file L1TRawToDigi.cc.

Referenced by produce().

fwOverride_

bool l1t::L1TRawToDigi::fwOverride_

private

Definition at line 66 of file L1TRawToDigi.cc.

Referenced by produce().

minFeds_

unsigned int l1t::L1TRawToDigi::minFeds_

private

Definition at line 63 of file L1TRawToDigi.cc.

Referenced by produce().

mtf7_mode_

bool l1t::L1TRawToDigi::mtf7_mode_

private

Definition at line 81 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

prov_

std::unique_ptr<PackingSetup> l1t::L1TRawToDigi::prov_

private

Definition at line 68 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

slinkHeaderSize_

int l1t::L1TRawToDigi::slinkHeaderSize_

private

Definition at line 71 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

slinkTrailerSize_

int l1t::L1TRawToDigi::slinkTrailerSize_

private

Definition at line 72 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

tmtCheck_

bool l1t::L1TRawToDigi::tmtCheck_

private

Definition at line 78 of file L1TRawToDigi.cc.

Referenced by produce().

warnsa_

int l1t::L1TRawToDigi::warnsa_

private

Definition at line 83 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

warnsb_

int l1t::L1TRawToDigi::warnsb_

private

Definition at line 84 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().