ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits > Class Template Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >:

Public Types
using	Algo = pixelDetails::SiPixelRawToClusterKernel< TrackerTraits >
Public Types inherited from edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, Args... >
using	BranchAliasSetterT = ProductRegistryHelper::BranchAliasSetterT< T >
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex > >
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Public Member Functions
	SiPixelRawToCluster (const edm::ParameterSet &iConfig)
	~SiPixelRawToCluster () override=default
Public Member Functions inherited from ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>
void	acquire (edm::Event const &iEvent, edm::EventSetup const &iSetup, edm::WaitingTaskWithArenaHolder holder) final
void	produce (edm::Event &iEvent, edm::EventSetup const &iSetup) final
Public Member Functions inherited from edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, Args... >
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const
	ProducerBase ()
std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const
std::vector< bool > const &	recordProvenanceList () const
void	registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...
void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...
	~ProducerBase () noexcept(false) override

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

Private Member Functions
void	acquire (device::Event const &iEvent, device::EventSetup const &iSetup) override
void	produce (device::Event &iEvent, device::EventSetup const &iSetup) override

Private Attributes
Algo	Algo_
std::unique_ptr< SiPixelFedCablingTree >	cabling_
const SiPixelFedCablingMap *	cablingMap_ = nullptr
const edm::ESGetToken< SiPixelFedCablingMap, SiPixelFedCablingMapRcd >	cablingMapToken_
device::EDPutToken< SiPixelClustersSoACollection >	clusterPutToken_
const SiPixelClusterThresholds	clusterThresholds_
device::EDPutToken< SiPixelDigiErrorsSoACollection >	digiErrorPutToken_
device::EDPutToken< SiPixelDigisSoACollection >	digiPutToken_
PixelDataFormatter::Errors	errors_
std::vector< unsigned int >	fedIds_
edm::EDPutTokenT< SiPixelFormatterErrors >	fmtErrorToken_
const device::ESGetToken< SiPixelGainCalibrationForHLTDevice, SiPixelGainCalibrationForHLTSoARcd >	gainsToken_
const bool	includeErrors_
const device::ESGetToken< SiPixelMappingDevice, SiPixelMappingSoARecord >	mapToken_
uint32_t	nDigis_
edm::EDGetTokenT< FEDRawDataCollection >	rawGetToken_
edm::ESWatcher< SiPixelFedCablingMapRcd >	recordWatcher_
std::unique_ptr< PixelUnpackingRegions >	regions_
const bool	useQuality_

Additional Inherited Members
Protected Member Functions inherited from edm::ProducerBase< edm::stream::EDProducer, edm::ExternalWork, Args... >
auto	produces (std::string instanceName) noexcept
	declare what type of product will make and with which optional label More...
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
auto	produces () noexcept
ProducesCollector	producesCollector ()

Detailed Description

template<typename TrackerTraits>
class ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >

Definition at line 43 of file SiPixelRawToCluster.cc.

Member Typedef Documentation

Algo

template<typename TrackerTraits >

using ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::Algo = pixelDetails::SiPixelRawToClusterKernel<TrackerTraits>

Definition at line 49 of file SiPixelRawToCluster.cc.

Constructor & Destructor Documentation

SiPixelRawToCluster()

template<typename TrackerTraits >

ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::SiPixelRawToCluster ( const edm::ParameterSet &  iConfig )

explicit

Definition at line 81 of file SiPixelRawToCluster.cc.

References edm::ParameterSet::getParameter().

      : rawGetToken_(consumes(iConfig.getParameter<edm::InputTag>("InputLabel"))),
        digiPutToken_(produces()),
        clusterPutToken_(produces()),
        mapToken_(esConsumes()),
        gainsToken_(esConsumes()),
        cablingMapToken_(esConsumes<SiPixelFedCablingMap, SiPixelFedCablingMapRcd>(
            edm::ESInputTag("", iConfig.getParameter<std::string>("CablingMapLabel")))),
        includeErrors_(iConfig.getParameter<bool>("IncludeErrors")),
        useQuality_(iConfig.getParameter<bool>("UseQualityInfo")),
        clusterThresholds_{iConfig.getParameter<int32_t>("clusterThreshold_layer1"),
                           iConfig.getParameter<int32_t>("clusterThreshold_otherLayers"),
                           static_cast<float>(iConfig.getParameter<double>("VCaltoElectronGain")),
                           static_cast<float>(iConfig.getParameter<double>("VCaltoElectronGain_L1")),
                           static_cast<float>(iConfig.getParameter<double>("VCaltoElectronOffset")),
                           static_cast<float>(iConfig.getParameter<double>("VCaltoElectronOffset_L1"))} {
    if (includeErrors_) {
      digiErrorPutToken_ = produces();
      fmtErrorToken_ = produces();
    }

    // regions
    if (!iConfig.getParameter<edm::ParameterSet>("Regions").getParameterNames().empty()) {
      regions_ = std::make_unique<PixelUnpackingRegions>(iConfig, consumesCollector());
    }
  }

