#include <RecoTracker/NuclearSeedGenerator/interface/NuclearTrackCorrector.h>

Inheritance diagram for NuclearTrackCorrector:

Public Types
using	AlgoProductCollection = TrackProducerAlgorithm< reco::Track >::AlgoProductCollection

typedef TransientTrackingRecHit::ConstRecHitContainer	ConstRecHitContainer

typedef edm::Ref< TrackCandidateCollection >	TrackCandidateRef

typedef edm::Ref< TrajectoryCollection >	TrajectoryRef

typedef edm::RefVector< TrajectorySeedCollection >	TrajectorySeedRefVector

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

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

	~NuclearTrackCorrector () 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
TrajectoryStateOnSurface	getInitialState (const reco::Track theT, TransientTrackingRecHit::RecHitContainer &hits, const TrackingGeometry theG, const MagneticField *theMF)
	Calculate the inital state to be used to buil the track. More...

reco::TrackExtra	getNewTrackExtra (const AlgoProductCollection &algoresults)
	get a new TrackExtra from an AlgoProductCollection More...

bool	getTrackFromTrajectory (const Trajectory &newTraj, const TrajectoryRef &initialTrajRef, AlgoProductCollection &algoResults)
	Get the refitted track from the Trajectory. More...

bool	newTrajNeeded (Trajectory &newtrajectory, const TrajectoryRef &trajRef, const reco::NuclearInteraction &ni)
	check if the trajectory has to be refitted and get the new trajectory More...

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

void	swap_map (const edm::Handle< TrajectoryCollection > &trajColl, std::map< reco::TrackRef, edm::Ref< TrajectoryCollection > > &result)

Private Attributes
std::vector< std::pair< unsigned int, unsigned int > >	Indice_Map

int	int_Input_Hit_Distance

int	KeepOnlyCorrectedTracks

const TrajTrackAssociationCollection *	m_TrajToTrackCollection

std::string	str_Input_NuclearInteraction

std::string	str_Input_Trajectory

TrackProducerAlgorithm< reco::Track > *	theAlgo

edm::ESHandle< TrajectoryFitter >	theFitter

edm::ESGetToken< TrajectoryFitter, TrajectoryFitter::Record >	theFitterToken

edm::ESHandle< TrackerGeometry >	theG

edm::ESGetToken< TrackerGeometry, TrackerDigiGeometryRecord >	theGToken

TransientInitialStateEstimator *	theInitialState

edm::ESHandle< MagneticField >	theMF

edm::ESGetToken< MagneticField, IdealMagneticFieldRecord >	theMFToken

edm::ESHandle< Propagator >	thePropagator

edm::ESGetToken< Propagator, TrackingComponentsRecord >	thePropagatorToken

int	verbosity

Detailed Description

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

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

Definition at line 67 of file NuclearTrackCorrector.h.

Member Typedef Documentation

◆ AlgoProductCollection

using NuclearTrackCorrector::AlgoProductCollection = TrackProducerAlgorithm<reco::Track>::AlgoProductCollection

Definition at line 74 of file NuclearTrackCorrector.h.

◆ ConstRecHitContainer

typedef TransientTrackingRecHit::ConstRecHitContainer NuclearTrackCorrector::ConstRecHitContainer

Definition at line 72 of file NuclearTrackCorrector.h.

◆ TrackCandidateRef

typedef edm::Ref<TrackCandidateCollection> NuclearTrackCorrector::TrackCandidateRef

Definition at line 71 of file NuclearTrackCorrector.h.

◆ TrajectoryRef

typedef edm::Ref<TrajectoryCollection> NuclearTrackCorrector::TrajectoryRef

Definition at line 70 of file NuclearTrackCorrector.h.

◆ TrajectorySeedRefVector

typedef edm::RefVector<TrajectorySeedCollection> NuclearTrackCorrector::TrajectorySeedRefVector

Definition at line 69 of file NuclearTrackCorrector.h.

Constructor & Destructor Documentation

◆ NuclearTrackCorrector()

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

explicit

Definition at line 34 of file NuclearTrackCorrector.cc.

