Inheritance diagram for L1CTJetFileWriter:

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

Public Member Functions inherited from edm::one::EDAnalyzer< edm::one::SharedResources >
	EDAnalyzer ()=default

	EDAnalyzer (const EDAnalyzer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const EDAnalyzer &	operator= (const EDAnalyzer &)=delete

bool	wantsGlobalLuminosityBlocks () const noexcept final

bool	wantsGlobalRuns () const noexcept final

bool	wantsInputProcessBlocks () const noexcept final

bool	wantsProcessBlocks () const noexcept final

Public Member Functions inherited from edm::one::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const noexcept

bool	wantsStreamRuns () const noexcept

	~EDAnalyzerBase () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ESResolverIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESResolverIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const *> const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices const &)

virtual	~EDConsumerBase () noexcept(false)

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

Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Member Functions
void	analyze (const edm::Event &, const edm::EventSetup &) override

std::vector< ap_uint< 64 > >	encodeJets (const std::vector< l1t::PFJet > jets, unsigned nJets)

std::vector< ap_uint< 64 > >	encodeSums (const std::vector< l1t::EtSum > sums, unsigned nSums)

void	endJob () override

Private Attributes
std::map< l1t::demo::LinkId, std::pair< l1t::demo::ChannelSpec, std::vector< size_t > > >	channelSpecsOutputToGT_

std::vector< edm::ParameterSet >	collections_

size_t	ctl2BoardTMUX_

l1t::demo::BoardDataWriter	fileWriterOutputToGT_

size_t	gapLengthOutput_

size_t	maxLinesPerFile_

size_t	nFramesPerBX_

std::vector< unsigned >	nJets_

std::vector< unsigned >	nSums_

std::vector< std::pair< edm::EDGetTokenT< edm::View< l1t::PFJet > >, edm::EDGetTokenT< edm::View< l1t::EtSum > > > >	tokens_

std::vector< std::pair< bool, bool > >	tokensToWrite_

Additional Inherited Members
Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

void	resetItemsToGetFrom (BranchType iType)

Detailed Description

Definition at line 26 of file L1CTJetFileWriter.cc.

Constructor & Destructor Documentation

◆ L1CTJetFileWriter()

L1CTJetFileWriter::L1CTJetFileWriter ( const edm::ParameterSet & iConfig )

explicit

Definition at line 55 of file L1CTJetFileWriter.cc.

References ctl2BoardTMUX_, and gapLengthOutput_.

     : collections_(iConfig.getParameter<std::vector<edm::ParameterSet>>("collections")),
       nFramesPerBX_(iConfig.getParameter<unsigned>("nFramesPerBX")),
       ctl2BoardTMUX_(iConfig.getParameter<unsigned>("TMUX")),
       gapLengthOutput_(iConfig.getParameter<unsigned>("gapLengthOutput")),
       maxLinesPerFile_(iConfig.getParameter<unsigned>("maxLinesPerFile")),
       channelSpecsOutputToGT_{{{"jets", 0}, {{ctl2BoardTMUX_, gapLengthOutput_}, {0}}}},
       fileWriterOutputToGT_(l1t::demo::parseFileFormat(iConfig.getParameter<std::string>("format")),
                             iConfig.getParameter<std::string>("outputFilename"),
                             iConfig.getParameter<std::string>("outputFileExtension"),
                             nFramesPerBX_,
                             ctl2BoardTMUX_,
                             maxLinesPerFile_,
                             channelSpecsOutputToGT_) {
   for (const auto& pset : collections_) {
     edm::EDGetTokenT<edm::View<l1t::PFJet>> jetToken;
     edm::EDGetTokenT<edm::View<l1t::EtSum>> mhtToken;
     unsigned nJets = pset.getParameter<unsigned>("nJets");
     unsigned nSums = pset.getParameter<unsigned>("nSums");
     nJets_.push_back(nJets);
     nSums_.push_back(nSums);
     bool writeJetToken(false), writeMhtToken(false);
     if (nJets > 0) {
       jetToken = consumes<edm::View<l1t::PFJet>>(pset.getParameter<edm::InputTag>("jets"));
       writeJetToken = true;
     }
     if (nSums > 0) {
       mhtToken = consumes<edm::View<l1t::EtSum>>(pset.getParameter<edm::InputTag>("mht"));
       writeMhtToken = true;
     }
     tokens_.emplace_back(jetToken, mhtToken);
     tokensToWrite_.emplace_back(writeJetToken, writeMhtToken);
   }
 }

Member Function Documentation

◆ analyze()

void L1CTJetFileWriter::analyze	(	const edm::Event &	iEvent,
		const edm::EventSetup &	iSetup
	)

overrideprivatevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 90 of file L1CTJetFileWriter.cc.

References l1t::demo::EventData::add(), l1t::demo::BoardDataWriter::addEvent(), collections_, filterCSVwithJSON::copy, encodeJets(), encodeSums(), fileWriterOutputToGT_, mps_fire::i, iEvent, dqmiolumiharvest::j, PDWG_EXODelayedJetMET_cff::jets, unpackData-CaloStage1::jetToken, l1tJetFileWriter_cfi::mht, nJets_, nSums_, tokens_, and tokensToWrite_.

                                                                                    {
   using namespace edm;
 
   // 1) Pack collections in the order they're specified. jets then sums within collection
   std::vector<ap_uint<64>> link_words;
   for (unsigned iCollection = 0; iCollection < collections_.size(); iCollection++) {
     if (tokensToWrite_.at(iCollection).first) {
       const auto& jetToken = tokens_.at(iCollection).first;
       // 2) Encode jet information onto vectors containing link data
       const edm::View<l1t::PFJet>& jets = iEvent.get(jetToken);
       std::vector<l1t::PFJet> sortedJets;
       sortedJets.reserve(jets.size());
       std::copy(jets.begin(), jets.end(), std::back_inserter(sortedJets));
 
       std::stable_sort(
           sortedJets.begin(), sortedJets.end(), [](l1t::PFJet i, l1t::PFJet j) { return (i.hwPt() > j.hwPt()); });
       const auto outputJets(encodeJets(sortedJets, nJets_.at(iCollection)));
       link_words.insert(link_words.end(), outputJets.begin(), outputJets.end());
     }
 
     if (tokensToWrite_.at(iCollection).second) {
       // 3) Encode sums onto vectors containing link data
       const auto& mhtToken = tokens_.at(iCollection).second;
       const edm::View<l1t::EtSum>& mht = iEvent.get(mhtToken);
       std::vector<l1t::EtSum> orderedSums;
       std::copy(mht.begin(), mht.end(), std::back_inserter(orderedSums));
       const auto outputSums(encodeSums(orderedSums, nSums_.at(iCollection)));
       link_words.insert(link_words.end(), outputSums.begin(), outputSums.end());
     }
   }
   // 4) Pack jet information into 'event data' object, and pass that to file writer
   l1t::demo::EventData eventDataJets;
   eventDataJets.add({"jets", 0}, link_words);
   fileWriterOutputToGT_.addEvent(eventDataJets);
 }

◆ encodeJets()

std::vector< ap_uint< 64 > > L1CTJetFileWriter::encodeJets	(	const std::vector< l1t::PFJet >	jets,
		unsigned	nJets
	)

private

Definition at line 132 of file L1CTJetFileWriter.cc.

References mps_fire::i, dqmiolumiharvest::j, PDWG_EXODelayedJetMET_cff::jets, SiStripPI::min, nJets, and parallelization::uint.

Referenced by analyze().

                                                                                                          {
   // Encode up to nJets jets, padded with 0s
   std::vector<ap_uint<64>> jet_words(2 * nJets, 0);  // allocate 2 words per jet
   for (unsigned i = 0; i < std::min(nJets, (uint)jets.size()); i++) {
     const l1t::PFJet& j = jets.at(i);
     jet_words[2 * i] = j.encodedJet()[0];
     jet_words[2 * i + 1] = j.encodedJet()[1];
   }
   return jet_words;
 }

◆ encodeSums()

std::vector< ap_uint< 64 > > L1CTJetFileWriter::encodeSums	(	const std::vector< l1t::EtSum >	sums,
		unsigned	nSums
	)

private

Definition at line 143 of file L1CTJetFileWriter.cc.

References mps_fire::i, l1tJetFileWriter_cfi::nSums, l1gt::Sum::pack_ap(), l1gt::Sum::scalar_pt, l1gt::Sum::valid, l1gt::Sum::vector_phi, and l1gt::Sum::vector_pt.

Referenced by analyze().

                                                                                                    {
   // Need two l1t::EtSum for each GT Sum
   std::vector<ap_uint<64>> sum_words;
   for (unsigned i = 0; i < nSums; i++) {
     if (2 * i < sums.size()) {
       l1gt::Sum gtSum;
       gtSum.valid = 1;  // if the sums are sent at all, they are valid
       gtSum.vector_pt.V = sums.at(2 * i + 1).hwPt();
       gtSum.vector_phi.V = sums.at(2 * i + 1).hwPhi();
       gtSum.scalar_pt.V = sums.at(2 * i).hwPt();
       sum_words.push_back(gtSum.pack_ap());
     } else {
       sum_words.push_back(0);
     }
   }
   return sum_words;
 }

