EcalRecHitProducerGPU Class Reference

Inheritance diagram for EcalRecHitProducerGPU:

Public Member Functions
	EcalRecHitProducerGPU (edm::ParameterSet const &ps)
	~EcalRecHitProducerGPU () override
Public Member Functions inherited from edm::stream::EDProducer< edm::ExternalWork >
	EDProducer ()=default
bool	hasAbilityToProduceInBeginLumis () const final
bool	hasAbilityToProduceInBeginProcessBlocks () const final
bool	hasAbilityToProduceInBeginRuns () const final
bool	hasAbilityToProduceInEndLumis () const final
bool	hasAbilityToProduceInEndProcessBlocks () const final
bool	hasAbilityToProduceInEndRuns () const final

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

Private Types
using	InputProduct = cms::cuda::Product< ecal::UncalibratedRecHit< calo::common::DevStoragePolicy > >
using	OutputProduct = cms::cuda::Product< ecal::RecHit< calo::common::DevStoragePolicy > >

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

Private Attributes
edm::ESHandle< EcalRechitADCToGeVConstantGPU >	ADCToGeVConstantHandle_
edm::ESHandle< EcalRechitChannelStatusGPU >	ChannelStatusHandle_
ecal::rechit::ConfigurationParameters	configParameters_
cms::cuda::ContextState	cudaState_
ecal::rechit::EventOutputDataGPU	eventOutputDataGPU_
std::vector< uint32_t >	expanded_flagbit_v_DB_reco_flags_
std::vector< uint32_t >	expanded_Sizes_v_DB_reco_flags_
std::vector< int >	expanded_v_DB_reco_flags_
uint32_t	flagmask_
edm::ESHandle< EcalIntercalibConstantsGPU >	IntercalibConstantsHandle_
edm::ESHandle< EcalLaserAlphasGPU >	LaserAlphasHandle_
edm::ESHandle< EcalLaserAPDPNRatiosGPU >	LaserAPDPNRatiosHandle_
edm::ESHandle< EcalLaserAPDPNRatiosRefGPU >	LaserAPDPNRatiosRefHandle_
edm::ESHandle< EcalLinearCorrectionsGPU >	LinearCorrectionsHandle_
uint32_t	neb_
uint32_t	nee_
edm::ESHandle< EcalRecHitParametersGPU >	recHitParametersHandle_
edm::EDPutTokenT< OutputProduct >	recHitsTokenEB_
edm::EDPutTokenT< OutputProduct >	recHitsTokenEE_
edm::EDGetTokenT< InputProduct >	uncalibRecHitsInEBToken_
edm::EDGetTokenT< InputProduct >	uncalibRecHitsInEEToken_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer< edm::ExternalWork >
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 34 of file EcalRecHitProducerGPU.cc.

Member Typedef Documentation

InputProduct

using EcalRecHitProducerGPU::InputProduct = cms::cuda::Product<ecal::UncalibratedRecHit<calo::common::DevStoragePolicy> >

private

Definition at line 49 of file EcalRecHitProducerGPU.cc.

OutputProduct

using EcalRecHitProducerGPU::OutputProduct = cms::cuda::Product<ecal::RecHit<calo::common::DevStoragePolicy> >

private

Definition at line 59 of file EcalRecHitProducerGPU.cc.

Constructor & Destructor Documentation

EcalRecHitProducerGPU()

EcalRecHitProducerGPU::EcalRecHitProducerGPU ( edm::ParameterSet const &  ps )

explicit

