#include <DPGAnalysis/SiStripTools/src/EventWithHistoryProducerFromL1ABC.cc>

Inheritance diagram for EventWithHistoryProducerFromL1ABC:

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

	~EventWithHistoryProducerFromL1ABC () override

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

	EDProducer (const EDProducer &)=delete

bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginProcessBlocks () const final

bool	hasAbilityToProduceInBeginRuns () const final

bool	hasAbilityToProduceInEndLumis () const final

bool	hasAbilityToProduceInEndProcessBlocks () const final

bool	hasAbilityToProduceInEndRuns () const final

const EDProducer &	operator= (const EDProducer &)=delete

Private Member Functions
void	beginRun (const edm::Run &, const edm::EventSetup &) override

void	endRun (const edm::Run &, const edm::EventSetup &) override

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

Private Attributes
edm::EventNumber_t	_curroffevent

long long	_curroffset

const bool	_forceNoOffset

const bool	_forceSCAL

edm::EDGetTokenT< L1AcceptBunchCrossingCollection >	_l1abccollectionToken

std::map< edm::EventNumber_t, long long >	_offsets

edm::EDGetTokenT< TCDSRecord >	_tcdsRecordToken

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer<>
using	CacheTypes = CacheContexts< T... >

using	GlobalCache = typename CacheTypes::GlobalCache

using	HasAbility = AbilityChecker< T... >

using	InputProcessBlockCache = typename CacheTypes::InputProcessBlockCache

using	LuminosityBlockCache = typename CacheTypes::LuminosityBlockCache

using	LuminosityBlockContext = LuminosityBlockContextT< LuminosityBlockCache, RunCache, GlobalCache >

using	LuminosityBlockSummaryCache = typename CacheTypes::LuminosityBlockSummaryCache

using	RunCache = typename CacheTypes::RunCache

using	RunContext = RunContextT< RunCache, GlobalCache >

using	RunSummaryCache = typename CacheTypes::RunSummaryCache

Detailed Description

Description: <one line="" class="" summary>="">

Implementation: <Notes on="" implementation>="">

Definition at line 43 of file EventWithHistoryProducerFromL1ABC.cc.

Constructor & Destructor Documentation

◆ EventWithHistoryProducerFromL1ABC()

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

explicit

Definition at line 75 of file EventWithHistoryProducerFromL1ABC.cc.

References _forceNoOffset.

     : _l1abccollectionToken(
           mayConsume<L1AcceptBunchCrossingCollection>(iConfig.getParameter<edm::InputTag>("l1ABCCollection"))),
       _tcdsRecordToken(mayConsume<TCDSRecord>(iConfig.getParameter<edm::InputTag>("tcdsRecordLabel"))),
       _forceNoOffset(iConfig.getUntrackedParameter<bool>("forceNoOffset", false)),
       _forceSCAL(iConfig.getParameter<bool>("forceSCAL")),
       _offsets(),
       _curroffset(0),
       _curroffevent(0) {
   if (_forceNoOffset)
     edm::LogWarning("NoOffsetComputation") << "Orbit and BX offset will NOT be computed: Be careful!";
 
   produces<EventWithHistory>();
 
   //now do what ever other initialization is needed
 }

◆ ~EventWithHistoryProducerFromL1ABC()

EventWithHistoryProducerFromL1ABC::~EventWithHistoryProducerFromL1ABC ( )

override

Definition at line 92 of file EventWithHistoryProducerFromL1ABC.cc.

                                                                       {
   // do anything here that needs to be done at desctruction time
   // (e.g. close files, deallocate resources etc.)
 }

Member Function Documentation

◆ beginRun()

void EventWithHistoryProducerFromL1ABC::beginRun	(	const edm::Run &	,
		const edm::EventSetup &
	)

overrideprivate

Definition at line 175 of file EventWithHistoryProducerFromL1ABC.cc.

References _offsets.

                                                                                     {
   // reset offset vector
 
   _offsets.clear();
   edm::LogInfo("AbsoluteBXOffsetReset") << "Absolute BX offset map reset";
 }

◆ endRun()

void EventWithHistoryProducerFromL1ABC::endRun	(	const edm::Run &	,
		const edm::EventSetup &
	)

overrideprivate

Definition at line 182 of file EventWithHistoryProducerFromL1ABC.cc.