References deDxTools::esConsumes(), edm::ParameterSet::getParameter(), KeepOnlyCorrectedTracks, HLT_2024v14_cff::propagatorName, str_Input_NuclearInteraction, str_Input_Trajectory, AlCaHLTBitMon_QueryRunRegistry::string, theAlgo, theFitterToken, theGToken, theMFToken, thePropagatorToken, and verbosity.

                                                                            : theInitialState(nullptr) {
   str_Input_Trajectory = iConfig.getParameter<std::string>("InputTrajectory");
   str_Input_NuclearInteraction = iConfig.getParameter<std::string>("InputNuclearInteraction");
   verbosity = iConfig.getParameter<int>("Verbosity");
   KeepOnlyCorrectedTracks = iConfig.getParameter<bool>("KeepOnlyCorrectedTracks");
 
   theAlgo = new TrackProducerAlgorithm<reco::Track>(iConfig);
 
   produces<TrajectoryCollection>();
   produces<TrajectoryToTrajectoryMap>();
 
   produces<reco::TrackExtraCollection>();
   produces<reco::TrackCollection>();
   produces<TrackToTrajectoryMap>();
 
   produces<TrackToTrackMap>();
 
   theGToken = esConsumes();
   theMFToken = esConsumes();
   std::string fitterName = iConfig.getParameter<std::string>("Fitter");
   theFitterToken = esConsumes(edm::ESInputTag("", fitterName));
   std::string propagatorName = iConfig.getParameter<std::string>("Propagator");
   thePropagatorToken = esConsumes(edm::ESInputTag("", propagatorName));
 }

◆ ~NuclearTrackCorrector()

NuclearTrackCorrector::~NuclearTrackCorrector ( )

override

Definition at line 59 of file NuclearTrackCorrector.cc.

59 {}

Member Function Documentation

◆ getInitialState()

TrajectoryStateOnSurface NuclearTrackCorrector::getInitialState	(	const reco::Track *	theT,
		TransientTrackingRecHit::RecHitContainer &	hits,
		const TrackingGeometry *	theG,
		const MagneticField *	theMF
	)

private

Calculate the inital state to be used to buil the track.

Definition at line 305 of file NuclearTrackCorrector.cc.

References TrajectoryStateOnSurface::globalPosition(), hfClusterShapes_cfi::hits, trajectoryStateTransform::innerStateOnSurface(), TrajectoryStateOnSurface::localError(), TrajectoryStateOnSurface::localParameters(), mag2(), trajectoryStateTransform::outerStateOnSurface(), TrajectoryStateOnSurface::rescaleError(), TrajectoryStateOnSurface::surface(), theG, and theMF.

Referenced by getTrackFromTrajectory().

                                                                                             {
   TrajectoryStateOnSurface theInitialStateForRefitting;
   //the starting state is the state closest to the first hit along seedDirection.
 
   //avoiding to use transientTrack, it should be faster;
   TrajectoryStateOnSurface innerStateFromTrack = trajectoryStateTransform::innerStateOnSurface(*theT, *theG, theMF);
   TrajectoryStateOnSurface outerStateFromTrack = trajectoryStateTransform::outerStateOnSurface(*theT, *theG, theMF);
   TrajectoryStateOnSurface initialStateFromTrack =
       ((innerStateFromTrack.globalPosition() - hits.front()->globalPosition()).mag2() <
        (outerStateFromTrack.globalPosition() - hits.front()->globalPosition()).mag2())
           ? innerStateFromTrack
           : outerStateFromTrack;
 
   // error is rescaled, but correlation are kept.
   initialStateFromTrack.rescaleError(100);
   theInitialStateForRefitting = TrajectoryStateOnSurface(initialStateFromTrack.localParameters(),
                                                          initialStateFromTrack.localError(),
                                                          initialStateFromTrack.surface(),
                                                          theMF);
   return theInitialStateForRefitting;
 }

◆ getNewTrackExtra()

reco::TrackExtra NuclearTrackCorrector::getNewTrackExtra ( const AlgoProductCollection & algoresults )

private

get a new TrackExtra from an AlgoProductCollection

Definition at line 264 of file NuclearTrackCorrector.cc.

References alongMomentum, TrajectoryStateOnSurface::curvilinearError(), Trajectory::direction(), Trajectory::firstMeasurement(), TrajectoryStateOnSurface::globalParameters(), Trajectory::lastMeasurement(), GlobalTrajectoryParameters::momentum(), AlCaHLTBitMon_ParallelJobs::p, GlobalTrajectoryParameters::position(), TrajectoryMeasurement::recHit(), TrajectoryMeasurement::updatedState(), and findQualityFiles::v.

