trklet::ProducerTBout Class Reference

Transforms TTTracks and Streams from Tracklet pattern reco. into StreamsTrack by adding to the digitised track stream a reference to the corresponding TTTrack. (Could not be done in previous L1TrackFPGAProducer, as single EDProducer can't produce output containing both an EDProduct and refs to that product). Writes Tracks & stubs rejected/kept after truncation to separate StreamsTrack & StreamsStub branches. More...

Inheritance diagram for trklet::ProducerTBout:

Public Member Functions
	ProducerTBout (const ParameterSet &)
	~ProducerTBout () 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 Run &, const EventSetup &) override
virtual void	endJob ()
void	produce (Event &, const EventSetup &) override

Private Attributes
ChannelAssignment *	channelAssignment_ = nullptr
const DataFormats *	dataFormats_ = nullptr
EDGetTokenT< StreamsStub >	edGetTokenStubs_
EDGetTokenT< Streams >	edGetTokenTracks_
EDGetTokenT< TTTracks >	edGetTokenTTTracks_
EDPutTokenT< StreamsStub >	edPutTokenAcceptedStubs_
EDPutTokenT< StreamsTrack >	edPutTokenAcceptedTracks_
EDPutTokenT< StreamsStub >	edPutTokenLostStubs_
EDPutTokenT< StreamsTrack >	edPutTokenLostTracks_
bool	enableTruncation_
ESGetToken< ChannelAssignment, ChannelAssignmentRcd >	esGetTokenChannelAssignment_
ESGetToken< DataFormats, DataFormatsRcd >	esGetTokenDataFormats_
ESGetToken< Setup, SetupRcd >	esGetTokenSetup_
ParameterSet	iConfig_
const Setup *	setup_ = nullptr

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

