CTPPSProtonProducer Class Reference

Inheritance diagram for CTPPSProtonProducer:

Classes
struct	AssociationCuts

Public Member Functions
	CTPPSProtonProducer (const edm::ParameterSet &)
	~CTPPSProtonProducer () override=default
Public Member Functions inherited from edm::stream::EDProducer<>
	EDProducer ()=default
bool	hasAbilityToProduceInLumis () const final
bool	hasAbilityToProduceInRuns () const final

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

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

Private Attributes
ProtonReconstructionAlgorithm	algorithm_
std::map< unsigned int, AssociationCuts >	association_cuts_
bool	doMultiRPReconstruction_
bool	doSingleRPReconstruction_
std::string	lhcInfoLabel_
double	localAngleXMax_
double	localAngleXMin_
double	localAngleYMax_
double	localAngleYMin_
unsigned int	max_n_timing_tracks_
std::string	multiRPReconstructionLabel_
std::string	opticsLabel_
bool	opticsValid_
edm::ESWatcher< CTPPSInterpolatedOpticsRcd >	opticsWatcher_
std::string	singleRPReconstructionLabel_
edm::EDGetTokenT< CTPPSLocalTrackLiteCollection >	tracksToken_
unsigned int	verbosity_

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 35 of file CTPPSProtonProducer.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 122 of file CTPPSProtonProducer.cc.

References association_cuts_, doMultiRPReconstruction_, doSingleRPReconstruction_, edm::ParameterSet::getParameterSet(), multiRPReconstructionLabel_, singleRPReconstructionLabel_, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                       :
  tracksToken_                (consumes<CTPPSLocalTrackLiteCollection>(iConfig.getParameter<edm::InputTag>("tagLocalTrackLite"))),
  lhcInfoLabel_               (iConfig.getParameter<std::string>("lhcInfoLabel")),
  opticsLabel_                (iConfig.getParameter<std::string>("opticsLabel")),
  verbosity_                  (iConfig.getUntrackedParameter<unsigned int>("verbosity", 0)),
  doSingleRPReconstruction_   (iConfig.getParameter<bool>("doSingleRPReconstruction")),
  doMultiRPReconstruction_    (iConfig.getParameter<bool>("doMultiRPReconstruction")),
  singleRPReconstructionLabel_(iConfig.getParameter<std::string>("singleRPReconstructionLabel")),
  multiRPReconstructionLabel_ (iConfig.getParameter<std::string>("multiRPReconstructionLabel")),

  localAngleXMin_             (iConfig.getParameter<double>("localAngleXMin")),
  localAngleXMax_             (iConfig.getParameter<double>("localAngleXMax")),
  localAngleYMin_             (iConfig.getParameter<double>("localAngleYMin")),
  localAngleYMax_             (iConfig.getParameter<double>("localAngleYMax")),

  max_n_timing_tracks_        (iConfig.getParameter<unsigned int>("max_n_timing_tracks")),

  algorithm_                  (iConfig.getParameter<bool>("fitVtxY"), iConfig.getParameter<bool>("useImprovedInitialEstimate"), verbosity_),
  opticsValid_(false)
{
  for (const std::string &sector : { "45", "56" })
  {
    const unsigned int arm = (sector == "45") ? 0 : 1;
    association_cuts_[arm].load(iConfig.getParameterSet("association_cuts_" + sector));
  }

  if (doSingleRPReconstruction_)
    produces<reco::ForwardProtonCollection>(singleRPReconstructionLabel_);

  if (doMultiRPReconstruction_)
    produces<reco::ForwardProtonCollection>(multiRPReconstructionLabel_);
}

CTPPSProtonProducer::~CTPPSProtonProducer ( )

overridedefault

Member Function Documentation

void CTPPSProtonProducer::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 157 of file CTPPSProtonProducer.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addUntracked(), looper::config, CTPPSProtonProducer::AssociationCuts::getDefaultParameters(), edm::ParameterDescriptionNode::setComment(), and AlCaHLTBitMon_QueryRunRegistry::string.