Referenced by produce().

                                                                                                {
   Trajectory* theTraj = algoResults[0].trajectory;
   PropagationDirection seedDir = algoResults[0].pDir;
 
   TrajectoryStateOnSurface outertsos;
   TrajectoryStateOnSurface innertsos;
   unsigned int innerId, outerId;
   if (theTraj->direction() == alongMomentum) {
     outertsos = theTraj->lastMeasurement().updatedState();
     innertsos = theTraj->firstMeasurement().updatedState();
     outerId = theTraj->lastMeasurement().recHit()->geographicalId().rawId();
     innerId = theTraj->firstMeasurement().recHit()->geographicalId().rawId();
   } else {
     outertsos = theTraj->firstMeasurement().updatedState();
     innertsos = theTraj->lastMeasurement().updatedState();
     outerId = theTraj->firstMeasurement().recHit()->geographicalId().rawId();
     innerId = theTraj->lastMeasurement().recHit()->geographicalId().rawId();
   }
 
   GlobalPoint v = outertsos.globalParameters().position();
   GlobalVector p = outertsos.globalParameters().momentum();
   math::XYZVector outmom(p.x(), p.y(), p.z());
   math::XYZPoint outpos(v.x(), v.y(), v.z());
   v = innertsos.globalParameters().position();
   p = innertsos.globalParameters().momentum();
   math::XYZVector inmom(p.x(), p.y(), p.z());
   math::XYZPoint inpos(v.x(), v.y(), v.z());
 
   return reco::TrackExtra(outpos,
                           outmom,
                           true,
                           inpos,
                           inmom,
                           true,
                           outertsos.curvilinearError(),
                           outerId,
                           innertsos.curvilinearError(),
                           innerId,
                           seedDir);
 }

◆ getTrackFromTrajectory()

bool NuclearTrackCorrector::getTrackFromTrajectory	(	const Trajectory &	newTraj,
		const TrajectoryRef &	initialTrajRef,
		AlgoProductCollection &	algoResults
	)

private

Get the refitted track from the Trajectory.

Definition at line 221 of file NuclearTrackCorrector.cc.