Definition at line 107 of file EcalRecHitProducerGPU.cc.

                                                                      {
  //---- input
  uncalibRecHitsInEBToken_ = consumes<InputProduct>(ps.getParameter<edm::InputTag>("uncalibrecHitsInLabelEB"));
  uncalibRecHitsInEEToken_ = consumes<InputProduct>(ps.getParameter<edm::InputTag>("uncalibrecHitsInLabelEE"));
 
  //---- output
  recHitsTokenEB_ = produces<OutputProduct>(ps.getParameter<std::string>("recHitsLabelEB"));
  recHitsTokenEE_ = produces<OutputProduct>(ps.getParameter<std::string>("recHitsLabelEE"));
 
  bool killDeadChannels = ps.getParameter<bool>("killDeadChannels");
  configParameters_.killDeadChannels = killDeadChannels;
 
  configParameters_.EBLaserMIN = ps.getParameter<double>("EBLaserMIN");
  configParameters_.EELaserMIN = ps.getParameter<double>("EELaserMIN");
  configParameters_.EBLaserMAX = ps.getParameter<double>("EBLaserMAX");
  configParameters_.EELaserMAX = ps.getParameter<double>("EELaserMAX");
 
  // max number of digis to allocate for
  configParameters_.maxNumberHitsEB = ps.getParameter<uint32_t>("maxNumberHitsEB");
  configParameters_.maxNumberHitsEE = ps.getParameter<uint32_t>("maxNumberHitsEE");
 
  flagmask_ = 0;
  flagmask_ |= 0x1 << EcalRecHit::kNeighboursRecovered;
  flagmask_ |= 0x1 << EcalRecHit::kTowerRecovered;
  flagmask_ |= 0x1 << EcalRecHit::kDead;
  flagmask_ |= 0x1 << EcalRecHit::kKilled;
  flagmask_ |= 0x1 << EcalRecHit::kTPSaturated;
  flagmask_ |= 0x1 << EcalRecHit::kL1SpikeFlag;
 
  configParameters_.flagmask = flagmask_;
 
  // for recovery and killing
 
  configParameters_.recoverEBIsolatedChannels = ps.getParameter<bool>("recoverEBIsolatedChannels");
  configParameters_.recoverEEIsolatedChannels = ps.getParameter<bool>("recoverEEIsolatedChannels");
  configParameters_.recoverEBVFE = ps.getParameter<bool>("recoverEBVFE");
  configParameters_.recoverEEVFE = ps.getParameter<bool>("recoverEEVFE");
  configParameters_.recoverEBFE = ps.getParameter<bool>("recoverEBFE");
  configParameters_.recoverEEFE = ps.getParameter<bool>("recoverEEFE");
}

References configParameters_, ecal::rechit::ConfigurationParameters::EBLaserMAX, ecal::rechit::ConfigurationParameters::EBLaserMIN, ecal::rechit::ConfigurationParameters::EELaserMAX, ecal::rechit::ConfigurationParameters::EELaserMIN, ecal::rechit::ConfigurationParameters::flagmask, flagmask_, edm::ParameterSet::getParameter(), EcalRecHit::kDead, ecal::rechit::ConfigurationParameters::killDeadChannels, HLT_FULL_cff::killDeadChannels, EcalRecHit::kKilled, EcalRecHit::kL1SpikeFlag, EcalRecHit::kNeighboursRecovered, EcalRecHit::kTowerRecovered, EcalRecHit::kTPSaturated, ecal::rechit::ConfigurationParameters::maxNumberHitsEB, ecal::rechit::ConfigurationParameters::maxNumberHitsEE, recHitsTokenEB_, recHitsTokenEE_, ecal::rechit::ConfigurationParameters::recoverEBFE, ecal::rechit::ConfigurationParameters::recoverEBIsolatedChannels, ecal::rechit::ConfigurationParameters::recoverEBVFE, ecal::rechit::ConfigurationParameters::recoverEEFE, ecal::rechit::ConfigurationParameters::recoverEEIsolatedChannels, ecal::rechit::ConfigurationParameters::recoverEEVFE, AlCaHLTBitMon_QueryRunRegistry::string, uncalibRecHitsInEBToken_, and uncalibRecHitsInEEToken_.

~EcalRecHitProducerGPU()

EcalRecHitProducerGPU::~EcalRecHitProducerGPU ( )

override

Definition at line 148 of file EcalRecHitProducerGPU.cc.

{}

Member Function Documentation

acquire()

void EcalRecHitProducerGPU::acquire ( edm::Event const &  event, edm::EventSetup const &  setup, edm::WaitingTaskWithArenaHolder  holder  )

overrideprivate