{
  edm::ParameterSetDescription desc;

  desc.add<edm::InputTag>("tagLocalTrackLite", edm::InputTag("ctppsLocalTrackLiteProducer"))
    ->setComment("specification of the input lite-track collection");

  desc.add<std::string>("lhcInfoLabel", "")->setComment("label of the LHCInfo record");
  desc.add<std::string>("opticsLabel", "")->setComment("label of the optics record");

  desc.addUntracked<unsigned int>("verbosity", 0)->setComment("verbosity level");

  desc.add<bool>("doSingleRPReconstruction", true)
    ->setComment("flag whether to apply single-RP reconstruction strategy");

  desc.add<bool>("doMultiRPReconstruction", true)
    ->setComment("flag whether to apply multi-RP reconstruction strategy");

  desc.add<std::string>("singleRPReconstructionLabel", "singleRP")
    ->setComment("output label for single-RP reconstruction products");

  desc.add<std::string>("multiRPReconstructionLabel", "multiRP")
    ->setComment("output label for multi-RP reconstruction products");

  desc.add<double>("localAngleXMin", -0.03)->setComment("minimal accepted value of local horizontal angle (rad)");
  desc.add<double>("localAngleXMax", +0.03)->setComment("maximal accepted value of local horizontal angle (rad)");
  desc.add<double>("localAngleYMin", -0.04)->setComment("minimal accepted value of local vertical angle (rad)");
  desc.add<double>("localAngleYMax", +0.04)->setComment("maximal accepted value of local vertical angle (rad)");

  for (const std::string &sector : { "45", "56" })
  {
    desc.add<edm::ParameterSetDescription>("association_cuts_" + sector, AssociationCuts::getDefaultParameters())
      ->setComment("track-association cuts for sector " + sector);
  }

  std::vector<edm::ParameterSet> config;

  desc.add<unsigned int>("max_n_timing_tracks", 5)->setComment("maximum number of timing tracks per RP");

  desc.add<bool>("fitVtxY", true)
    ->setComment("for multi-RP reconstruction, flag whether y* should be free fit parameter");

  desc.add<bool>("useImprovedInitialEstimate", true)
    ->setComment("for multi-RP reconstruction, flag whether a quadratic estimate of the initial point should be used");

  descriptions.add("ctppsProtons", desc);
}

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

overrideprivate

Definition at line 207 of file CTPPSProtonProducer.cc.

References funct::abs(), algorithm_, association_cuts_, edm::ESWatcher< T >::check(), alignCSCRings::de_x, DEFINE_FWK_MODULE, doMultiRPReconstruction_, doSingleRPReconstruction_, edm::EventSetup::get(), edm::Event::getByToken(), CTPPSGeometry::getRPTranslation(), mps_fire::i, training_settings::idx, ProtonReconstructionAlgorithm::init(), lhcInfoLabel_, localAngleXMax_, localAngleXMin_, localAngleYMax_, localAngleYMin_, max_n_timing_tracks_, eostools::move(), multiRPReconstructionLabel_, opticsLabel_, opticsValid_, opticsWatcher_, AlCaHLTBitMon_ParallelJobs::p, edm::RefVector< C, T, F >::push_back(), edm::Event::put(), alignCSCRings::r, ProtonReconstructionAlgorithm::reconstructFromMultiRP(), ProtonReconstructionAlgorithm::reconstructFromSingleRP(), ProtonReconstructionAlgorithm::release(), year_2016_postTS2_cff::rpId, year_2016_cff::rpIds, CTPPSDetId::sdTrackingPixel, CTPPSDetId::sdTrackingStrip, reco::ForwardProton::setContributingLocalTracks(), reco::ForwardProton::setTime(), reco::ForwardProton::setTimeError(), singleRPReconstructionLabel_, mathSSE::sqrt(), ntuplemaker::time, tracksToken_, verbosity_, w, and z.