References cms::cuda::bs, TrackProducerAlgorithm< T >::buildTrack(), getInitialState(), h, hfClusterShapes_cfi::hits, sistrip::SpyUtilities::isValid(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, LogDebug, m_TrajToTrackCollection, PixelVertexMonitor_cff::ndof, edm::ESHandle< T >::product(), theAlgo, theFitter, theG, theMF, and thePropagator.

Referenced by produce().

                                                                                        {
   const Trajectory* it = &newTraj;
 
   TransientTrackingRecHit::RecHitContainer hits;
   it->validRecHits(hits);
 
   float ndof = 0;
   for (unsigned int h = 0; h < hits.size(); h++) {
     if (hits[h]->isValid()) {
       ndof = ndof + hits[h]->dimension() * hits[h]->weight();
     } else {
       LogDebug("NuclearSeedGenerator") << " HIT IS INVALID ???";
     }
   }
 
   ndof = ndof - 5;
   reco::TrackRef theT = m_TrajToTrackCollection->operator[](initialTrajRef);
   LogDebug("NuclearSeedGenerator") << " TrackCorrector - number of valid hits" << hits.size() << "\n"
                                    << "                - number of hits from Track " << theT->recHitsSize() << "\n"
                                    << "                - number of valid hits from initial track "
                                    << theT->numberOfValidHits();
 
   if (hits.size() > 1) {
     TrajectoryStateOnSurface theInitialStateForRefitting =
         getInitialState(&(*theT), hits, theG.product(), theMF.product());
 
     reco::BeamSpot bs;
     return theAlgo->buildTrack(theFitter.product(),
                                thePropagator.product(),
                                algoResults,
                                hits,
                                theInitialStateForRefitting,
                                it->seed(),
                                ndof,
                                bs,
                                theT->seedRef());
   }
 
   return false;
 }

◆ newTrajNeeded()

bool NuclearTrackCorrector::newTrajNeeded	(	Trajectory &	newtrajectory,
		const TrajectoryRef &	trajRef,
		const reco::NuclearInteraction &	ni
	)

private

check if the trajectory has to be refitted and get the new trajectory

Definition at line 180 of file NuclearTrackCorrector.cc.

References alongMomentum, TrackerGeometry::idToDet(), createfilelist::int, LogDebug, visualization-live-secondInstance_cfg::m, PV3DBase< T, PVType, FrameType >::mag(), reco::Vertex::position(), Trajectory::push(), rpcPointValidation_cfi::recHit, mathSSE::sqrt(), GeomDet::surface(), theG, Surface::toGlobal(), verbosity, and reco::NuclearInteraction::vertex().

Referenced by produce().

                                                                         {
   bool needNewTraj = false;
   reco::Vertex::Point vtx_pos = ni.vertex().position();
   double vtx_pos_mag = sqrt(vtx_pos.X() * vtx_pos.X() + vtx_pos.Y() * vtx_pos.Y() + vtx_pos.Z() * vtx_pos.Z());
   if (verbosity >= 2)
     printf("Nuclear Interaction pos = %f\n", vtx_pos_mag);
 
   newtrajectory = Trajectory(trajRef->seed(), alongMomentum);
 
   // Look all the Hits of the trajectory and keep only Hits before seeds
   Trajectory::DataContainer Measurements = trajRef->measurements();
   if (verbosity >= 2)
     LogDebug("NuclearTrackCorrector") << "Size of Measurements  = " << Measurements.size();
 
   for (unsigned int m = Measurements.size() - 1; m != (unsigned int)-1; m--) {
     if (!Measurements[m].recHit()->isValid())
       continue;
     GlobalPoint hit_pos = theG->idToDet(Measurements[m].recHit()->geographicalId())
                               ->surface()
                               .toGlobal(Measurements[m].recHit()->localPosition());
 
     if (verbosity >= 2)
       printf("Hit pos = %f", hit_pos.mag());
 
     if (hit_pos.mag() > vtx_pos_mag) {
       if (verbosity >= 2)
         printf(" X ");
       needNewTraj = true;
     } else {
       newtrajectory.push(Measurements[m]);
     }
     if (verbosity >= 2)
       printf("\n");
   }
 
   return needNewTraj;
 }

◆ produce()

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

overrideprivate

Definition at line 61 of file NuclearTrackCorrector.cc.

References edm::RefToBase< T >::castTo(), dqmdumpme::first, edm::EventSetup::getHandle(), getNewTrackExtra(), getTrackFromTrajectory(), mps_fire::i, iEvent, Indice_Map, edm::AssociationMap< Tag >::insert(), KeepOnlyCorrectedTracks, reco::NuclearInteraction::likelihood(), LogDebug, m_TrajToTrackCollection, eostools::move(), newTrajNeeded(), reco::NuclearInteraction::primaryTrack(), edm::Handle< T >::product(), edm::AssociationMap< Tag >::refProd(), edm::second(), str_Input_NuclearInteraction, str_Input_Trajectory, swap_map(), theFitter, theFitterToken, theG, theGToken, theMF, theMFToken, thePropagator, thePropagatorToken, HLT_2024v14_cff::track, and verbosity.

                                                                                  {
   // Create Output Collections
   // --------------------------------------------------------------------------------------------------
   auto Output_traj = std::make_unique<TrajectoryCollection>();
   auto Output_trajmap = std::make_unique<TrajectoryToTrajectoryMap>();
 
   auto Output_trackextra = std::make_unique<reco::TrackExtraCollection>();
   auto Output_track = std::make_unique<reco::TrackCollection>();
   auto Output_trackmap = std::make_unique<TrackToTrajectoryMap>();
 
   // Load Reccord
   // --------------------------------------------------------------------------------------------------
   theFitter = iSetup.getHandle(theFitterToken);
 
   thePropagator = iSetup.getHandle(thePropagatorToken);
   theG = iSetup.getHandle(theGToken);
 
   reco::TrackExtraRefProd rTrackExtras = iEvent.getRefBeforePut<reco::TrackExtraCollection>();
 
   theMF = iSetup.getHandle(theMFToken);
 
   // Load Inputs
   // --------------------------------------------------------------------------------------------------
   edm::Handle<TrajectoryCollection> temp_m_TrajectoryCollection;
   iEvent.getByLabel(str_Input_Trajectory, temp_m_TrajectoryCollection);
   const TrajectoryCollection m_TrajectoryCollection = *(temp_m_TrajectoryCollection.product());
 
   edm::Handle<NuclearInteractionCollection> temp_m_NuclearInteractionCollection;
   iEvent.getByLabel(str_Input_NuclearInteraction, temp_m_NuclearInteractionCollection);
   const NuclearInteractionCollection m_NuclearInteractionCollection = *(temp_m_NuclearInteractionCollection.product());
 
   edm::Handle<TrajTrackAssociationCollection> h_TrajToTrackCollection;
   iEvent.getByLabel(str_Input_Trajectory, h_TrajToTrackCollection);
   m_TrajToTrackCollection = h_TrajToTrackCollection.product();
 
   // Correct the trajectories (Remove trajectory's hits that are located after the nuclear interacion)
   // --------------------------------------------------------------------------------------------------
   if (verbosity >= 1) {
     LogDebug("NuclearTrackCorrector") << "Number of trajectories                    = " << m_TrajectoryCollection.size()
                                       << std::endl
                                       << "Number of nuclear interactions            = "
                                       << m_NuclearInteractionCollection.size();
   }
 
   std::map<reco::TrackRef, TrajectoryRef> m_TrackToTrajMap;
   swap_map(temp_m_TrajectoryCollection, m_TrackToTrajMap);
 
   for (unsigned int i = 0; i < m_NuclearInteractionCollection.size(); i++) {
     const reco::NuclearInteraction& ni = m_NuclearInteractionCollection[i];
     if (ni.likelihood() < 0.4)
       continue;
 
     reco::TrackRef primTrackRef = ni.primaryTrack().castTo<reco::TrackRef>();
 
     TrajectoryRef trajRef = m_TrackToTrajMap[primTrackRef];
 
     Trajectory newTraj;
     if (newTrajNeeded(newTraj, trajRef, ni)) {
       AlgoProductCollection algoResults;
       bool isOK = getTrackFromTrajectory(newTraj, trajRef, algoResults);
 
       if (isOK) {
         pair<unsigned int, unsigned int> tempory_pair;
         tempory_pair.first = Output_track->size();
         tempory_pair.second = i;
         Indice_Map.push_back(tempory_pair);
 
         reco::TrackExtraRef teref = reco::TrackExtraRef(rTrackExtras, i);
         reco::TrackExtra newTrackExtra = getNewTrackExtra(algoResults);
         (algoResults[0].track)->setExtra(teref);
 
         Output_track->push_back(*algoResults[0].track);
         Output_trackextra->push_back(newTrackExtra);
         Output_traj->push_back(newTraj);
       }
     } else {
       if (!KeepOnlyCorrectedTracks) {
         Output_track->push_back(*primTrackRef);
         Output_trackextra->push_back(*primTrackRef->extra());
         Output_traj->push_back(*trajRef);
       }
     }
   }
   const edm::OrphanHandle<TrajectoryCollection> Handle_traj = iEvent.put(std::move(Output_traj));
   const edm::OrphanHandle<reco::TrackCollection> Handle_tracks = iEvent.put(std::move(Output_track));
   iEvent.put(std::move(Output_trackextra));
 
   // Make Maps between elements
   // --------------------------------------------------------------------------------------------------
   if (Handle_tracks->size() != Handle_traj->size()) {
     printf("ERROR Handle_tracks->size() != Handle_traj->size() \n");
     return;
   }
 
   auto Output_tracktrackmap = std::make_unique<TrackToTrackMap>(Handle_tracks, m_TrajToTrackCollection->refProd().val);
 
   for (unsigned int i = 0; i < Indice_Map.size(); i++) {
     TrajectoryRef InTrajRef(temp_m_TrajectoryCollection, Indice_Map[i].second);
     TrajectoryRef OutTrajRef(Handle_traj, Indice_Map[i].first);
     reco::TrackRef TrackRef(Handle_tracks, Indice_Map[i].first);
 
     Output_trajmap->insert(OutTrajRef, InTrajRef);
     Output_trackmap->insert(TrackRef, InTrajRef);
 
     try {
       reco::TrackRef PrimaryTrackRef = m_TrajToTrackCollection->operator[](InTrajRef);
       Output_tracktrackmap->insert(TrackRef, PrimaryTrackRef);
     } catch (edm::Exception const&) {
     }
   }
   iEvent.put(std::move(Output_trajmap));
   iEvent.put(std::move(Output_trackmap));
   iEvent.put(std::move(Output_tracktrackmap));
 
   if (verbosity >= 3)
     printf("-----------------------\n");
 }

◆ swap_map()

void NuclearTrackCorrector::swap_map	(	const edm::Handle< TrajectoryCollection > &	trajColl,
		std::map< reco::TrackRef, edm::Ref< TrajectoryCollection > > &	result
	)

private

Definition at line 330 of file NuclearTrackCorrector.cc.

References mps_fire::i, m_TrajToTrackCollection, and mps_fire::result.

Referenced by produce().

                                                                                                   {
   for (unsigned int i = 0; i < trajColl->size(); i++) {
     TrajectoryRef InTrajRef(trajColl, i);
     reco::TrackRef PrimaryTrackRef = m_TrajToTrackCollection->operator[](InTrajRef);
     result[PrimaryTrackRef] = InTrajRef;
   }
 }