◆ endJob()

void L1CTJetFileWriter::endJob ( void )

overrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 127 of file L1CTJetFileWriter.cc.

References fileWriterOutputToGT_, and l1t::demo::BoardDataWriter::flush().

                                {
   // Writing pending events to file before exiting
   fileWriterOutputToGT_.flush();
 }

◆ fillDescriptions()

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

static

Definition at line 162 of file L1CTJetFileWriter.cc.

References edm::ParameterSetDescription::add(), edm::ConfigurationDescriptions::addDefault(), edm::ParameterSetDescription::addOptional(), submitPVResolutionJobs::desc, AlCaHLTBitMon_QueryRunRegistry::string, and parallelization::uint.

                                                                                    {
   edm::ParameterSetDescription desc;
   {
     edm::ParameterSetDescription vpsd1;
     vpsd1.addOptional<edm::InputTag>("jets");
     vpsd1.addOptional<edm::InputTag>("mht");
     vpsd1.add<uint>("nJets", 0);
     vpsd1.add<uint>("nSums", 0);
     desc.addVPSet("collections", vpsd1);
   }
   desc.add<std::string>("outputFilename");
   desc.add<std::string>("outputFileExtension", "txt");
   desc.add<uint32_t>("nJets", 12);
   desc.add<uint32_t>("nFramesPerBX", 9);
   desc.add<uint32_t>("gapLengthOutput", 4);
   desc.add<uint32_t>("TMUX", 6);
   desc.add<uint32_t>("maxLinesPerFile", 1024);
   desc.add<std::string>("format", "EMPv2");
   descriptions.addDefault(desc);
 }

Member Data Documentation

◆ channelSpecsOutputToGT_

std::map<l1t::demo::LinkId, std::pair<l1t::demo::ChannelSpec, std::vector<size_t> > > L1CTJetFileWriter::channelSpecsOutputToGT_

private

Definition at line 40 of file L1CTJetFileWriter.cc.

◆ collections_

std::vector<edm::ParameterSet> L1CTJetFileWriter::collections_

private

Definition at line 34 of file L1CTJetFileWriter.cc.

Referenced by analyze().

◆ ctl2BoardTMUX_

size_t L1CTJetFileWriter::ctl2BoardTMUX_

private

Definition at line 37 of file L1CTJetFileWriter.cc.

Referenced by L1CTJetFileWriter().

◆ fileWriterOutputToGT_

l1t::demo::BoardDataWriter L1CTJetFileWriter::fileWriterOutputToGT_

private

Definition at line 48 of file L1CTJetFileWriter.cc.

Referenced by analyze(), and endJob().

◆ gapLengthOutput_

size_t L1CTJetFileWriter::gapLengthOutput_

private

Definition at line 38 of file L1CTJetFileWriter.cc.

Referenced by L1CTJetFileWriter().

◆ maxLinesPerFile_

size_t L1CTJetFileWriter::maxLinesPerFile_

private

Definition at line 39 of file L1CTJetFileWriter.cc.

◆ nFramesPerBX_

size_t L1CTJetFileWriter::nFramesPerBX_

private

Definition at line 36 of file L1CTJetFileWriter.cc.

◆ nJets_

std::vector<unsigned> L1CTJetFileWriter::nJets_

private

Definition at line 51 of file L1CTJetFileWriter.cc.

Referenced by analyze().

◆ nSums_

std::vector<unsigned> L1CTJetFileWriter::nSums_

private

Definition at line 52 of file L1CTJetFileWriter.cc.

Referenced by analyze().

◆ tokens_

std::vector<std::pair<edm::EDGetTokenT<edm::View<l1t::PFJet> >, edm::EDGetTokenT<edm::View<l1t::EtSum> > > > L1CTJetFileWriter::tokens_

private

Definition at line 49 of file L1CTJetFileWriter.cc.

Referenced by analyze().

◆ tokensToWrite_

std::vector<std::pair<bool, bool> > L1CTJetFileWriter::tokensToWrite_

private

Definition at line 50 of file L1CTJetFileWriter.cc.

Referenced by analyze().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ L1CTJetFileWriter()

Member Function Documentation

◆ analyze()

◆ encodeJets()

◆ encodeSums()

◆ endJob()

◆ fillDescriptions()

Member Data Documentation

◆ channelSpecsOutputToGT_

◆ collections_

◆ ctl2BoardTMUX_

◆ fileWriterOutputToGT_

◆ gapLengthOutput_

◆ maxLinesPerFile_

◆ nFramesPerBX_

◆ nJets_

◆ nSums_

◆ tokens_

◆ tokensToWrite_