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
const bool	containsTimingInformation_
const bool	isPhase2_
OutputProduct	recHitsEB_
OutputProduct	recHitsEE_
const edm::EDGetTokenT< InputProduct >	recHitsInEBToken_
const edm::EDGetTokenT< InputProduct >	recHitsInEEToken_
const edm::EDPutTokenT< OutputProduct >	recHitsOutEBToken_
const 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 20 of file EcalCPUUncalibRecHitProducer.cc.

Member Typedef Documentation

InputProduct

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

private

Definition at line 32 of file EcalCPUUncalibRecHitProducer.cc.

OutputProduct

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

private

Definition at line 34 of file EcalCPUUncalibRecHitProducer.cc.

Constructor & Destructor Documentation

EcalCPUUncalibRecHitProducer()

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

explicit

Definition at line 57 of file EcalCPUUncalibRecHitProducer.cc.

References edm::ParameterSet::getParameter().

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

~EcalCPUUncalibRecHitProducer()

EcalCPUUncalibRecHitProducer::~EcalCPUUncalibRecHitProducer ( )

override

Definition at line 67 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 69 of file EcalCPUUncalibRecHitProducer.cc.

References ecal::UncalibratedRecHit< StoragePolicy >::amplitude, ecal::UncalibratedRecHit< StoragePolicy >::amplitudeError, ecal::UncalibratedRecHit< StoragePolicy >::amplitudesAll, ecal::UncalibratedRecHit< StoragePolicy >::chi2, containsTimingInformation_, cudaCheck, mps_fire::dest, ecal::UncalibratedRecHit< StoragePolicy >::did, ecal::UncalibratedRecHit< StoragePolicy >::flags, isPhase2_, 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_);
  cms::cuda::ScopedContextAcquire ctx{ebRecHitsProduct, std::move(taskHolder)};
  auto const& ebRecHits = ctx.get(ebRecHitsProduct);

  // resize the output buffers
  recHitsEB_.resize(ebRecHits.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(recHitsEB_.amplitudesAll, ebRecHits.amplitudesAll.get());
  lambdaToTransfer(recHitsEB_.amplitude, ebRecHits.amplitude.get());
  lambdaToTransfer(recHitsEB_.chi2, ebRecHits.chi2.get());
  lambdaToTransfer(recHitsEB_.pedestal, ebRecHits.pedestal.get());
  lambdaToTransfer(recHitsEB_.flags, ebRecHits.flags.get());
  if (containsTimingInformation_) {
    lambdaToTransfer(recHitsEB_.jitter, ebRecHits.jitter.get());
    lambdaToTransfer(recHitsEB_.jitterError, ebRecHits.jitterError.get());
  }
  if (isPhase2_) {
    lambdaToTransfer(recHitsEB_.amplitudeError, ebRecHits.amplitudeError.get());

  } else {
    auto const& eeRecHitsProduct = event.get(recHitsInEEToken_);
    auto const& eeRecHits = ctx.get(eeRecHitsProduct);
    recHitsEE_.resize(eeRecHits.size);
    lambdaToTransfer(recHitsEE_.did, eeRecHits.did.get());
    lambdaToTransfer(recHitsEE_.amplitudesAll, eeRecHits.amplitudesAll.get());
    lambdaToTransfer(recHitsEE_.amplitude, eeRecHits.amplitude.get());
    lambdaToTransfer(recHitsEE_.chi2, eeRecHits.chi2.get());
    lambdaToTransfer(recHitsEE_.pedestal, eeRecHits.pedestal.get());
    lambdaToTransfer(recHitsEE_.flags, eeRecHits.flags.get());
    if (containsTimingInformation_) {
      lambdaToTransfer(recHitsEE_.jitter, eeRecHits.jitter.get());
      lambdaToTransfer(recHitsEE_.jitterError, eeRecHits.jitterError.get());
    }
  }
}

fillDescriptions()

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

static

Definition at line 41 of file EcalCPUUncalibRecHitProducer.cc.

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

                                                                                          {
  edm::ParameterSetDescription desc;

  desc.add<edm::InputTag>("recHitsInLabelEB", edm::InputTag{"ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEB"});
  desc.add<std::string>("recHitsOutLabelEB", "EcalUncalibRecHitsEB");
  desc.add<bool>("containsTimingInformation", false);
  desc.ifValue(
      edm::ParameterDescription<bool>("isPhase2", false, true),
      false >> (edm::ParameterDescription<edm::InputTag>(
                    "recHitsInLabelEE", edm::InputTag{"ecalUncalibRecHitProducerGPU", "EcalUncalibRecHitsEE"}, true) and
                edm::ParameterDescription<std::string>("recHitsOutLabelEE", "EcalUncalibRecHitsEE", true)) or
          true >> edm::EmptyGroupDescription());

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

produce()

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

overrideprivate

Definition at line 119 of file EcalCPUUncalibRecHitProducer.cc.

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

                                                                                      {
  // tmp vectors
  auto recHitsOutEB = std::make_unique<OutputProduct>(std::move(recHitsEB_));
  // put into event
  event.put(recHitsOutEBToken_, std::move(recHitsOutEB));

  if (!isPhase2_) {
    auto recHitsOutEE = std::make_unique<OutputProduct>(std::move(recHitsEE_));
    event.put(recHitsOutEEToken_, std::move(recHitsOutEE));
  }
}

Member Data Documentation

containsTimingInformation_

const bool EcalCPUUncalibRecHitProducer::containsTimingInformation_

private

Definition at line 38 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

isPhase2_

const bool EcalCPUUncalibRecHitProducer::isPhase2_

private

Definition at line 31 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire(), and produce().

recHitsEB_

OutputProduct EcalCPUUncalibRecHitProducer::recHitsEB_

private

Definition at line 37 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire(), and produce().

recHitsEE_

OutputProduct EcalCPUUncalibRecHitProducer::recHitsEE_

private

Definition at line 37 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire(), and produce().

recHitsInEBToken_

const edm::EDGetTokenT<InputProduct> EcalCPUUncalibRecHitProducer::recHitsInEBToken_

private

Definition at line 33 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

recHitsInEEToken_

const edm::EDGetTokenT<InputProduct> EcalCPUUncalibRecHitProducer::recHitsInEEToken_

private

Definition at line 33 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by acquire().

recHitsOutEBToken_

const edm::EDPutTokenT<OutputProduct> EcalCPUUncalibRecHitProducer::recHitsOutEBToken_

private

Definition at line 35 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by produce().

recHitsOutEEToken_

const edm::EDPutTokenT<OutputProduct> EcalCPUUncalibRecHitProducer::recHitsOutEEToken_

private

Definition at line 35 of file EcalCPUUncalibRecHitProducer.cc.

Referenced by produce().