{
  // get input
  edm::Handle<CTPPSLocalTrackLiteCollection> hTracks;
  iEvent.getByToken(tracksToken_, hTracks);

  // book output
  std::unique_ptr<reco::ForwardProtonCollection> pOutSingleRP(new reco::ForwardProtonCollection);
  std::unique_ptr<reco::ForwardProtonCollection> pOutMultiRP(new reco::ForwardProtonCollection);

  // continue only if there is something to process
  // NB: this avoids loading (possibly non-existing) conditions in workflows without proton data
  if (!hTracks->empty())
  {
    // get conditions
    edm::ESHandle<LHCInfo> hLHCInfo;
    iSetup.get<LHCInfoRcd>().get(lhcInfoLabel_, hLHCInfo);

    edm::ESHandle<LHCInterpolatedOpticalFunctionsSetCollection> hOpticalFunctions;
    iSetup.get<CTPPSInterpolatedOpticsRcd>().get(opticsLabel_, hOpticalFunctions);

    edm::ESHandle<CTPPSGeometry> hGeometry;
    iSetup.get<VeryForwardRealGeometryRecord>().get(hGeometry);

    // re-initialise algorithm upon crossing-angle change
    if (opticsWatcher_.check(iSetup))
    {
      if (hOpticalFunctions->empty()) {
        edm::LogInfo("CTPPSProtonProducer") << "No optical functions available, reconstruction disabled.";
        algorithm_.release();
        opticsValid_ = false;
      }
      else {
        algorithm_.init(*hOpticalFunctions);
        opticsValid_ = true;
      }
    }

    // do reconstruction only if optics is valid
    if (opticsValid_)
    {
      // prepare log
      std::ostringstream ssLog;
      if (verbosity_)
        ssLog << "* input tracks:" << std::endl;

      // select tracks with small local angles, split them by LHC sector and tracker/timing RPs
      std::map<unsigned int, std::vector<unsigned int>> trackingSelection, timingSelection;

      for (unsigned int idx = 0; idx < hTracks->size(); ++idx)
      {
        const auto& tr = hTracks->at(idx);

        if (tr.getTx() < localAngleXMin_ || tr.getTx() > localAngleXMax_
            || tr.getTy() < localAngleYMin_ || tr.getTy() > localAngleYMax_)
          continue;

        const CTPPSDetId rpId(tr.getRPId());

        if (verbosity_)
          ssLog << "\t"
            << "[" << idx << "] "
            << tr.getRPId() << " (" << (rpId.arm()*100 + rpId.station()*10 + rpId.rp()) << "): "
            << "x=" << tr.getX() << " +- " << tr.getXUnc() << " mm, "
            << "y=" << tr.getY() << " +- " << tr.getYUnc() << " mm" << std::endl;

        const bool trackerRP = (rpId.subdetId() == CTPPSDetId::sdTrackingStrip || rpId.subdetId() == CTPPSDetId::sdTrackingPixel);

        if (trackerRP)
          trackingSelection[rpId.arm()].push_back(idx);
        else
          timingSelection[rpId.arm()].push_back(idx);
      }

      // process each arm
      for (const auto &arm_it : trackingSelection)
      {
        const auto &indices = arm_it.second;

        const auto &ac = association_cuts_[arm_it.first];

        // do single-RP reco if needed
        std::map<unsigned int, reco::ForwardProton> singleRPResultsIndexed;
        if (doSingleRPReconstruction_ || ac.xi_cut_apply || ac.th_y_cut_apply)
        {
          for (const auto &idx : indices)
          {
            if (verbosity_)
              ssLog << std::endl << "* reconstruction from track " << idx << std::endl;

            singleRPResultsIndexed[idx] = algorithm_.reconstructFromSingleRP(CTPPSLocalTrackLiteRef(hTracks, idx), *hLHCInfo, ssLog);
          }
        }

        // check that exactly two tracking RPs are involved
        //    - 1 is insufficient for multi-RP reconstruction
        //    - PPS did not use more than 2 tracking RPs per arm -> algorithms are tuned to this
        std::set<unsigned int> rpIds;
        for (const auto &idx : indices)
          rpIds.insert(hTracks->at(idx).getRPId());

        // do multi-RP reco if chosen
        if (doMultiRPReconstruction_ && rpIds.size() == 2)
        {
          // find matching track pairs from different tracking RPs
          std::vector<std::pair<unsigned int, unsigned int>> idx_pairs;
          std::map<unsigned int, unsigned int> idx_pair_multiplicity;
          for (const auto &i : indices)
          {
            for (const auto &j : indices)
            {
              if (j <= i)
                continue;

              const auto &tr_i = hTracks->at(i);
              const auto &tr_j = hTracks->at(j);

              const auto &pr_i = singleRPResultsIndexed[i];
              const auto &pr_j = singleRPResultsIndexed[j];

              if (tr_i.getRPId() == tr_j.getRPId())
                continue;

              bool matching = true;

              if (ac.x_cut_apply && std::abs(tr_i.getX() - tr_j.getX()) > ac.x_cut_value)
                matching = false;
              if (ac.y_cut_apply && std::abs(tr_i.getY() - tr_j.getY()) > ac.y_cut_value)
                matching = false;
              if (ac.xi_cut_apply && std::abs(pr_i.xi() - pr_j.xi()) > ac.xi_cut_value)
                matching = false;
              if (ac.th_y_cut_apply && std::abs(pr_i.thetaY() - pr_j.thetaY()) > ac.th_y_cut_value)
                matching = false;

              if (!matching)
                continue;

              idx_pairs.emplace_back(i, j);
              idx_pair_multiplicity[i]++;
              idx_pair_multiplicity[j]++;
            }
          }

          // evaluate track multiplicity in each timing RP
          std::map<unsigned int, unsigned int> timing_RP_track_multiplicity;
          for (const auto &ti : timingSelection[arm_it.first])
          {
            const auto &tr = hTracks->at(ti);
            timing_RP_track_multiplicity[tr.getRPId()]++;
          }

          // associate tracking-RP pairs with timing-RP tracks
          std::map<unsigned int, std::vector<unsigned int>> matched_timing_track_indices;
          std::map<unsigned int, unsigned int> matched_timing_track_multiplicity;
          for (unsigned int pr_idx = 0; pr_idx < idx_pairs.size(); ++pr_idx)
          {
            const auto &i = idx_pairs[pr_idx].first;
            const auto &j = idx_pairs[pr_idx].second;

            // skip non-unique associations
            if (idx_pair_multiplicity[i] > 1 || idx_pair_multiplicity[j] > 1)
              continue;

            const auto &tr_i = hTracks->at(i);
            const auto &tr_j = hTracks->at(j);

            const double z_i = hGeometry->getRPTranslation(tr_i.getRPId()).z();
            const double z_j = hGeometry->getRPTranslation(tr_j.getRPId()).z();

            for (const auto &ti : timingSelection[arm_it.first])
            {
              const auto &tr_ti = hTracks->at(ti);

              // skip if timing RP saturated (high track multiplicity)
              if (timing_RP_track_multiplicity[tr_ti.getRPId()] > max_n_timing_tracks_)
                continue;

              // interpolation from tracking RPs
              const double z_ti = - hGeometry->getRPTranslation(tr_ti.getRPId()).z(); // the minus sign fixes a bug in the diamond geometry
              const double f_i = (z_ti - z_j) / (z_i - z_j), f_j = (z_i - z_ti) / (z_i - z_j);
              const double x_inter = f_i * tr_i.getX() + f_j * tr_j.getX();
              const double x_inter_unc_sq = f_i*f_i * tr_i.getXUnc()*tr_i.getXUnc() + f_j*f_j * tr_j.getXUnc()*tr_j.getXUnc();

              const double de_x = tr_ti.getX() - x_inter;
              const double de_x_unc = sqrt(tr_ti.getXUnc()*tr_ti.getXUnc() + x_inter_unc_sq);
              const double r = (de_x_unc > 0.) ? de_x / de_x_unc : 1E100;

              const bool matching = (ac.ti_tr_min < r && r < ac.ti_tr_max);

              if (verbosity_)
                ssLog << "ti=" << ti << ", i=" << i << ", j=" << j
                  << " | z_ti=" << z_ti << ", z_i=" << z_i << ", z_j=" << z_j
                  << " | x_ti=" << tr_ti.getX() << ", x_inter=" << x_inter << ", de_x=" << de_x << ", de_x_unc=" << de_x_unc
                  << ", matching=" << matching << std::endl;

              if (!matching)
                continue;

              matched_timing_track_indices[pr_idx].push_back(ti);
              matched_timing_track_multiplicity[ti]++;
            }
          }

          // process associated tracks
          for (unsigned int pr_idx = 0; pr_idx < idx_pairs.size(); ++pr_idx)
          {
            const auto &i = idx_pairs[pr_idx].first;
            const auto &j = idx_pairs[pr_idx].second;

            // skip non-unique associations of tracking-RP tracks
            if (idx_pair_multiplicity[i] > 1 || idx_pair_multiplicity[j] > 1)
              continue;

            if (verbosity_)
              ssLog << std::endl << "* reconstruction from tracking-RP tracks: " << i << ", " << j << " and timing-RP tracks: ";

            // buffer contributing tracks
            CTPPSLocalTrackLiteRefVector sel_tracks;
            sel_tracks.push_back(CTPPSLocalTrackLiteRef(hTracks, i));
            sel_tracks.push_back(CTPPSLocalTrackLiteRef(hTracks, j));

            CTPPSLocalTrackLiteRefVector sel_track_for_kin_reco = sel_tracks;

            // process timing-RP data
            double sw=0., swt=0.;
            for (const auto &ti : matched_timing_track_indices[pr_idx])
            {
              // skip non-unique associations of timing-RP tracks
              if (matched_timing_track_multiplicity[ti] > 1)
                continue;

              sel_tracks.push_back(CTPPSLocalTrackLiteRef(hTracks, ti));

              if (verbosity_)
                ssLog << ti << ", ";

              const auto &tr = hTracks->at(ti);
              const double t_unc = tr.getTimeUnc();
              const double w = (t_unc > 0.) ? 1./t_unc/t_unc : 1.;
              sw += w;
              swt += w * tr.getTime();
            }

            float time = 0., time_unc = 0.;
            if (sw > 0.)
            {
              time = swt / sw;
              time_unc = 1. / sqrt(sw);
            }

            if (verbosity_)
              ssLog << std::endl << "    time = " << time << " +- " << time_unc << std::endl;

            // process tracking-RP data
            reco::ForwardProton proton = algorithm_.reconstructFromMultiRP(sel_track_for_kin_reco, *hLHCInfo, ssLog);

            // save combined output
            proton.setContributingLocalTracks(sel_tracks);
            proton.setTime(time);
            proton.setTimeError(time_unc);

            pOutMultiRP->emplace_back(proton);
          }
        }

        // save single-RP results (un-indexed)
        for (const auto &p : singleRPResultsIndexed)
          pOutSingleRP->emplace_back(std::move(p.second));
      }

      // dump log
      if (verbosity_)
        edm::LogInfo("CTPPSProtonProducer") << ssLog.str();
    }
  }

  // save output
  if (doSingleRPReconstruction_)
    iEvent.put(std::move(pOutSingleRP), singleRPReconstructionLabel_);

  if (doMultiRPReconstruction_)
    iEvent.put(std::move(pOutMultiRP), multiRPReconstructionLabel_);
}

