Inheritance diagram for l1t::L1TDigiToRaw:

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

	~L1TDigiToRaw () override

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

bool	hasAbilityToProduceInLumis () const final

bool	hasAbilityToProduceInRuns () 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
bool	ctp7_mode_

int	evtType_

int	fedId_

unsigned	fwId_

std::unique_ptr< PackingSetup >	setup_

int	slinkHeaderSize_

int	slinkTrailerSize_

std::unique_ptr< PackerTokens >	tokens_

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 47 of file L1TDigiToRaw.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 81 of file L1TDigiToRaw.cc.

References evtType_, fwId_, l1t::PackingSetupFactory::get(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), l1t::PackingSetupFactory::make(), setup_, slinkHeaderSize_, slinkTrailerSize_, AlCaHLTBitMon_QueryRunRegistry::string, and tokens_.

                                                            :
       fedId_(config.getParameter<int>("FedId")),
       ctp7_mode_(config.getUntrackedParameter<bool>("CTP7"))
    {
       // Register products
       produces<FEDRawDataCollection>();
 
       fwId_ = config.getParameter<unsigned int>("FWId");
       evtType_ = config.getUntrackedParameter<int>("eventType", 1);
 
       auto cc = edm::ConsumesCollector(consumesCollector());
 
       setup_ = PackingSetupFactory::get()->make(config.getParameter<std::string>("Setup"));
       tokens_ = setup_->registerConsumes(config, cc);
 
       slinkHeaderSize_ = config.getUntrackedParameter<int>("lenSlinkHeader", 8);
       slinkTrailerSize_ = config.getUntrackedParameter<int>("lenSlinkTrailer", 8);
    }

L1TDigiToRaw::~L1TDigiToRaw ( )

override

Definition at line 101 of file L1TDigiToRaw.cc.

102 {

103 }

Member Function Documentation

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

inlineoverrideprivate

Definition at line 61 of file L1TDigiToRaw.cc.

61 {};

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

inlineoverrideprivate

Definition at line 59 of file L1TDigiToRaw.cc.

59 {};

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

inlineoverrideprivate

Definition at line 62 of file L1TDigiToRaw.cc.

62 {};

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

inlineoverrideprivate

Definition at line 60 of file L1TDigiToRaw.cc.

60 {};

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

static