Definition at line 150 of file EcalRecHitProducerGPU.cc.

                                                                          {
  // cuda products
  auto const& ebUncalibRecHitsProduct = event.get(uncalibRecHitsInEBToken_);
  auto const& eeUncalibRecHitsProduct = event.get(uncalibRecHitsInEEToken_);
  // raii
  cms::cuda::ScopedContextAcquire ctx{ebUncalibRecHitsProduct, std::move(holder), cudaState_};
  // get actual object
  auto const& ebUncalibRecHits = ctx.get(ebUncalibRecHitsProduct);
  auto const& eeUncalibRecHits = ctx.get(eeUncalibRecHitsProduct);
 
  ecal::rechit::EventInputDataGPU inputDataGPU{ebUncalibRecHits, eeUncalibRecHits};
 
  neb_ = ebUncalibRecHits.size;
  nee_ = eeUncalibRecHits.size;
 
  // stop here if there are no uncalibRecHits
  if (neb_ + nee_ == 0)
    return;
 
  if ((neb_ > configParameters_.maxNumberHitsEB) || (nee_ > configParameters_.maxNumberHitsEE)) {
    edm::LogError("EcalRecHitProducerGPU")
        << "max number of channels exceeded. See options 'maxNumberHitsEB and maxNumberHitsEE' ";
  }
 
  int nchannelsEB = ebUncalibRecHits.size;  // --> offsetForInput, first EB and then EE
 
  // conditions
  // - laser correction
  // - IC
  // - adt2gev
 
  //
  setup.get<EcalADCToGeVConstantRcd>().get(ADCToGeVConstantHandle_);
  setup.get<EcalIntercalibConstantsRcd>().get(IntercalibConstantsHandle_);
  setup.get<EcalChannelStatusRcd>().get(ChannelStatusHandle_);
 
  setup.get<EcalLaserAPDPNRatiosRcd>().get(LaserAPDPNRatiosHandle_);
  setup.get<EcalLaserAPDPNRatiosRefRcd>().get(LaserAPDPNRatiosRefHandle_);
  setup.get<EcalLaserAlphasRcd>().get(LaserAlphasHandle_);
  setup.get<EcalLinearCorrectionsRcd>().get(LinearCorrectionsHandle_);
  setup.get<JobConfigurationGPURecord>().get(recHitParametersHandle_);
 
  auto const& ADCToGeVConstantProduct = ADCToGeVConstantHandle_->getProduct(ctx.stream());
  auto const& IntercalibConstantsProduct = IntercalibConstantsHandle_->getProduct(ctx.stream());
  auto const& ChannelStatusProduct = ChannelStatusHandle_->getProduct(ctx.stream());
 
  auto const& LaserAPDPNRatiosProduct = LaserAPDPNRatiosHandle_->getProduct(ctx.stream());
  auto const& LaserAPDPNRatiosRefProduct = LaserAPDPNRatiosRefHandle_->getProduct(ctx.stream());
  auto const& LaserAlphasProduct = LaserAlphasHandle_->getProduct(ctx.stream());
  auto const& LinearCorrectionsProduct = LinearCorrectionsHandle_->getProduct(ctx.stream());
  auto const& recHitParametersProduct = recHitParametersHandle_->getProduct(ctx.stream());
 
  // set config ptrs : this is done to avoid changing things downstream
  configParameters_.ChannelStatusToBeExcluded = recHitParametersProduct.channelStatusToBeExcluded.get();
  configParameters_.ChannelStatusToBeExcludedSize = std::get<0>(recHitParametersHandle_->getValues()).get().size();
  configParameters_.expanded_v_DB_reco_flags = recHitParametersProduct.expanded_v_DB_reco_flags.get();
  configParameters_.expanded_Sizes_v_DB_reco_flags = recHitParametersProduct.expanded_Sizes_v_DB_reco_flags.get();
  configParameters_.expanded_flagbit_v_DB_reco_flags = recHitParametersProduct.expanded_flagbit_v_DB_reco_flags.get();
  configParameters_.expanded_v_DB_reco_flagsSize = std::get<3>(recHitParametersHandle_->getValues()).get().size();
 
  // bundle up conditions
  ecal::rechit::ConditionsProducts conditions{ADCToGeVConstantProduct,
                                              IntercalibConstantsProduct,
                                              ChannelStatusProduct,
                                              LaserAPDPNRatiosProduct,
                                              LaserAPDPNRatiosRefProduct,
                                              LaserAlphasProduct,
                                              LinearCorrectionsProduct,
                                              IntercalibConstantsHandle_->getOffset()};
 
  // dev mem
  eventOutputDataGPU_.allocate(configParameters_, ctx.stream());
 
  //
  // schedule algorithms
  //
 
  edm::TimeValue_t event_time = event.time().value();
 
  ecal::rechit::create_ecal_rehit(
      inputDataGPU, eventOutputDataGPU_, conditions, configParameters_, nchannelsEB, event_time, ctx.stream());
 
  cudaCheck(cudaGetLastError());
}