~SiPixelRawToCluster()

template<typename TrackerTraits >

ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::~SiPixelRawToCluster ( )

overridedefault

Member Function Documentation

acquire()

template<typename TrackerTraits >

void ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::acquire ( device::Event const &  iEvent, device::EventSetup const &  iSetup  )

overrideprivatevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 139 of file SiPixelRawToCluster.cc.

References cms::cuda::assert(), edm::MessageDrop::debugEnabled, l1tstage2_dqm_sourceclient-live_cfg::fedId, ecalph2::gains, ALPAKA_ACCELERATOR_NAMESPACE::device::EventSetup::getData(), ALPAKA_ACCELERATOR_NAMESPACE::SiPixelMappingUtilities::getModToUnpRegionalAsync(), RecoTauValidation_cfi::header, mps_fire::i, iEvent, ALPAKA_ACCELERATOR_NAMESPACE::pixelDetails::WordFedAppender::initializeWordFed(), edm::MessageDrop::instance(), LogDebug, pixelgpudetails::MAX_SIZE, FEDNumbering::MINSiPixeluTCAFEDID, l1ctLayer2EG_cff::nWords, l1tstage2_dqm_sourceclient-live_cfg::rawData, and command_line::start.

                                                                                                            {
    [[maybe_unused]] auto const& hMap = iSetup.getData(mapToken_);
    auto const& dGains = iSetup.getData(gainsToken_);
    auto gains = SiPixelGainCalibrationForHLTDevice(1, iEvent.queue());
    auto modulesToUnpackRegional =
        cms::alpakatools::make_device_buffer<unsigned char[]>(iEvent.queue(), ::pixelgpudetails::MAX_SIZE);
    const unsigned char* modulesToUnpack;
    // initialize cabling map or update if necessary
    if (recordWatcher_.check(iSetup)) {
      // cabling map, which maps online address (fed->link->ROC->local pixel) to offline (DetId->global pixel)
      cablingMap_ = &iSetup.getData(cablingMapToken_);
      fedIds_ = cablingMap_->fedIds();
      cabling_ = cablingMap_->cablingTree();
      LogDebug("map version:") << cablingMap_->version();
    }
    if (regions_) {
      regions_->run(iEvent, iSetup);
      LogDebug("SiPixelRawToCluster") << "region2unpack #feds: " << regions_->nFEDs();
      LogDebug("SiPixelRawToCluster") << "region2unpack #modules (BPIX,EPIX,total): " << regions_->nBarrelModules()
                                      << " " << regions_->nForwardModules() << " " << regions_->nModules();

      modulesToUnpackRegional = SiPixelMappingUtilities::getModToUnpRegionalAsync(
          *(regions_->modulesToUnpack()), cabling_.get(), fedIds_, iEvent.queue());
      modulesToUnpack = modulesToUnpackRegional.data();
    } else {
      modulesToUnpack = hMap->modToUnpDefault();
    }

    const auto& buffers = iEvent.get(rawGetToken_);

    errors_.clear();

    // GPU specific: Data extraction for RawToDigi GPU
    unsigned int wordCounter = 0;
    unsigned int fedCounter = 0;
    bool errorsInEvent = false;
    std::vector<unsigned int> index(fedIds_.size(), 0);
    std::vector<cms_uint32_t const*> start(fedIds_.size(), nullptr);
    std::vector<ptrdiff_t> words(fedIds_.size(), 0);
    // In CPU algorithm this loop is part of PixelDataFormatter::interpretRawData()
    ErrorChecker errorcheck;
    for (uint32_t i = 0; i < fedIds_.size(); ++i) {
      const int fedId = fedIds_[i];
      if (regions_ && !regions_->mayUnpackFED(fedId))
        continue;

      // for GPU
      // first 150 index stores the fedId and next 150 will store the
      // start index of word in that fed
      assert(fedId >= FEDNumbering::MINSiPixeluTCAFEDID);
      fedCounter++;

      // get event data for this fed
      const FEDRawData& rawData = buffers.FEDData(fedId);

      // GPU specific
      int nWords = rawData.size() / sizeof(cms_uint64_t);
      if (nWords == 0) {
        continue;
      }
      // check CRC bit
      const cms_uint64_t* trailer = reinterpret_cast<const cms_uint64_t*>(rawData.data()) + (nWords - 1);
      if (not errorcheck.checkCRC(errorsInEvent, fedId, trailer, errors_)) {
        continue;
      }
      // check headers
      const cms_uint64_t* header = reinterpret_cast<const cms_uint64_t*>(rawData.data());
      header--;
      bool moreHeaders = true;
      while (moreHeaders) {
        header++;
        bool headerStatus = errorcheck.checkHeader(errorsInEvent, fedId, header, errors_);
        moreHeaders = headerStatus;
      }

      // check trailers
      bool moreTrailers = true;
      trailer++;
      while (moreTrailers) {
        trailer--;
        bool trailerStatus = errorcheck.checkTrailer(errorsInEvent, fedId, nWords, trailer, errors_);
        moreTrailers = trailerStatus;
      }

      const cms_uint32_t* bw = (const cms_uint32_t*)(header + 1);
      const cms_uint32_t* ew = (const cms_uint32_t*)(trailer);

      assert(0 == (ew - bw) % 2);
      index[i] = wordCounter;
      start[i] = bw;
      words[i] = (ew - bw);
      wordCounter += (ew - bw);

    }  // end of for loop
    nDigis_ = wordCounter;
    if (nDigis_ == 0)
      return;

    // copy the FED data to a single cpu buffer
    pixelDetails::WordFedAppender wordFedAppender(nDigis_);
    for (uint32_t i = 0; i < fedIds_.size(); ++i) {
      wordFedAppender.initializeWordFed(fedIds_[i], index[i], start[i], words[i]);
    }
    Algo_.makePhase1ClustersAsync(iEvent.queue(),
                                  clusterThresholds_,
                                  hMap.const_view(),
                                  modulesToUnpack,
                                  dGains.const_view(),
                                  wordFedAppender,
                                  wordCounter,
                                  fedCounter,
                                  useQuality_,
                                  includeErrors_,
                                  edm::MessageDrop::instance()->debugEnabled);
  }

