Inheritance diagram for omtf::OmtfPacker:

Public Member Functions
void	beginRun (const edm::Run &run, const edm::EventSetup &es) override

	OmtfPacker (const edm::ParameterSet &pset)

void	produce (edm::Event &ev, const edm::EventSetup &es) override

	~OmtfPacker () 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 Attributes
edm::ParameterSet	theConfig

CscPacker	theCscPacker

edm::EDGetTokenT< CSCCorrelatedLCTDigiCollection >	theCscToken

DtPacker	theDtPacker

edm::EDGetTokenT< L1MuDTChambPhContainer >	theDtPhToken

edm::EDGetTokenT< L1MuDTChambThContainer >	theDtThToken

unsigned long	theEventCounter

std::string	theOutputTag

RpcPacker	theRpcPacker

edm::EDGetTokenT< RPCDigiCollection >	theRpcToken

bool	theSkipCsc

bool	theSkipDt

bool	theSkipRpc

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 46 of file OmtfPacker.cc.

Constructor & Destructor Documentation

◆ OmtfPacker()

omtf::OmtfPacker::OmtfPacker ( const edm::ParameterSet & pset )

Definition at line 76 of file OmtfPacker.cc.

                                                     : theConfig(pset), theEventCounter(0) {
     theOutputTag = pset.getParameter<std::string>("outputTag");
  
     produces<FEDRawDataCollection>(theOutputTag);
  
     theRpcToken = consumes<RPCDigiCollection>(pset.getParameter<edm::InputTag>("rpcInputLabel"));
     theCscToken = consumes<CSCCorrelatedLCTDigiCollection>(pset.getParameter<edm::InputTag>("cscInputLabel"));
     theDtPhToken = consumes<L1MuDTChambPhContainer>(pset.getParameter<edm::InputTag>("dtPhInputLabel"));
     theDtThToken = consumes<L1MuDTChambThContainer>(pset.getParameter<edm::InputTag>("dtThInputLabel"));
  
     theSkipDt = pset.getParameter<bool>("skipDt");
     theSkipRpc = pset.getParameter<bool>("skipRpc");
     theSkipCsc = pset.getParameter<bool>("skipCsc");
   }

References muonDTDigis_cfi::pset, AlCaHLTBitMon_QueryRunRegistry::string, theCscToken, theDtPhToken, theDtThToken, theOutputTag, theRpcToken, theSkipCsc, theSkipDt, and theSkipRpc.

◆ ~OmtfPacker()

omtf::OmtfPacker::~OmtfPacker ( )

inlineoverride

Definition at line 50 of file OmtfPacker.cc.

50 {}

Member Function Documentation

◆ beginRun()

void omtf::OmtfPacker::beginRun	(	const edm::Run &	run,
		const edm::EventSetup &	es
	)

override

Definition at line 106 of file OmtfPacker.cc.

                                                                       {
     //
     // initialise RPC packer
     //
     if (!theSkipRpc) {
       if (theConfig.getParameter<bool>("useRpcConnectionFile")) {
         theRpcPacker.init(es, edm::FileInPath(theConfig.getParameter<std::string>("rpcConnectionFile")).fullPath());
       } else {
         theRpcPacker.init(es);
       }
     }
  
     //
     // init CSC Link map
     //
     if (!theSkipCsc)
       theCscPacker.init();
   }

References edm::FileInPath::fullPath(), edm::ParameterSet::getParameter(), omtf::CscPacker::init(), omtf::RpcPacker::init(), AlCaHLTBitMon_QueryRunRegistry::string, theConfig, theCscPacker, theRpcPacker, theSkipCsc, and theSkipRpc.

◆ fillDescriptions()

