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

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

Definition at line 76 of file OmtfPacker.cc.

References edm::ParameterSet::getParameter(), AlCaHLTBitMon_QueryRunRegistry::string, theCscToken, theDtPhToken, theDtThToken, theOutputTag, theRpcToken, theSkipCsc, theSkipDt, and theSkipRpc.

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

omtf::OmtfPacker::~OmtfPacker ( )

inlineoverride

Definition at line 50 of file OmtfPacker.cc.

References beginRun(), ev, fillDescriptions(), produce(), and writedatasetfile::run.

50 {}

Member Function Documentation

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

override

Definition at line 106 of file OmtfPacker.cc.

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

Referenced by ~OmtfPacker().

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

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

static

Definition at line 91 of file OmtfPacker.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), HLT_2018_cff::InputTag, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by ~OmtfPacker().

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

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

override

Definition at line 125 of file OmtfPacker.cc.

References amc13::Packet::add(), edm::EventBase::bunchCrossing(), evf::compute_crc(), omtf::DataWord64::csc, FEDRawData::data(), DEFINE_FWK_MODULE, omtf::DataWord64::dt, edm::EventID::event(), edm::Event::eventAuxiliary(), l1tstage2_dqm_sourceclient-live_cfg::fedId, L1TStage2BMTF_cff::fedIds, EcalFEDMonitor_cfi::FEDRawDataCollection, edm::Event::getByToken(), RecoTauValidation_cfi::header, edm::EventBase::id(), LogDebug, LogTrace, eostools::move(), omtf::DataWord64::omtf, edm::EventAuxiliary::orbitNumber(), omtf::DtPacker::pack(), omtf::CscPacker::pack(), omtf::RpcPacker::pack(), jets_cff::payload, edm::Handle< T >::product(), edm::Event::put(), FEDRawData::resize(), omtf::DataWord64::rpc, FEDHeader::set(), FEDTrailer::set(), amc13::Packet::size(), findQualityFiles::size, theCscPacker, theCscToken, theDtPacker, theDtPhToken, theDtThToken, theEventCounter, theOutputTag, theRpcPacker, theRpcToken, theSkipCsc, theSkipDt, theSkipRpc, omtf::DataWord64::type(), and amc13::Packet::write().

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

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