EcalCPUUncalibRecHitProducer Class Reference

Inheritance diagram for EcalCPUUncalibRecHitProducer:

Public Member Functions
	EcalCPUUncalibRecHitProducer (edm::ParameterSet const &ps)
	~EcalCPUUncalibRecHitProducer () override
Public Member Functions inherited from edm::stream::EDProducer< edm::ExternalWork >
	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

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

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

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

Private Attributes
bool	containsTimingInformation_
OutputProduct	recHitsEB_
OutputProduct	recHitsEE_
edm::EDGetTokenT< InputProduct >	recHitsInEBToken_
edm::EDGetTokenT< InputProduct >	recHitsInEEToken_
edm::EDPutTokenT< OutputProduct >	recHitsOutEBToken_
edm::EDPutTokenT< OutputProduct >	recHitsOutEEToken_

Additional Inherited Members
Public Types inherited from edm::stream::EDProducer< edm::ExternalWork >
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

Detailed Description

Definition at line 19 of file EcalCPUUncalibRecHitProducer.cc.

Member Typedef Documentation

InputProduct

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

private

Definition at line 30 of file EcalCPUUncalibRecHitProducer.cc.

OutputProduct

using EcalCPUUncalibRecHitProducer::OutputProduct = ecal::UncalibratedRecHit<calo::common::VecStoragePolicy<calo::common::CUDAHostAllocatorAlias> >

private

Definition at line 32 of file EcalCPUUncalibRecHitProducer.cc.

Constructor & Destructor Documentation

EcalCPUUncalibRecHitProducer()

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

explicit

Definition at line 51 of file EcalCPUUncalibRecHitProducer.cc.

References edm::ParameterSet::getParameter().

    : recHitsInEBToken_{consumes<InputProduct>(ps.getParameter<edm::InputTag>("recHitsInLabelEB"))},
      recHitsInEEToken_{consumes<InputProduct>(ps.getParameter<edm::InputTag>("recHitsInLabelEE"))},
      recHitsOutEBToken_{produces<OutputProduct>(ps.getParameter<std::string>("recHitsOutLabelEB"))},
      recHitsOutEEToken_{produces<OutputProduct>(ps.getParameter<std::string>("recHitsOutLabelEE"))},
      containsTimingInformation_{ps.getParameter<bool>("containsTimingInformation")} {}

~EcalCPUUncalibRecHitProducer()

EcalCPUUncalibRecHitProducer::~EcalCPUUncalibRecHitProducer ( )

override

Definition at line 58 of file EcalCPUUncalibRecHitProducer.cc.

{}

Member Function Documentation

acquire()

void EcalCPUUncalibRecHitProducer::acquire ( edm::Event const &  event, edm::EventSetup const &  setup, edm::WaitingTaskWithArenaHolder  taskHolder  )

overrideprivate

Definition at line 60 of file EcalCPUUncalibRecHitProducer.cc.