Member Data Documentation

ProtonReconstructionAlgorithm CTPPSProtonProducer::algorithm_

private

Definition at line 114 of file CTPPSProtonProducer.cc.

Referenced by produce().

std::map<unsigned int, AssociationCuts> CTPPSProtonProducer::association_cuts_

private

Definition at line 110 of file CTPPSProtonProducer.cc.

Referenced by CTPPSProtonProducer(), and produce().

bool CTPPSProtonProducer::doMultiRPReconstruction_

private

Definition at line 54 of file CTPPSProtonProducer.cc.

Referenced by CTPPSProtonProducer(), and produce().

bool CTPPSProtonProducer::doSingleRPReconstruction_

private

Definition at line 53 of file CTPPSProtonProducer.cc.

Referenced by CTPPSProtonProducer(), and produce().

std::string CTPPSProtonProducer::lhcInfoLabel_

private

Definition at line 48 of file CTPPSProtonProducer.cc.

Referenced by produce().

double CTPPSProtonProducer::localAngleXMax_

private

Definition at line 59 of file CTPPSProtonProducer.cc.

Referenced by produce().

double CTPPSProtonProducer::localAngleXMin_

private

Definition at line 59 of file CTPPSProtonProducer.cc.

Referenced by produce().

double CTPPSProtonProducer::localAngleYMax_

