MuonUnpacker.cc

Go to the documentation of this file.

#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/Utilities/interface/Exception.h"
#include "EventFilter/L1TRawToDigi/plugins/UnpackerFactory.h"

#include "L1Trigger/L1TMuon/interface/MuonRawDigiTranslator.h"

#include "MuonUnpacker.h"

namespace l1t {
  namespace stage2 {
    MuonUnpacker::MuonUnpacker() : muonCollection_(nullptr), muonShowerCollection_(nullptr), muonCopy_(0) {}

    bool MuonUnpacker::unpack(const Block& block, UnpackerCollections* coll) {
      LogDebug("L1T") << "Block ID  = " << block.header().getID() << " size = " << block.header().getSize();
      // process only if there is a payload
      // If all BX block were zero suppressed the block header size is 0.
      if (block.header().getSize() < 1) {
        return true;
      }

      auto payload = block.payload();

      int nBX, firstBX, lastBX;
      // Check if per BX zero suppression was enabled
      bool bxZsEnabled = ((block.header().getFlags() >> bxzs_enable_shift_) & 0x1) == 1;
      // Calculate the total number of BXs
      if (bxZsEnabled) {
        BxBlockHeader bxHeader(payload.at(0));
        nBX = bxHeader.getTotalBx();
      } else {
        nBX = int(ceil(block.header().getSize() / nWords_));
      }
      getBXRange(nBX, firstBX, lastBX);

      // Set the muon collection and the BX range
      muonCollection_ = static_cast<L1TObjectCollections*>(coll)->getMuons(muonCopy_);
      muonCollection_->setBXRange(firstBX, lastBX);
      // Set the muon shower collection and the BX range
      muonShowerCollection_ = static_cast<L1TObjectCollections*>(coll)->getMuonShowers(muonCopy_);
      muonShowerCollection_->setBXRange(firstBX, lastBX);

      LogDebug("L1T") << "nBX = " << nBX << " first BX = " << firstBX << " lastBX = " << lastBX;

      // Get the BX blocks and unpack them
      auto bxBlocks = block.getBxBlocks(nWords_, bxZsEnabled);
      for (const auto& bxBlock : bxBlocks) {
        // Throw an exception if finding a corrupt BX header with out of range BX numbers
        const auto bx = bxBlock.header().getBx();
        if (bx < firstBX || bx > lastBX) {
          throw cms::Exception("CorruptData")
              << "Corrupt RAW data from FED " << fed_ << ", AMC " << block.amc().getAMCNumber() << ". BX number " << bx
              << " in BX header is outside of the BX range [" << firstBX << "," << lastBX
              << "] defined in the block header.";
        }
        unpackBx(bx, bxBlock.payload(), block.header().getID());
      }
      return true;
    }

    void MuonUnpacker::unpackBx(int bx,
                                const std::vector<uint32_t>& payload,
                                unsigned int blockID,
                                unsigned int startIdx) {
      unsigned int i = startIdx + 2;  // Only words 2-5 are "standard" muon words.
      // Check if there are enough words left in the payload
      if (startIdx + nWords_ <= payload.size()) {
        // Unpacking showers.
        // The shower from uGMT is transmitted via four links, each link
        // carrying one of the bits of the shower. We therefore have to
        // determine which link we're looking at and act accordingly.
        // Output links are odd and input links are even.
        int link_offset{0};  // This is correct for the uGT unpacker
        if (fed_ == 1402) {  // For uGMT we have to adjust the block/link ID
          link_offset = 1;
        }
        unsigned linkID{(blockID - link_offset) / 2};

        // Try to get the shower for this BX and if it doesn't exist create an
        // empty one and push it in.
        // Note: We can't just create it for the first linkID, because in
        // prinicple there could be a case where that is removed by the ZS.
        MuonShower shower;
        if (!muonShowerCollection_->isEmpty(bx)) {
          shower = muonShowerCollection_->at(bx, 0);
          muonShowerCollection_->erase(bx, 0);
        }
        if (linkID == 0) {  // OneNominal shower
          shower.setOneNominalInTime(l1t::MuonRawDigiTranslator::showerFired(payload[i + 1], fed_, getAlgoVersion()));
        } else if (linkID == 1) {  // OneTight shower
          shower.setOneTightInTime(l1t::MuonRawDigiTranslator::showerFired(payload[i + 1], fed_, getAlgoVersion()));
        }

        if (shower.isValid()) {
          muonShowerCollection_->push_back(bx, shower);
        }

        for (unsigned nWord = 2; nWord < nWords_; nWord += 2) {  // Only words 2-5 are "standard" muon words.
          uint32_t raw_data_spare = payload[startIdx + 1];
          uint32_t raw_data_00_31 = payload[i++];
          uint32_t raw_data_32_63 = payload[i++];
          LogDebug("L1T") << "raw_data_spare = 0x" << hex << raw_data_spare << " raw_data_00_31 = 0x" << raw_data_00_31
                          << " raw_data_32_63 = 0x" << raw_data_32_63;
          // skip empty muons (hwPt == 0)
          if (((raw_data_00_31 >> l1t::MuonRawDigiTranslator::ptShift_) & l1t::MuonRawDigiTranslator::ptMask_) == 0) {
            LogDebug("L1T") << "Muon hwPt zero. Skip.";
            continue;
          }

          Muon mu;

          MuonRawDigiTranslator::fillMuon(
              mu, raw_data_spare, raw_data_00_31, raw_data_32_63, fed_, getAlgoVersion(), nWord / 2);

          LogDebug("L1T") << "Mu" << nWord / 2 << ": eta " << mu.hwEta() << " phi " << mu.hwPhi() << " pT " << mu.hwPt()
                          << " iso " << mu.hwIso() << " qual " << mu.hwQual() << " charge " << mu.hwCharge()
                          << " charge valid " << mu.hwChargeValid();

          muonCollection_->push_back(bx, mu);
        }
      } else {
        edm::LogWarning("L1T") << "Only " << payload.size() - i << " 32 bit words in this BX but " << nWords_
                               << " are required. Not unpacking the data for BX " << bx << ".";
      }
    }
  }  // namespace stage2
}  // namespace l1t

DEFINE_L1T_UNPACKER(l1t::stage2::MuonUnpacker);