References ecal::UncalibratedRecHit< StoragePolicy >::amplitude, ecal::UncalibratedRecHit< StoragePolicy >::amplitudesAll, ecal::UncalibratedRecHit< StoragePolicy >::chi2, containsTimingInformation_, cudaCheck, mps_fire::dest, ecal::UncalibratedRecHit< StoragePolicy >::did, ecal::UncalibratedRecHit< StoragePolicy >::flags, ecal::UncalibratedRecHit< StoragePolicy >::jitter, ecal::UncalibratedRecHit< StoragePolicy >::jitterError, eostools::move(), ecal::UncalibratedRecHit< StoragePolicy >::pedestal, recHitsEB_, recHitsEE_, recHitsInEBToken_, recHitsInEEToken_, ecal::UncalibratedRecHit< StoragePolicy >::resize(), TrackRefitter_38T_cff::src, and relativeConstraints::value.

                                                                                     {
  // retrieve data/ctx
  auto const& ebRecHitsProduct = event.get(recHitsInEBToken_);
  auto const& eeRecHitsProduct = event.get(recHitsInEEToken_);
  cms::cuda::ScopedContextAcquire ctx{ebRecHitsProduct, std::move(taskHolder)};
  auto const& ebRecHits = ctx.get(ebRecHitsProduct);
  auto const& eeRecHits = ctx.get(eeRecHitsProduct);

  // resize the output buffers
  recHitsEB_.resize(ebRecHits.size);
  recHitsEE_.resize(eeRecHits.size);

  auto lambdaToTransfer = [&ctx](auto& dest, auto* src) {
    using vector_type = typename std::remove_reference<decltype(dest)>::type;
    using type = typename vector_type::value_type;
    using src_type = typename std::remove_pointer<decltype(src)>::type;
    static_assert(std::is_same<src_type, type>::value && "dst and src data types do not match");
    cudaCheck(cudaMemcpyAsync(dest.data(), src, dest.size() * sizeof(type), cudaMemcpyDeviceToHost, ctx.stream()));
  };

  // enqeue transfers
  lambdaToTransfer(recHitsEB_.did, ebRecHits.did.get());
  lambdaToTransfer(recHitsEE_.did, eeRecHits.did.get());

  lambdaToTransfer(recHitsEB_.amplitudesAll, ebRecHits.amplitudesAll.get());
  lambdaToTransfer(recHitsEE_.amplitudesAll, eeRecHits.amplitudesAll.get());

  lambdaToTransfer(recHitsEB_.amplitude, ebRecHits.amplitude.get());
  lambdaToTransfer(recHitsEE_.amplitude, eeRecHits.amplitude.get());

  lambdaToTransfer(recHitsEB_.chi2, ebRecHits.chi2.get());
  lambdaToTransfer(recHitsEE_.chi2, eeRecHits.chi2.get());

  lambdaToTransfer(recHitsEB_.pedestal, ebRecHits.pedestal.get());
  lambdaToTransfer(recHitsEE_.pedestal, eeRecHits.pedestal.get());

  lambdaToTransfer(recHitsEB_.flags, ebRecHits.flags.get());
  lambdaToTransfer(recHitsEE_.flags, eeRecHits.flags.get());

  if (containsTimingInformation_) {
    lambdaToTransfer(recHitsEB_.jitter, ebRecHits.jitter.get());
    lambdaToTransfer(recHitsEE_.jitter, eeRecHits.jitter.get());

    lambdaToTransfer(recHitsEB_.jitterError, ebRecHits.jitterError.get());
    lambdaToTransfer(recHitsEE_.jitterError, eeRecHits.jitterError.get());
  }
}

fillDescriptions()

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

static

Definition at line 39 of file EcalCPUUncalibRecHitProducer.cc.

References edm::ConfigurationDescriptions::add(), submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                          {
  edm::ParameterSetDescription desc;

  desc.add<edm::InputTag>("recHitsInLabelEB", edm::InputTag{"ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEB"});
  desc.add<edm::InputTag>("recHitsInLabelEE", edm::InputTag{"ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEE"});
  desc.add<std::string>("recHitsOutLabelEB", "EcalUncalibRecHitsEB");
  desc.add<std::string>("recHitsOutLabelEE", "EcalUncalibRecHitsEE");
  desc.add<bool>("containsTimingInformation", false);

  confDesc.add("ecalCPUUncalibRecHitProducer", desc);
}

produce()

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

overrideprivate

Definition at line 110 of file EcalCPUUncalibRecHitProducer.cc.

References eostools::move(), recHitsEB_, recHitsEE_, recHitsOutEBToken_, and recHitsOutEEToken_.

                                                                                      {
  // tmp vectors
  auto recHitsOutEB = std::make_unique<OutputProduct>(std::move(recHitsEB_));
  auto recHitsOutEE = std::make_unique<OutputProduct>(std::move(recHitsEE_));

  // put into event
  event.put(recHitsOutEBToken_, std::move(recHitsOutEB));
  event.put(recHitsOutEEToken_, std::move(recHitsOutEE));
}

Member Data Documentation

containsTimingInformation_

bool EcalCPUUncalibRecHitProducer::containsTimingInformation_

private

Definition at line 36 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

recHitsEB_

OutputProduct EcalCPUUncalibRecHitProducer::recHitsEB_

private

Definition at line 35 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire(), and produce().

recHitsEE_

OutputProduct EcalCPUUncalibRecHitProducer::recHitsEE_

private

Definition at line 35 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire(), and produce().

recHitsInEBToken_

edm::EDGetTokenT<InputProduct> EcalCPUUncalibRecHitProducer::recHitsInEBToken_

private

Definition at line 31 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

recHitsInEEToken_

edm::EDGetTokenT<InputProduct> EcalCPUUncalibRecHitProducer::recHitsInEEToken_

private

Definition at line 31 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

recHitsOutEBToken_

edm::EDPutTokenT<OutputProduct> EcalCPUUncalibRecHitProducer::recHitsOutEBToken_

private

Definition at line 33 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by produce().

recHitsOutEEToken_

edm::EDPutTokenT<OutputProduct> EcalCPUUncalibRecHitProducer::recHitsOutEEToken_

private

Definition at line 33 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by produce().