void omtf::OmtfPacker::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 91 of file OmtfPacker.cc.

                                                                               {
     edm::ParameterSetDescription desc;
     desc.add<edm::InputTag>("rpcInputLabel", edm::InputTag(""));
     desc.add<edm::InputTag>("cscInputLabel", edm::InputTag(""));
     desc.add<edm::InputTag>("dtPhInputLabel", edm::InputTag(""));
     desc.add<edm::InputTag>("dtThInputLabel", edm::InputTag(""));
     desc.add<bool>("skipRpc", false);
     desc.add<bool>("skipCsc", false);
     desc.add<bool>("skipDt", false);
     desc.add<bool>("useRpcConnectionFile", false);
     desc.add<std::string>("rpcConnectionFile", "");
     desc.add<std::string>("outputTag", "");
     descriptions.add("omtfPacker", desc);
   }

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

◆ produce()

void omtf::OmtfPacker::produce	(	edm::Event &	ev,
		const edm::EventSetup &	es
	)

override

Definition at line 125 of file OmtfPacker.cc.

                                                                 {
     LogDebug("OmtfPacker::produce") << "Beginning To Pack Event: " << ++theEventCounter;
  
     //
     // prepare FedAmcRawsMap structure to collect Word64 raws from digi packers
     //
     FedAmcRawsMap raws;
     std::list<unsigned int> amcIds = {1, 3, 5, 7, 9, 11};
     std::list<unsigned int> fedIds = {1380, 1381};
     for (auto& fedId : fedIds) {
       for (auto& amcId : amcIds) {
         raws[std::make_pair(fedId, amcId)];
       }
     }
  
     //
     // DT raws
     //
     if (!theSkipDt) {
       edm::Handle<L1MuDTChambPhContainer> digiCollectionDTPh;
       ev.getByToken(theDtPhToken, digiCollectionDTPh);
       edm::Handle<L1MuDTChambThContainer> digiCollectionDTTh;
       ev.getByToken(theDtThToken, digiCollectionDTTh);
       theDtPacker.pack(digiCollectionDTPh.product(), digiCollectionDTTh.product(), raws);
     }
  
     //
     // csc raws
     //
     if (!theSkipCsc) {
       edm::Handle<CSCCorrelatedLCTDigiCollection> digiCollectionCSC;
       ev.getByToken(theCscToken, digiCollectionCSC);
       theCscPacker.pack(digiCollectionCSC.product(), raws);
     }
  
     //
     // rpc raws
     //
     if (!theSkipRpc) {
       edm::Handle<RPCDigiCollection> digiCollectionRPC;
       ev.getByToken(theRpcToken, digiCollectionRPC);
       theRpcPacker.pack(digiCollectionRPC.product(), raws);
     }
  
     auto bxId = ev.bunchCrossing();
     auto evtId = ev.id().event();
     auto orbit = ev.eventAuxiliary().orbitNumber();
     std::unique_ptr<FEDRawDataCollection> raw_coll(new FEDRawDataCollection());
     for (auto& fedId : fedIds) {
       //
       // assign formatted raws to feds
       //
       amc13::Packet amc13;
       for (const auto& it : raws) {
         if (fedId != it.first.first)
           continue;
         const std::vector<Word64>& amcData = it.second;
         unsigned int amcId = it.first.second;
         for (const auto& raw : amcData) {
           std::ostringstream dataStr;
           if (DataWord64::csc == DataWord64::type(raw))
             dataStr << CscDataWord64(raw);
           if (DataWord64::dt == DataWord64::type(raw))
             dataStr << DtDataWord64(raw);
           if (DataWord64::rpc == DataWord64::type(raw))
             dataStr << RpcDataWord64(raw);
           if (DataWord64::omtf == DataWord64::type(raw))
             dataStr << MuonDataWord64(raw);
           LogTrace("") << " fed: " << fedId << " amcId: " << amcId << " RAW DATA: " << dataStr.str() << std::endl;
         }
         amc13.add(amcId, 43981, evtId, orbit, bxId, amcData);
       }
  
       FEDRawData& fed_data = raw_coll->FEDData(fedId);
  
       const unsigned int slinkHeaderSize = 8;
       const unsigned int slinkTrailerSize = 8;
       unsigned int size = (amc13.size()) * sizeof(Word64) + slinkHeaderSize + slinkTrailerSize;
       fed_data.resize(size);
       unsigned char* payload = fed_data.data();
       unsigned char* payload_start = payload;
  
       FEDHeader header(payload);
       const unsigned int evtType = 1;
       header.set(payload, evtType, evtId, bxId, fedId);
  
       amc13.write(ev, 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);
     }
     ev.put(std::move(raw_coll), theOutputTag);
   }