References _offsets, and hltrates_dqm_sourceclient-live_cfg::offset.

                                                                                   {
   // summary of absolute bx offset vector
 
   edm::LogInfo("AbsoluteBXOffsetSummary") << "Absolute BX offset summary:";
   for (std::map<edm::EventNumber_t, long long>::const_iterator offset = _offsets.begin(); offset != _offsets.end();
        ++offset) {
     edm::LogVerbatim("AbsoluteBXOffsetSummary") << offset->first << " " << offset->second;
   }
 }

◆ produce()

void EventWithHistoryProducerFromL1ABC::produce	(	edm::Event &	iEvent,
		const edm::EventSetup &	iSetup
	)

overrideprivate

Definition at line 102 of file EventWithHistoryProducerFromL1ABC.cc.

References _curroffevent, _curroffset, _forceNoOffset, _forceSCAL, _l1abccollectionToken, _offsets, _tcdsRecordToken, iEvent, edm::HandleBase::isValid(), eostools::move(), edm::Handle< T >::product(), and BeamMonitor_cff::tcdsRecord.

                                                                                              {
   using namespace edm;
 
   if (iEvent.run() < 110878) {
     std::unique_ptr<EventWithHistory> pOut(new EventWithHistory(iEvent));
     iEvent.put(std::move(pOut));
 
   } else {
     Handle<L1AcceptBunchCrossingCollection> pIn;
     iEvent.getByToken(_l1abccollectionToken, pIn);
     Handle<TCDSRecord> tcds_pIn;
     iEvent.getByToken(_tcdsRecordToken, tcds_pIn);
     bool useTCDS(tcds_pIn.isValid() && !_forceSCAL);
 
     const auto* tcdsRecord = useTCDS ? tcds_pIn.product() : nullptr;
     // offset computation
 
     long long orbitoffset = 0;
     int bxoffset = 0;
 
     if (useTCDS) {
       if (!_forceNoOffset) {
         if (tcdsRecord->getL1aHistoryEntry(0).getIndex() == 0) {
           orbitoffset = (long long)tcdsRecord->getOrbitNr() - (long long)iEvent.orbitNumber();
           bxoffset = tcdsRecord->getBXID() - iEvent.bunchCrossing();
         }
       }
     } else {
       if (!_forceNoOffset) {
         for (L1AcceptBunchCrossingCollection::const_iterator l1abc = pIn->begin(); l1abc != pIn->end(); ++l1abc) {
           if (l1abc->l1AcceptOffset() == 0) {
             orbitoffset = (long long)l1abc->orbitNumber() - (long long)iEvent.orbitNumber();
             bxoffset = l1abc->bunchCrossing() - iEvent.bunchCrossing();
           }
         }
       }
     }
 
     std::unique_ptr<EventWithHistory> pOut(useTCDS ? new EventWithHistory(iEvent, *tcdsRecord, orbitoffset, bxoffset)
                                                    : new EventWithHistory(iEvent, *pIn, orbitoffset, bxoffset));
     iEvent.put(std::move(pOut));
 
     // monitor offset
 
     long long absbxoffset = orbitoffset * 3564 + bxoffset;
 
     if (_offsets.empty()) {
       _curroffset = absbxoffset;
       _curroffevent = iEvent.id().event();
       _offsets[iEvent.id().event()] = absbxoffset;
     } else {
       if (_curroffset != absbxoffset || iEvent.id().event() < _curroffevent) {
         if (_curroffset != absbxoffset) {
           edm::LogInfo("AbsoluteBXOffsetChanged")
               << "Absolute BX offset changed from " << _curroffset << " to " << absbxoffset << " at orbit "
               << iEvent.orbitNumber() << " and BX " << iEvent.bunchCrossing();
           if (useTCDS) {
             edm::LogVerbatim("AbsoluteBXOffsetChanged") << *tcdsRecord;  // Not sure about this
           } else {
             for (L1AcceptBunchCrossingCollection::const_iterator l1abc = pIn->begin(); l1abc != pIn->end(); ++l1abc) {
               edm::LogVerbatim("AbsoluteBXOffsetChanged") << *l1abc;
             }
           }
         }
 
         _curroffset = absbxoffset;
         _curroffevent = iEvent.id().event();
         _offsets[iEvent.id().event()] = absbxoffset;
       }
     }
   }
 }