fillDescriptions()

template<typename TrackerTraits >

void ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 109 of file SiPixelRawToCluster.cc.

References edm::ParameterSetDescription::addOptional(), edm::ConfigurationDescriptions::addWithDefaultLabel(), pixelClustering::clusterThresholdLayerOne, pixelClustering::clusterThresholdOtherLayers, submitPVResolutionJobs::desc, ProducerED_cfi::InputTag, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                      {
    edm::ParameterSetDescription desc;
    desc.add<bool>("IncludeErrors", true);
    desc.add<bool>("UseQualityInfo", false);
    // Note: this parameter is obsolete: it is ignored and will have no effect.
    // It is kept to avoid breaking older configurations, and will not be printed in the generated cfi.py file.
    desc.addOptionalNode(edm::ParameterDescription<uint32_t>("MaxFEDWords", 0, true), false)
        ->setComment("This parameter is obsolete and will be ignored.");
    desc.add<int32_t>("clusterThreshold_layer1", pixelClustering::clusterThresholdLayerOne);
    desc.add<int32_t>("clusterThreshold_otherLayers", pixelClustering::clusterThresholdOtherLayers);
    desc.add<double>("VCaltoElectronGain", 47.f);
    desc.add<double>("VCaltoElectronGain_L1", 50.f);
    desc.add<double>("VCaltoElectronOffset", -60.f);
    desc.add<double>("VCaltoElectronOffset_L1", -670.f);

    desc.add<edm::InputTag>("InputLabel", edm::InputTag("rawDataCollector"));
    {
      edm::ParameterSetDescription psd0;
      psd0.addOptional<std::vector<edm::InputTag>>("inputs");
      psd0.addOptional<std::vector<double>>("deltaPhi");
      psd0.addOptional<std::vector<double>>("maxZ");
      psd0.addOptional<edm::InputTag>("beamSpot");
      desc.add<edm::ParameterSetDescription>("Regions", psd0)
          ->setComment("## Empty Regions PSet means complete unpacking");
    }
    desc.add<std::string>("CablingMapLabel", "")->setComment("CablingMap label");  //Tav
    descriptions.addWithDefaultLabel(desc);
  }

produce()

template<typename TrackerTraits >

void ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::produce ( device::Event &  iEvent, device::EventSetup const &  iSetup  )

overrideprivatevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::SynchronizingEDProducer<>.

Definition at line 256 of file SiPixelRawToCluster.cc.