References ADCToGeVConstantHandle_, ecal::rechit::EventOutputDataGPU::allocate(), ChannelStatusHandle_, ecal::rechit::ConfigurationParameters::ChannelStatusToBeExcluded, ecal::rechit::ConfigurationParameters::ChannelStatusToBeExcludedSize, submitPVValidationJobs::conditions, configParameters_, ecal::rechit::create_ecal_rehit(), cudaCheck, cudaState_, eventOutputDataGPU_, ecal::rechit::ConfigurationParameters::expanded_flagbit_v_DB_reco_flags, ecal::rechit::ConfigurationParameters::expanded_Sizes_v_DB_reco_flags, ecal::rechit::ConfigurationParameters::expanded_v_DB_reco_flags, ecal::rechit::ConfigurationParameters::expanded_v_DB_reco_flagsSize, get, EcalIntercalibConstantsGPU::getOffset(), EcalIntercalibConstantsGPU::getProduct(), EcalLaserAPDPNRatiosRefGPU::getProduct(), EcalLaserAlphasGPU::getProduct(), EcalRechitADCToGeVConstantGPU::getProduct(), EcalRechitChannelStatusGPU::getProduct(), EcalRecHitParametersGPU::getProduct(), EcalLinearCorrectionsGPU::getProduct(), EcalLaserAPDPNRatiosGPU::getProduct(), EcalRecHitParametersGPU::getValues(), IntercalibConstantsHandle_, LaserAlphasHandle_, LaserAPDPNRatiosHandle_, LaserAPDPNRatiosRefHandle_, LinearCorrectionsHandle_, ecal::rechit::ConfigurationParameters::maxNumberHitsEB, ecal::rechit::ConfigurationParameters::maxNumberHitsEE, eostools::move(), neb_, nee_, recHitParametersHandle_, singleTopDQM_cfi::setup, uncalibRecHitsInEBToken_, and uncalibRecHitsInEEToken_.

fillDescriptions()

void EcalRecHitProducerGPU::fillDescriptions ( edm::ConfigurationDescriptions &  confDesc )

static

Definition at line 85 of file EcalRecHitProducerGPU.cc.

                                                                                   {
  edm::ParameterSetDescription desc;
 
  desc.add<edm::InputTag>("uncalibrecHitsInLabelEB",
                          edm::InputTag("ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEB"));
  desc.add<edm::InputTag>("uncalibrecHitsInLabelEE",
                          edm::InputTag("ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEE"));
 
  desc.add<std::string>("recHitsLabelEB", "EcalRecHitsGPUEB");
  desc.add<std::string>("recHitsLabelEE", "EcalRecHitsGPUEE");
 
  desc.add<bool>("killDeadChannels", true);
 
  desc.add<double>("EBLaserMIN", 0.01);
  desc.add<double>("EELaserMIN", 0.01);
  desc.add<double>("EBLaserMAX", 30.0);
  desc.add<double>("EELaserMAX", 30.0);
 
  desc.add<uint32_t>("maxNumberHitsEB", 61200);
  desc.add<uint32_t>("maxNumberHitsEE", 14648);
}

References submitPVResolutionJobs::desc, HLT_FULL_cff::InputTag, and AlCaHLTBitMon_QueryRunRegistry::string.

produce()

void EcalRecHitProducerGPU::produce ( edm::Event &  event, edm::EventSetup const &  setup  )

overrideprivate

Definition at line 237 of file EcalRecHitProducerGPU.cc.

                                                                               {
  cms::cuda::ScopedContextProduce ctx{cudaState_};
 
  eventOutputDataGPU_.recHitsEB.size = neb_;
  eventOutputDataGPU_.recHitsEE.size = nee_;
 
  // put into the event
  ctx.emplace(event, recHitsTokenEB_, std::move(eventOutputDataGPU_.recHitsEB));
  ctx.emplace(event, recHitsTokenEE_, std::move(eventOutputDataGPU_.recHitsEE));
}

References cudaState_, eventOutputDataGPU_, eostools::move(), neb_, nee_, ecal::rechit::EventOutputDataGPU::recHitsEB, ecal::rechit::EventOutputDataGPU::recHitsEE, recHitsTokenEB_, and recHitsTokenEE_.

Member Data Documentation

ADCToGeVConstantHandle_