private

Definition at line 59 of file CTPPSProtonProducer.cc.

Referenced by produce().

double CTPPSProtonProducer::localAngleYMin_

private

Definition at line 59 of file CTPPSProtonProducer.cc.

Referenced by produce().

unsigned int CTPPSProtonProducer::max_n_timing_tracks_

private

Definition at line 112 of file CTPPSProtonProducer.cc.

Referenced by produce().

std::string CTPPSProtonProducer::multiRPReconstructionLabel_

private

Definition at line 57 of file CTPPSProtonProducer.cc.

Referenced by CTPPSProtonProducer(), and produce().

std::string CTPPSProtonProducer::opticsLabel_

private

Definition at line 49 of file CTPPSProtonProducer.cc.

Referenced by produce().

bool CTPPSProtonProducer::opticsValid_

private

Definition at line 116 of file CTPPSProtonProducer.cc.

Referenced by produce().

edm::ESWatcher<CTPPSInterpolatedOpticsRcd> CTPPSProtonProducer::opticsWatcher_

private

Definition at line 117 of file CTPPSProtonProducer.cc.

Referenced by produce().

std::string CTPPSProtonProducer::singleRPReconstructionLabel_

private

Definition at line 56 of file CTPPSProtonProducer.cc.

Referenced by CTPPSProtonProducer(), and produce().

edm::EDGetTokenT<CTPPSLocalTrackLiteCollection> CTPPSProtonProducer::tracksToken_

private

Definition at line 46 of file CTPPSProtonProducer.cc.

Referenced by produce().

unsigned int CTPPSProtonProducer::verbosity_

private

Definition at line 51 of file CTPPSProtonProducer.cc.

Referenced by produce().