Transforms TTTracks and Streams from Tracklet pattern reco. into StreamsTrack by adding to the digitised track stream a reference to the corresponding TTTrack. (Could not be done in previous L1TrackFPGAProducer, as single EDProducer can't produce output containing both an EDProduct and refs to that product). Writes Tracks & stubs rejected/kept after truncation to separate StreamsTrack & StreamsStub branches.

Author

Thomas Schuh

Date

2021, Oct

Definition at line 40 of file ProducerTBout.cc.

Constructor & Destructor Documentation

ProducerTBout()

trklet::ProducerTBout::ProducerTBout ( const ParameterSet &  iConfig )

explicit

Definition at line 80 of file ProducerTBout.cc.

References edGetTokenStubs_, edGetTokenTracks_, edGetTokenTTTracks_, edPutTokenAcceptedStubs_, edPutTokenAcceptedTracks_, edPutTokenLostStubs_, edPutTokenLostTracks_, enableTruncation_, esGetTokenChannelAssignment_, esGetTokenDataFormats_, esGetTokenSetup_, edm::ParameterSet::getParameter(), and SimL1EmulatorRepack_Full_cff::inputTag.

                                                          : iConfig_(iConfig) {
    const InputTag& inputTag = iConfig.getParameter<InputTag>("InputTag");
    const string& branchAcceptedStubs = iConfig.getParameter<string>("BranchAcceptedStubs");
    const string& branchAcceptedTracks = iConfig.getParameter<string>("BranchAcceptedTracks");
    const string& branchLostStubs = iConfig.getParameter<string>("BranchLostStubs");
    const string& branchLostTracks = iConfig.getParameter<string>("BranchLostTracks");
    // book in- and output ED products
    edGetTokenTTTracks_ = consumes<TTTracks>(inputTag);
    edGetTokenTracks_ = consumes<Streams>(inputTag);
    edGetTokenStubs_ = consumes<StreamsStub>(inputTag);
    edPutTokenAcceptedStubs_ = produces<StreamsStub>(branchAcceptedStubs);
    edPutTokenAcceptedTracks_ = produces<StreamsTrack>(branchAcceptedTracks);
    edPutTokenLostStubs_ = produces<StreamsStub>(branchLostStubs);
    edPutTokenLostTracks_ = produces<StreamsTrack>(branchLostTracks);
    // book ES products
    esGetTokenSetup_ = esConsumes<Setup, SetupRcd, Transition::BeginRun>();
    esGetTokenDataFormats_ = esConsumes<DataFormats, DataFormatsRcd, Transition::BeginRun>();
    esGetTokenChannelAssignment_ = esConsumes<ChannelAssignment, ChannelAssignmentRcd, Transition::BeginRun>();
    //
    enableTruncation_ = iConfig.getParameter<bool>("EnableTruncation");
  }

~ProducerTBout()

trklet::ProducerTBout::~ProducerTBout ( )

inlineoverride

Definition at line 43 of file ProducerTBout.cc.

{}

Member Function Documentation

beginRun()

void trklet::ProducerTBout::beginRun ( const Run &  iRun, const EventSetup &  iSetup  )

overrideprivate

Definition at line 102 of file ProducerTBout.cc.

References channelAssignment_, tt::Setup::checkHistory(), tt::Setup::configurationSupported(), dataFormats_, esGetTokenChannelAssignment_, esGetTokenDataFormats_, esGetTokenSetup_, edm::EventSetup::getData(), edm::ParameterSet::getParameter(), iConfig_, edm::Run::processHistory(), and setup_.

                                                                        {
    // helper class to store configurations
    setup_ = &iSetup.getData(esGetTokenSetup_);
    if (!setup_->configurationSupported())
      return;
    // check process history if desired
    if (iConfig_.getParameter<bool>("CheckHistory"))
      setup_->checkHistory(iRun.processHistory());
    // helper class to extract structured data from tt::Frames
    dataFormats_ = &iSetup.getData(esGetTokenDataFormats_);
    // helper class to assign tracks to channel
    channelAssignment_ = const_cast<ChannelAssignment*>(&iSetup.getData(esGetTokenChannelAssignment_));
  }

endJob()

virtual void trklet::ProducerTBout::endJob ( void  )

inlineprivatevirtual

Definition at line 48 of file ProducerTBout.cc.

{}

produce()

void trklet::ProducerTBout::produce ( Event &  iEvent, const EventSetup &  iSetup  )

overrideprivate

Definition at line 116 of file ProducerTBout.cc.

References channelAssignment_, trklet::ChannelAssignment::channelId(), totem::nt2::vfat::channelId(), tt::Setup::configurationSupported(), HLT_2022v15_cff::distance, edGetTokenStubs_, edGetTokenTracks_, edGetTokenTTTracks_, edPutTokenAcceptedStubs_, edPutTokenAcceptedTracks_, edPutTokenLostStubs_, edPutTokenLostTracks_, enableTruncation_, cppFunctionSkipper::exception, f, amptDefault_cfi::frame, mps_fire::i, iEvent, createfilelist::int, remoteMonitoring_LASER_era2018_cfg::limit, eostools::move(), GetRecoTauVFromDQM_MC_cff::next, BeamSpotPI::nTracks, trklet::ChannelAssignment::numChannelsStub(), trklet::ChannelAssignment::numChannelsTrack(), tt::Setup::numFrames(), tt::Setup::numRegions(), push_back(), HLT_2022v15_cff::region, setup_, and HcalDetIdTransform::transform().

                                                                     {
    const int numStreamsTracks = setup_->numRegions() * channelAssignment_->numChannelsTrack();
    const int numStreamsStubs = setup_->numRegions() * channelAssignment_->numChannelsStub();
    // empty KFin products
    StreamsStub streamAcceptedStubs(numStreamsStubs);
    StreamsTrack streamAcceptedTracks(numStreamsTracks);
    StreamsStub streamLostStubs(numStreamsStubs);
    StreamsTrack streamLostTracks(numStreamsTracks);
    // read in hybrid track finding product and produce KFin product
    if (setup_->configurationSupported()) {
      // create and structure TTrackRefs in h/w channel
      vector<deque<TTTrackRef>> ttTrackRefs(numStreamsTracks);
      Handle<TTTracks> handleTTTracks;
      iEvent.getByToken<TTTracks>(edGetTokenTTTracks_, handleTTTracks);
      int channelId(-1);
      for (int i = 0; i < (int)handleTTTracks->size(); i++) {
        const TTTrackRef ttTrackRef(handleTTTracks, i);
        if (channelAssignment_->channelId(ttTrackRef, channelId))
          ttTrackRefs[channelId].push_back(ttTrackRef);
      }
      // get and trunacte tracks
      Handle<Streams> handleTracks;
      iEvent.getByToken<Streams>(edGetTokenTracks_, handleTracks);
      channelId = 0;
      for (const Stream& streamTrack : *handleTracks) {
        const int nTracks = accumulate(
            streamTrack.begin(), streamTrack.end(), 0, [](int& sum, const Frame& f) { return sum += f.any() ? 1 : 0; });
        StreamTrack& accepted = streamAcceptedTracks[channelId];
        StreamTrack& lost = streamLostTracks[channelId];
        auto limit = streamTrack.end();
        if (enableTruncation_ && (int)streamTrack.size() > setup_->numFrames())
          limit = next(streamTrack.begin(), setup_->numFrames());
        accepted.reserve(distance(streamTrack.begin(), limit));
        lost.reserve(distance(limit, streamTrack.end()));
        int nFrame(0);
        const deque<TTTrackRef>& ttTracks = ttTrackRefs[channelId++];
        if ((int)ttTracks.size() != nTracks) {
          cms::Exception exception("LogicError.");
          const int region = channelId / channelAssignment_->numChannelsTrack();
          const int channel = channelId % channelAssignment_->numChannelsTrack();
          exception << "Region " << region << " output channel " << channel << " has " << nTracks
                    << " tracks found but created " << ttTracks.size() << " TTTracks.";
          exception.addContext("trklet::ProducerTBout::produce");
          throw exception;
        }
        auto toFrameTrack = [&nFrame, &ttTracks](const Frame& frame) {
          if (frame.any())
            return FrameTrack(ttTracks[nFrame++], frame);
          return FrameTrack();
        };
        transform(streamTrack.begin(), limit, back_inserter(accepted), toFrameTrack);
        transform(limit, streamTrack.end(), back_inserter(lost), toFrameTrack);
      }
      // get and trunacte stubs
      Handle<StreamsStub> handleStubs;
      iEvent.getByToken<StreamsStub>(edGetTokenStubs_, handleStubs);
      const StreamsStub& streamsStub = *handleStubs;
      // reserve output ed products
      channelId = 0;
      for (const StreamStub& streamStub : streamsStub) {
        auto limit = streamStub.end();
        if (enableTruncation_ && (int)streamStub.size() > setup_->numFrames())
          limit = next(streamStub.begin(), setup_->numFrames());
        streamAcceptedStubs[channelId] = StreamStub(streamStub.begin(), limit);
        streamLostStubs[channelId++] = StreamStub(limit, streamStub.end());
      }
    }
    // store products
    iEvent.emplace(edPutTokenAcceptedStubs_, move(streamAcceptedStubs));
    iEvent.emplace(edPutTokenAcceptedTracks_, move(streamAcceptedTracks));
    iEvent.emplace(edPutTokenLostStubs_, move(streamLostStubs));
    iEvent.emplace(edPutTokenLostTracks_, move(streamLostTracks));
  }

Member Data Documentation

channelAssignment_

ChannelAssignment* trklet::ProducerTBout::channelAssignment_ = nullptr

private

Definition at line 75 of file ProducerTBout.cc.

Referenced by beginRun(), and produce().

dataFormats_

const DataFormats* trklet::ProducerTBout::dataFormats_ = nullptr

private

Definition at line 73 of file ProducerTBout.cc.

Referenced by beginRun().

edGetTokenStubs_

EDGetTokenT<StreamsStub> trklet::ProducerTBout::edGetTokenStubs_

private

Definition at line 55 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edGetTokenTracks_

EDGetTokenT<Streams> trklet::ProducerTBout::edGetTokenTracks_

private

Definition at line 53 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edGetTokenTTTracks_

EDGetTokenT<TTTracks> trklet::ProducerTBout::edGetTokenTTTracks_

private

Definition at line 51 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edPutTokenAcceptedStubs_

EDPutTokenT<StreamsStub> trklet::ProducerTBout::edPutTokenAcceptedStubs_

private

Definition at line 57 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edPutTokenAcceptedTracks_

EDPutTokenT<StreamsTrack> trklet::ProducerTBout::edPutTokenAcceptedTracks_

private

Definition at line 60 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edPutTokenLostStubs_

EDPutTokenT<StreamsStub> trklet::ProducerTBout::edPutTokenLostStubs_

private

Definition at line 58 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

edPutTokenLostTracks_

EDPutTokenT<StreamsTrack> trklet::ProducerTBout::edPutTokenLostTracks_

private

Definition at line 61 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

enableTruncation_

bool trklet::ProducerTBout::enableTruncation_

private

Definition at line 77 of file ProducerTBout.cc.

Referenced by produce(), and ProducerTBout().

esGetTokenChannelAssignment_

ESGetToken<ChannelAssignment, ChannelAssignmentRcd> trklet::ProducerTBout::esGetTokenChannelAssignment_

private

Definition at line 67 of file ProducerTBout.cc.

Referenced by beginRun(), and ProducerTBout().

esGetTokenDataFormats_

ESGetToken<DataFormats, DataFormatsRcd> trklet::ProducerTBout::esGetTokenDataFormats_

private

Definition at line 65 of file ProducerTBout.cc.

Referenced by beginRun(), and ProducerTBout().

esGetTokenSetup_

ESGetToken<Setup, SetupRcd> trklet::ProducerTBout::esGetTokenSetup_

private

Definition at line 63 of file ProducerTBout.cc.

Referenced by beginRun(), and ProducerTBout().

iConfig_

ParameterSet trklet::ProducerTBout::iConfig_

private

Definition at line 69 of file ProducerTBout.cc.

Referenced by beginRun().

setup_

const Setup* trklet::ProducerTBout::setup_ = nullptr

private

Definition at line 71 of file ProducerTBout.cc.

Referenced by beginRun(), produce(), and upgradeWorkflowComponents.UpgradeWorkflow::setup().