Definition at line 246 of file L1TDigiToRaw.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addOptional(), edm::ParameterSetDescription::addUntracked(), DEFINE_FWK_MODULE, l1t::PackingSetupFactory::fillDescription(), l1t::PackingSetupFactory::get(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                             {
      edm::ParameterSetDescription desc;
      desc.add<unsigned int>("FWId", -1);
      desc.add<int>("FedId");
      desc.addUntracked<int>("eventType", 1);
      desc.add<std::string>("Setup");
      desc.addOptional<edm::InputTag>("InputLabel",edm::InputTag(""));
      desc.addOptional<edm::InputTag>("InputLabel2",edm::InputTag(""));
      desc.addUntracked<int>("lenSlinkHeader", 8);
      desc.addUntracked<int>("lenSlinkTrailer", 8);
      desc.addUntracked<bool>("CTP7", false);
 
      PackingSetupFactory::get()->fillDescription(desc);
 
      descriptions.add("l1tDigiToRaw", desc);
    }

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

overrideprivate

Definition at line 107 of file L1TDigiToRaw.cc.

References amc13::Packet::add(), groupFilesInBlocks::block, gather_cfg::blocks, evf::compute_crc(), l1t::CTP7, ctp7_mode_, FEDRawData::data(), evtType_, fedId_, fwId_, RecoTauValidation_cfi::header, mps_fire::i, svgfig::load(), LogDebug, eostools::move(), jets_cff::payload, FEDRawData::resize(), alignCSCRings::s, FEDHeader::set(), FEDTrailer::set(), setup_, amc13::Packet::size(), findQualityFiles::size, slinkHeaderSize_, slinkTrailerSize_, jetUpdater_cfi::sort, tokens_, and amc13::Packet::write().

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

    {
       using namespace edm;
 
       LogDebug("L1T") << "Packing data with FED ID " << fedId_;
 
       amc13::Packet amc13;
 
       auto bxId = event.bunchCrossing();
       // Note: L1ID != event ID
       // See e.g. triggerCount vs. eventNumber
       // in EventFilter/FEDInterface/interface/FED1024.h
       // But the trigger count is not stored in cmssw event class
       auto evtId = event.id().event();
       auto orbit = event.eventAuxiliary().orbitNumber();
       LogDebug("L1T") << "Forming FED with metadata bxId=" << bxId << ", l1ID=" << evtId << ", orbit=" << orbit;
 
       // Create all the AMC payloads to pack into the AMC13
       for (const auto& item: setup_->getPackers(fedId_, fwId_)) {
          auto amc_no = item.first.first;
          auto board = item.first.second;
          auto packers = item.second;
 
          Blocks block_load;
          for (const auto& packer: packers) {
             LogDebug("L1T") << "Adding packed blocks";
             packer->setBoard(board);
             auto blocks = packer->pack(event, tokens_.get());
             block_load.insert(block_load.end(), blocks.begin(), blocks.end());
          }
 
          std::sort(block_load.begin(), block_load.end());
 
          LogDebug("L1T") << "Concatenating blocks";
 
          std::vector<uint32_t> load32;
          // CTP7 stores this info in AMC user header
          if ( not ctp7_mode_ ) {
             // TODO Infrastructure firmware version.  Currently not used.
             // Would change the way the payload has to be unpacked.
             load32.push_back(0);
             load32.push_back(fwId_);
          }
          for (const auto& block: block_load) {
             LogDebug("L1T") << "Adding block " << block.header().getID() << " with size " << block.payload().size();
             auto load = block.payload();
 
 #ifdef EDM_ML_DEBUG
             std::stringstream s("");
             s << "Block content:" << std::endl << std::hex << std::setfill('0');
             for (const auto& word: load)
                s << std::setw(8) << word << std::endl;
             LogDebug("L1T") << s.str();
 #endif
 
             if ( block.header().getType() == CTP7 ) {
               // Header is two words for CTP7, first word is just a magic
               load32.push_back(0xA110CA7E);
             }
             load32.push_back(block.header().raw());
             load32.insert(load32.end(), load.begin(), load.end());
          }
 
          LogDebug("L1T") << "Converting payload";
 
          std::vector<uint64_t> load64;
          for (unsigned int i = 0; i < load32.size(); i += 2) {
             uint64_t word = load32[i];
             if (i + 1 < load32.size()) {
                word |= static_cast<uint64_t>(load32[i + 1]) << 32;
             } else {
                word |= static_cast<uint64_t>(0xffffffff) << 32;
             }
             load64.push_back(word);
          }
 
          LogDebug("L1T") << "Creating AMC packet";
 
          unsigned amc_user_header = 0;
          if ( ctp7_mode_ ) amc_user_header = fwId_;
          amc13.add(amc_no, board, evtId, orbit, bxId, load64, amc_user_header);
       }
 
       std::unique_ptr<FEDRawDataCollection> raw_coll(new FEDRawDataCollection());
       FEDRawData& fed_data = raw_coll->FEDData(fedId_);
 
       unsigned int size = slinkHeaderSize_ + slinkTrailerSize_ + amc13.size() * 8;
       fed_data.resize(size);
       unsigned char * payload = fed_data.data();
       unsigned char * payload_start = payload;
 
       FEDHeader header(payload);
       header.set(payload, evtType_, evtId, bxId, fedId_);
 
       amc13.write(event, payload, slinkHeaderSize_, size - slinkHeaderSize_ - slinkTrailerSize_);
 
       payload += slinkHeaderSize_;
       payload += amc13.size() * 8;
 
       FEDTrailer trailer(payload);
       trailer.set(payload, size / 8, evf::compute_crc(payload_start, size), 0, 0);
 
       event.put(std::move(raw_coll));
    }