ALPAKA_ACCELERATOR_NAMESPACE::ECLCCCompute1 Class Reference

#include <PFClusterECLCC.h>

Public Member Functions
template<typename TAcc , typename = std::enable_if_t<alpaka::isAccelerator<TAcc>>>
ALPAKA_FN_ACC void	operator() (const TAcc &acc, reco::PFRecHitHostCollection::ConstView pfRecHits, reco::PFClusteringVarsDeviceCollection::View pfClusteringVars, reco::PFClusteringEdgeVarsDeviceCollection::View pfClusteringEdgeVars) const

Detailed Description

Definition at line 104 of file PFClusterECLCC.h.

Member Function Documentation

operator()()

template<typename TAcc , typename = std::enable_if_t<alpaka::isAccelerator<TAcc>>>

ALPAKA_FN_ACC void ALPAKA_ACCELERATOR_NAMESPACE::ECLCCCompute1::operator() ( const TAcc &  acc, reco::PFRecHitHostCollection::ConstView  pfRecHits, reco::PFClusteringVarsDeviceCollection::View  pfClusteringVars, reco::PFClusteringEdgeVarsDeviceCollection::View  pfClusteringEdgeVars  ) const

inline

Definition at line 107 of file PFClusterECLCC.h.

References cms::alpakatools::elements_with_stride(), mps_fire::i, pfClusterHBHEAlpaka_cff::pfRecHits, ALPAKA_ACCELERATOR_NAMESPACE::representative(), runTheMatrix::ret, and findQualityFiles::v.

                                                                                                           {
      const int nRH = pfRecHits.size();

      for (int v : cms::alpakatools::elements_with_stride(acc, nRH)) {
        const int vstat = pfClusteringVars[v].pfrh_topoId();
        if (v != vstat) {
          const int beg = pfClusteringEdgeVars[v].pfrh_edgeIdx();
          const int end = pfClusteringEdgeVars[v + 1].pfrh_edgeIdx();
          int vstat = representative(v, pfClusteringVars);
          for (int i = beg; i < end; i++) {
            const int nli = pfClusteringEdgeVars[i].pfrh_edgeList();
            if (v > nli) {
              int ostat = representative(nli, pfClusteringVars);
              bool repeat;
              do {
                repeat = false;
                if (vstat != ostat) {
                  int ret;
                  if (vstat < ostat) {
                    if ((ret = alpaka::atomicCas(acc, &pfClusteringVars[ostat].pfrh_topoId(), ostat, vstat)) != ostat) {
                      ostat = ret;
                      repeat = true;
                    }
                  } else {
                    if ((ret = alpaka::atomicCas(acc, &pfClusteringVars[vstat].pfrh_topoId(), vstat, ostat)) != vstat) {
                      vstat = ret;
                      repeat = true;
                    }
                  }
                }
              } while (repeat);
            }
          }
        }
      }
    }