edm::ESHandle<EcalRechitADCToGeVConstantGPU> EcalRecHitProducerGPU::ADCToGeVConstantHandle_

private

Definition at line 66 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

ChannelStatusHandle_

edm::ESHandle<EcalRechitChannelStatusGPU> EcalRecHitProducerGPU::ChannelStatusHandle_

private

Definition at line 68 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

configParameters_

ecal::rechit::ConfigurationParameters EcalRecHitProducerGPU::configParameters_

private

Definition at line 63 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and EcalRecHitProducerGPU().

cudaState_

cms::cuda::ContextState EcalRecHitProducerGPU::cudaState_

private

Definition at line 56 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and produce().

eventOutputDataGPU_

ecal::rechit::EventOutputDataGPU EcalRecHitProducerGPU::eventOutputDataGPU_

private

Definition at line 54 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and produce().

expanded_flagbit_v_DB_reco_flags_

std::vector<uint32_t> EcalRecHitProducerGPU::expanded_flagbit_v_DB_reco_flags_

private

Definition at line 80 of file EcalRecHitProducerGPU.cc.

expanded_Sizes_v_DB_reco_flags_

std::vector<uint32_t> EcalRecHitProducerGPU::expanded_Sizes_v_DB_reco_flags_

private

Definition at line 79 of file EcalRecHitProducerGPU.cc.

expanded_v_DB_reco_flags_

std::vector<int> EcalRecHitProducerGPU::expanded_v_DB_reco_flags_

private

Definition at line 78 of file EcalRecHitProducerGPU.cc.

flagmask_

uint32_t EcalRecHitProducerGPU::flagmask_

private

Definition at line 82 of file EcalRecHitProducerGPU.cc.

Referenced by EcalRecHitProducerGPU().

IntercalibConstantsHandle_

edm::ESHandle<EcalIntercalibConstantsGPU> EcalRecHitProducerGPU::IntercalibConstantsHandle_

private

Definition at line 67 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

LaserAlphasHandle_

edm::ESHandle<EcalLaserAlphasGPU> EcalRecHitProducerGPU::LaserAlphasHandle_

private

Definition at line 72 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

LaserAPDPNRatiosHandle_

edm::ESHandle<EcalLaserAPDPNRatiosGPU> EcalRecHitProducerGPU::LaserAPDPNRatiosHandle_

private

Definition at line 70 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

LaserAPDPNRatiosRefHandle_

edm::ESHandle<EcalLaserAPDPNRatiosRefGPU> EcalRecHitProducerGPU::LaserAPDPNRatiosRefHandle_

private

Definition at line 71 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

LinearCorrectionsHandle_

edm::ESHandle<EcalLinearCorrectionsGPU> EcalRecHitProducerGPU::LinearCorrectionsHandle_

private

Definition at line 73 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

neb_

uint32_t EcalRecHitProducerGPU::neb_

private

Definition at line 46 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and produce().

nee_

uint32_t EcalRecHitProducerGPU::nee_

private

Definition at line 46 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and produce().

recHitParametersHandle_

edm::ESHandle<EcalRecHitParametersGPU> EcalRecHitProducerGPU::recHitParametersHandle_

private

Definition at line 74 of file EcalRecHitProducerGPU.cc.

Referenced by acquire().

recHitsTokenEB_

edm::EDPutTokenT<OutputProduct> EcalRecHitProducerGPU::recHitsTokenEB_

private

Definition at line 60 of file EcalRecHitProducerGPU.cc.

Referenced by EcalRecHitProducerGPU(), and produce().

recHitsTokenEE_

edm::EDPutTokenT<OutputProduct> EcalRecHitProducerGPU::recHitsTokenEE_

private

Definition at line 60 of file EcalRecHitProducerGPU.cc.

Referenced by EcalRecHitProducerGPU(), and produce().

uncalibRecHitsInEBToken_

edm::EDGetTokenT<InputProduct> EcalRecHitProducerGPU::uncalibRecHitsInEBToken_

private

Definition at line 50 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and EcalRecHitProducerGPU().

uncalibRecHitsInEEToken_

edm::EDGetTokenT<InputProduct> EcalRecHitProducerGPU::uncalibRecHitsInEEToken_

private

Definition at line 51 of file EcalRecHitProducerGPU.cc.

Referenced by acquire(), and EcalRecHitProducerGPU().