References evf::compute_crc(), omtf::DataWord64::csc, FEDRawData::data(), omtf::DataWord64::dt, ev, l1tstage2_dqm_sourceclient-live_cfg::fedId, L1TStage2BMTF_cff::fedIds, EcalFEDMonitor_cfi::FEDRawDataCollection, RecoTauValidation_cfi::header, LogDebug, LogTrace, eostools::move(), omtf::DataWord64::omtf, omtf::DtPacker::pack(), omtf::CscPacker::pack(), omtf::RpcPacker::pack(), jets_cff::payload, edm::Handle< T >::product(), FEDRawData::resize(), omtf::DataWord64::rpc, FEDTrailer::set(), findQualityFiles::size, theCscPacker, theCscToken, theDtPacker, theDtPhToken, theDtThToken, theEventCounter, theOutputTag, theRpcPacker, theRpcToken, theSkipCsc, theSkipDt, theSkipRpc, and omtf::DataWord64::type().

Member Data Documentation

◆ theConfig

edm::ParameterSet omtf::OmtfPacker::theConfig

private

Definition at line 59 of file OmtfPacker.cc.

Referenced by beginRun().

◆ theCscPacker

CscPacker omtf::OmtfPacker::theCscPacker

private

Definition at line 71 of file OmtfPacker.cc.

Referenced by beginRun(), and produce().

◆ theCscToken

edm::EDGetTokenT<CSCCorrelatedLCTDigiCollection> omtf::OmtfPacker::theCscToken

private

Definition at line 67 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theDtPacker

DtPacker omtf::OmtfPacker::theDtPacker

private

Definition at line 73 of file OmtfPacker.cc.

Referenced by produce().

◆ theDtPhToken

edm::EDGetTokenT<L1MuDTChambPhContainer> omtf::OmtfPacker::theDtPhToken

private

Definition at line 69 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theDtThToken

edm::EDGetTokenT<L1MuDTChambThContainer> omtf::OmtfPacker::theDtThToken

private

Definition at line 68 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theEventCounter

unsigned long omtf::OmtfPacker::theEventCounter

private

Definition at line 60 of file OmtfPacker.cc.

Referenced by produce().

◆ theOutputTag

std::string omtf::OmtfPacker::theOutputTag

private

Definition at line 62 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theRpcPacker

RpcPacker omtf::OmtfPacker::theRpcPacker

private

Definition at line 72 of file OmtfPacker.cc.

Referenced by beginRun(), and produce().

◆ theRpcToken

edm::EDGetTokenT<RPCDigiCollection> omtf::OmtfPacker::theRpcToken

private

Definition at line 66 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theSkipCsc

bool omtf::OmtfPacker::theSkipCsc

private

Definition at line 64 of file OmtfPacker.cc.

Referenced by beginRun(), OmtfPacker(), and produce().

◆ theSkipDt

bool omtf::OmtfPacker::theSkipDt

private

Definition at line 64 of file OmtfPacker.cc.

Referenced by OmtfPacker(), and produce().

◆ theSkipRpc

bool omtf::OmtfPacker::theSkipRpc

private

Definition at line 64 of file OmtfPacker.cc.

Referenced by beginRun(), OmtfPacker(), and produce().

Public Member Functions

Static Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ OmtfPacker()

◆ ~OmtfPacker()

Member Function Documentation

◆ beginRun()

◆ fillDescriptions()

◆ produce()

Member Data Documentation

◆ theConfig

◆ theCscPacker

◆ theCscToken

◆ theDtPacker

◆ theDtPhToken

◆ theDtThToken

◆ theEventCounter

◆ theOutputTag

◆ theRpcPacker

◆ theRpcToken

◆ theSkipCsc

◆ theSkipDt

◆ theSkipRpc