References iEvent, eostools::move(), and pixelTopology::Phase1::numberOfModules.

                                                                                                      {
    if (nDigis_ == 0) {
      // Cannot use the default constructor here, as it would not allocate memory.
      // In the case of no digis, clusters_d are not being instantiated, but are
      // still used downstream to initialize TrackingRecHitSoADevice. If there
      // are no valid pointers to clusters' Collection columns, instantiation
      // of TrackingRecHits fail. Example: workflow 11604.0

      iEvent.emplace(digiPutToken_, nDigis_, iEvent.queue());
      iEvent.emplace(clusterPutToken_, pixelTopology::Phase1::numberOfModules, iEvent.queue());
      if (includeErrors_) {
        iEvent.emplace(digiErrorPutToken_);
        iEvent.emplace(fmtErrorToken_);
      }
      return;
    }

    iEvent.emplace(digiPutToken_, Algo_.getDigis());
    iEvent.emplace(clusterPutToken_, Algo_.getClusters());
    if (includeErrors_) {
      iEvent.emplace(digiErrorPutToken_, Algo_.getErrors());
      iEvent.emplace(fmtErrorToken_, std::move(errors_));
    }
  }

Member Data Documentation

Algo_

template<typename TrackerTraits >

Algo ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::Algo_

private

Definition at line 71 of file SiPixelRawToCluster.cc.

cabling_

template<typename TrackerTraits >

std::unique_ptr<SiPixelFedCablingTree> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::cabling_

private

Definition at line 66 of file SiPixelRawToCluster.cc.

cablingMap_

template<typename TrackerTraits >

const SiPixelFedCablingMap* ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::cablingMap_ = nullptr

private

Definition at line 68 of file SiPixelRawToCluster.cc.

cablingMapToken_

template<typename TrackerTraits >

const edm::ESGetToken<SiPixelFedCablingMap, SiPixelFedCablingMapRcd> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::cablingMapToken_

private

Definition at line 64 of file SiPixelRawToCluster.cc.

clusterPutToken_

template<typename TrackerTraits >

device::EDPutToken<SiPixelClustersSoACollection> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::clusterPutToken_

private

Definition at line 59 of file SiPixelRawToCluster.cc.

clusterThresholds_

template<typename TrackerTraits >

const SiPixelClusterThresholds ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::clusterThresholds_

private

Definition at line 77 of file SiPixelRawToCluster.cc.

digiErrorPutToken_

template<typename TrackerTraits >

device::EDPutToken<SiPixelDigiErrorsSoACollection> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::digiErrorPutToken_

private

Definition at line 58 of file SiPixelRawToCluster.cc.

digiPutToken_

template<typename TrackerTraits >

device::EDPutToken<SiPixelDigisSoACollection> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::digiPutToken_

private

Definition at line 57 of file SiPixelRawToCluster.cc.

errors_

template<typename TrackerTraits >

PixelDataFormatter::Errors ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::errors_

private

Definition at line 72 of file SiPixelRawToCluster.cc.

fedIds_

template<typename TrackerTraits >

std::vector<unsigned int> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::fedIds_

private

Definition at line 67 of file SiPixelRawToCluster.cc.

fmtErrorToken_

template<typename TrackerTraits >

edm::EDPutTokenT<SiPixelFormatterErrors> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::fmtErrorToken_

private

Definition at line 56 of file SiPixelRawToCluster.cc.

gainsToken_

template<typename TrackerTraits >

const device::ESGetToken<SiPixelGainCalibrationForHLTDevice, SiPixelGainCalibrationForHLTSoARcd> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::gainsToken_

private

Definition at line 63 of file SiPixelRawToCluster.cc.

includeErrors_

template<typename TrackerTraits >

const bool ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::includeErrors_

private

Definition at line 74 of file SiPixelRawToCluster.cc.

mapToken_

template<typename TrackerTraits >

const device::ESGetToken<SiPixelMappingDevice, SiPixelMappingSoARecord> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::mapToken_

private

Definition at line 62 of file SiPixelRawToCluster.cc.

nDigis_

template<typename TrackerTraits >

uint32_t ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::nDigis_

private

Definition at line 76 of file SiPixelRawToCluster.cc.

rawGetToken_

template<typename TrackerTraits >

edm::EDGetTokenT<FEDRawDataCollection> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::rawGetToken_

private

Definition at line 55 of file SiPixelRawToCluster.cc.

recordWatcher_

template<typename TrackerTraits >

edm::ESWatcher<SiPixelFedCablingMapRcd> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::recordWatcher_

private

Definition at line 61 of file SiPixelRawToCluster.cc.

regions_

template<typename TrackerTraits >

std::unique_ptr<PixelUnpackingRegions> ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::regions_

private

Definition at line 69 of file SiPixelRawToCluster.cc.

useQuality_

template<typename TrackerTraits >

const bool ALPAKA_ACCELERATOR_NAMESPACE::SiPixelRawToCluster< TrackerTraits >::useQuality_

private

Definition at line 75 of file SiPixelRawToCluster.cc.