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	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () 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(), edm::ParameterSetDescription::add(), HLT_2018_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