Inheritance diagram for l1t::L1TRawToDigi:

Public Member Functions
	L1TRawToDigi (const edm::ParameterSet &)

	~L1TRawToDigi () override

Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default

	EDProducer (const EDProducer &)=delete

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

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

Private Member Functions
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<>
using	CacheTypes = CacheContexts< T... >

using	GlobalCache = typename CacheTypes::GlobalCache

using	HasAbility = AbilityChecker< T... >

using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache

using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache

using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >

using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache

using	RunCache = typename CacheTypes::RunCache

using	RunContext = RunContextT< RunCache, GlobalCache >

using	RunSummaryCache = typename CacheTypes::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 89 of file L1TRawToDigi.cc.

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_.

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

◆ ~L1TRawToDigi()

L1TRawToDigi::~L1TRawToDigi ( )

override

Definition at line 119 of file L1TRawToDigi.cc.

119 {}

Member Function Documentation

◆ fillDescriptions()

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

static

Definition at line 288 of file L1TRawToDigi.cc.

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

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

◆ produce()

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

overrideprivate

Definition at line 126 of file L1TRawToDigi.cc.

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_, FEDTrailer::evtStatus(), fedData_, l1t::stage2::layer2::fedId, l1tstage2_dqm_sourceclient-live_cfg::fedId, fedIds_, l1tstage2emulator_dqm_sourceclient-live_cfg::feds, FEDTrailer::fragmentLength(), fwId_, fwOverride_, RecoTauValidation_cfi::header, LogDebug, minFeds_, mtf7_mode_, l1t::stage2::layer2::mp::offsetBoardId, amc13::Packet::parse(), jetsAK4_Puppi_cff::payload, amc13::Packet::payload(), prov_, FEDRawData::size(), slinkHeaderSize_, slinkTrailerSize_, command_line::start, tmtCheck_, FEDTrailer::ttsBits(), dt_dqm_sourceclient_common_cff::unpackers, warnsa_, and warnsb_.

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

Member Data Documentation

◆ amc13HeaderSize_

int l1t::L1TRawToDigi::amc13HeaderSize_

private

Definition at line 70 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ amc13TrailerSize_

int l1t::L1TRawToDigi::amc13TrailerSize_

private

Definition at line 71 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ amcHeaderSize_

int l1t::L1TRawToDigi::amcHeaderSize_

private

Definition at line 68 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ amcTrailerSize_

int l1t::L1TRawToDigi::amcTrailerSize_

private

Definition at line 69 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ ctp7_mode_

bool l1t::L1TRawToDigi::ctp7_mode_

private

Definition at line 75 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ debug_

bool l1t::L1TRawToDigi::debug_

private

Definition at line 77 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ dmxFwId_

unsigned int l1t::L1TRawToDigi::dmxFwId_

private

Definition at line 60 of file L1TRawToDigi.cc.

Referenced by produce().

◆ fedData_

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

private

Definition at line 56 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ fedIds_

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

private

Definition at line 57 of file L1TRawToDigi.cc.

Referenced by produce().

◆ fwId_

unsigned int l1t::L1TRawToDigi::fwId_

private

Definition at line 59 of file L1TRawToDigi.cc.

Referenced by produce().

◆ fwOverride_

bool l1t::L1TRawToDigi::fwOverride_

private

Definition at line 61 of file L1TRawToDigi.cc.

Referenced by produce().

◆ minFeds_

unsigned int l1t::L1TRawToDigi::minFeds_

private

Definition at line 58 of file L1TRawToDigi.cc.

Referenced by produce().

◆ mtf7_mode_

bool l1t::L1TRawToDigi::mtf7_mode_

private

Definition at line 76 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ prov_

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

private

Definition at line 63 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ slinkHeaderSize_

int l1t::L1TRawToDigi::slinkHeaderSize_

private

Definition at line 66 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ slinkTrailerSize_

int l1t::L1TRawToDigi::slinkTrailerSize_

private

Definition at line 67 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ tmtCheck_

bool l1t::L1TRawToDigi::tmtCheck_

private

Definition at line 73 of file L1TRawToDigi.cc.

Referenced by produce().

◆ warnsa_

int l1t::L1TRawToDigi::warnsa_

private

Definition at line 78 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

◆ warnsb_

int l1t::L1TRawToDigi::warnsb_

private

Definition at line 79 of file L1TRawToDigi.cc.

Referenced by L1TRawToDigi(), and produce().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ L1TRawToDigi()

◆ ~L1TRawToDigi()

Member Function Documentation

◆ fillDescriptions()

◆ produce()

Member Data Documentation

◆ amc13HeaderSize_

◆ amc13TrailerSize_

◆ amcHeaderSize_

◆ amcTrailerSize_

◆ ctp7_mode_

◆ debug_

◆ dmxFwId_

◆ fedData_

◆ fedIds_

◆ fwId_

◆ fwOverride_

◆ minFeds_

◆ mtf7_mode_

◆ prov_

◆ slinkHeaderSize_

◆ slinkTrailerSize_

◆ tmtCheck_

◆ warnsa_

◆ warnsb_