EcalCPUDigisProducer Class Reference

Inheritance diagram for EcalCPUDigisProducer:

Public Member Functions
	EcalCPUDigisProducer (edm::ParameterSet const &ps)
	~EcalCPUDigisProducer () 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::DigisCollection< 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
std::vector< uint16_t, cms::cuda::HostAllocator< uint16_t > >	dataebtmp
std::vector< uint16_t, cms::cuda::HostAllocator< uint16_t > >	dataeetmp
edm::EDGetTokenT< InputProduct >	digisInEBToken_
edm::EDGetTokenT< InputProduct >	digisInEEToken_
edm::EDPutTokenT< EBDigiCollection >	digisOutEBToken_
edm::EDPutTokenT< EEDigiCollection >	digisOutEEToken_
edm::EDPutTokenT< EBDetIdCollection >	ebIntegrityChIdErrorsToken_
edm::EDPutTokenT< EBDetIdCollection >	ebIntegrityGainErrorsToken_
edm::EDPutTokenT< EBDetIdCollection >	ebIntegrityGainSwitchErrorsToken_
edm::EDPutTokenT< EBSrFlagCollection >	ebSrFlagToken_
edm::EDPutTokenT< EEDetIdCollection >	eeIntegrityChIdErrorsToken_
edm::EDPutTokenT< EEDetIdCollection >	eeIntegrityGainErrorsToken_
edm::EDPutTokenT< EEDetIdCollection >	eeIntegrityGainSwitchErrorsToken_
edm::EDPutTokenT< EESrFlagCollection >	eeSrFlagToken_
std::vector< uint32_t, cms::cuda::HostAllocator< uint32_t > >	idsebtmp
std::vector< uint32_t, cms::cuda::HostAllocator< uint32_t > >	idseetmp
edm::EDPutTokenT< EcalElectronicsIdCollection >	integrityBlockSizeErrorsToken_
edm::EDPutTokenT< EcalElectronicsIdCollection >	integrityTTIdErrorsToken_
bool	produceDummyIntegrityCollections_

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 23 of file EcalCPUDigisProducer.cc.

Member Typedef Documentation

InputProduct

using EcalCPUDigisProducer::InputProduct = cms::cuda::Product<ecal::DigisCollection<calo::common::DevStoragePolicy> >

private

Definition at line 35 of file EcalCPUDigisProducer.cc.

Constructor & Destructor Documentation

EcalCPUDigisProducer()

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

explicit

Definition at line 83 of file EcalCPUDigisProducer.cc.

    :  // input digi collections in GPU-friendly format
      digisInEBToken_{consumes<InputProduct>(ps.getParameter<edm::InputTag>("digisInLabelEB"))},
      digisInEEToken_{consumes<InputProduct>(ps.getParameter<edm::InputTag>("digisInLabelEE"))},
      // output digi collections in legacy format
      digisOutEBToken_{produces<EBDigiCollection>(ps.getParameter<std::string>("digisOutLabelEB"))},
      digisOutEEToken_{produces<EEDigiCollection>(ps.getParameter<std::string>("digisOutLabelEE"))},
      // whether to produce dummy integrity collections
      produceDummyIntegrityCollections_{ps.getParameter<bool>("produceDummyIntegrityCollections")},
      // dummy SRP collections
      ebSrFlagToken_{produceDummyIntegrityCollections_ ? produces<EBSrFlagCollection>()
                                                       : edm::EDPutTokenT<EBSrFlagCollection>{}},
      eeSrFlagToken_{produceDummyIntegrityCollections_ ? produces<EESrFlagCollection>()
                                                       : edm::EDPutTokenT<EESrFlagCollection>{}},
      // dummy integrity for xtal data
      ebIntegrityGainErrorsToken_{produceDummyIntegrityCollections_
                                      ? produces<EBDetIdCollection>("EcalIntegrityGainErrors")
                                      : edm::EDPutTokenT<EBDetIdCollection>{}},
      ebIntegrityGainSwitchErrorsToken_{produceDummyIntegrityCollections_
                                            ? produces<EBDetIdCollection>("EcalIntegrityGainSwitchErrors")
                                            : edm::EDPutTokenT<EBDetIdCollection>{}},
      ebIntegrityChIdErrorsToken_{produceDummyIntegrityCollections_
                                      ? produces<EBDetIdCollection>("EcalIntegrityChIdErrors")
                                      : edm::EDPutTokenT<EBDetIdCollection>{}},
      // dummy integrity for xtal data - EE specific (to be rivisited towards EB+EE common collection)
      eeIntegrityGainErrorsToken_{produceDummyIntegrityCollections_
                                      ? produces<EEDetIdCollection>("EcalIntegrityGainErrors")
                                      : edm::EDPutTokenT<EEDetIdCollection>{}},
      eeIntegrityGainSwitchErrorsToken_{produceDummyIntegrityCollections_
                                            ? produces<EEDetIdCollection>("EcalIntegrityGainSwitchErrors")
                                            : edm::EDPutTokenT<EEDetIdCollection>{}},
      eeIntegrityChIdErrorsToken_{produceDummyIntegrityCollections_
                                      ? produces<EEDetIdCollection>("EcalIntegrityChIdErrors")
                                      : edm::EDPutTokenT<EEDetIdCollection>{}},
      // dummy integrity errors
      integrityTTIdErrorsToken_{produceDummyIntegrityCollections_
                                    ? produces<EcalElectronicsIdCollection>("EcalIntegrityTTIdErrors")
                                    : edm::EDPutTokenT<EcalElectronicsIdCollection>{}},
      integrityBlockSizeErrorsToken_{produceDummyIntegrityCollections_
                                         ? produces<EcalElectronicsIdCollection>("EcalIntegrityBlockSizeErrors")
                                         : edm::EDPutTokenT<EcalElectronicsIdCollection>{}} {}

References edm::ParameterSet::getParameter().

~EcalCPUDigisProducer()

EcalCPUDigisProducer::~EcalCPUDigisProducer ( )

override

Definition at line 125 of file EcalCPUDigisProducer.cc.

{}

Member Function Documentation

acquire()

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

overrideprivate

Definition at line 127 of file EcalCPUDigisProducer.cc.

                                                                             {
  // retrieve data/ctx
  auto const& ebdigisProduct = event.get(digisInEBToken_);
  auto const& eedigisProduct = event.get(digisInEEToken_);
  cms::cuda::ScopedContextAcquire ctx{ebdigisProduct, std::move(taskHolder)};
  auto const& ebdigis = ctx.get(ebdigisProduct);
  auto const& eedigis = ctx.get(eedigisProduct);
 
  // resize tmp buffers
  dataebtmp.resize(ebdigis.size * EcalDataFrame::MAXSAMPLES);
  dataeetmp.resize(eedigis.size * EcalDataFrame::MAXSAMPLES);
  idsebtmp.resize(ebdigis.size);
  idseetmp.resize(eedigis.size);
 
  // enqeue transfers
  cudaCheck(cudaMemcpyAsync(
      dataebtmp.data(), ebdigis.data.get(), dataebtmp.size() * sizeof(uint16_t), cudaMemcpyDeviceToHost, ctx.stream()));
  cudaCheck(cudaMemcpyAsync(
      dataeetmp.data(), eedigis.data.get(), dataeetmp.size() * sizeof(uint16_t), cudaMemcpyDeviceToHost, ctx.stream()));
  cudaCheck(cudaMemcpyAsync(
      idsebtmp.data(), ebdigis.ids.get(), idsebtmp.size() * sizeof(uint32_t), cudaMemcpyDeviceToHost, ctx.stream()));
  cudaCheck(cudaMemcpyAsync(
      idseetmp.data(), eedigis.ids.get(), idseetmp.size() * sizeof(uint32_t), cudaMemcpyDeviceToHost, ctx.stream()));
}

References cudaCheck, dataebtmp, dataeetmp, digisInEBToken_, digisInEEToken_, idsebtmp, idseetmp, EcalDataFrame::MAXSAMPLES, and eostools::move().

fillDescriptions()

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

static

Definition at line 69 of file EcalCPUDigisProducer.cc.

                                                                                  {
  edm::ParameterSetDescription desc;
 
  desc.add<edm::InputTag>("digisInLabelEB", edm::InputTag{"ecalRawToDigiGPU", "ebDigis"});
  desc.add<edm::InputTag>("digisInLabelEE", edm::InputTag{"ecalRawToDigiGPU", "eeDigis"});
  desc.add<std::string>("digisOutLabelEB", "ebDigis");
  desc.add<std::string>("digisOutLabelEE", "eeDigis");
 
  desc.add<bool>("produceDummyIntegrityCollections", false);
 
  std::string label = "ecalCPUDigisProducer";
  confDesc.add(label, desc);
}

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

produce()

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

overrideprivate

Definition at line 154 of file EcalCPUDigisProducer.cc.

                                                                              {
  // output collections
  auto digisEB = std::make_unique<EBDigiCollection>();
  auto digisEE = std::make_unique<EEDigiCollection>();
  digisEB->resize(idsebtmp.size());
  digisEE->resize(idseetmp.size());
 
  // cast constness away
  // use pointers to buffers instead of move operator= semantics
  // cause we have different allocators in there...
  auto* dataEB = const_cast<uint16_t*>(digisEB->data().data());
  auto* dataEE = const_cast<uint16_t*>(digisEE->data().data());
  auto* idsEB = const_cast<uint32_t*>(digisEB->ids().data());
  auto* idsEE = const_cast<uint32_t*>(digisEE->ids().data());
 
  // copy data
  std::memcpy(dataEB, dataebtmp.data(), dataebtmp.size() * sizeof(uint16_t));
  std::memcpy(dataEE, dataeetmp.data(), dataeetmp.size() * sizeof(uint16_t));
  std::memcpy(idsEB, idsebtmp.data(), idsebtmp.size() * sizeof(uint32_t));
  std::memcpy(idsEE, idseetmp.data(), idseetmp.size() * sizeof(uint32_t));
 
  event.put(digisOutEBToken_, std::move(digisEB));
  event.put(digisOutEEToken_, std::move(digisEE));
 
  if (produceDummyIntegrityCollections_) {
    // dummy SRP collections
    event.emplace(ebSrFlagToken_);
    event.emplace(eeSrFlagToken_);
    // dummy integrity for xtal data
    event.emplace(ebIntegrityGainErrorsToken_);
    event.emplace(ebIntegrityGainSwitchErrorsToken_);
    event.emplace(ebIntegrityChIdErrorsToken_);
    // dummy integrity for xtal data - EE specific (to be rivisited towards EB+EE common collection)
    event.emplace(eeIntegrityGainErrorsToken_);
    event.emplace(eeIntegrityGainSwitchErrorsToken_);
    event.emplace(eeIntegrityChIdErrorsToken_);
    // dummy integrity errors
    event.emplace(integrityTTIdErrorsToken_);
    event.emplace(integrityBlockSizeErrorsToken_);
  }
}

References dataebtmp, dataeetmp, digisOutEBToken_, digisOutEEToken_, ebIntegrityChIdErrorsToken_, ebIntegrityGainErrorsToken_, ebIntegrityGainSwitchErrorsToken_, ebSrFlagToken_, eeIntegrityChIdErrorsToken_, eeIntegrityGainErrorsToken_, eeIntegrityGainSwitchErrorsToken_, eeSrFlagToken_, idsebtmp, idseetmp, integrityBlockSizeErrorsToken_, integrityTTIdErrorsToken_, eostools::move(), and produceDummyIntegrityCollections_.

Member Data Documentation

dataebtmp

std::vector<uint16_t, cms::cuda::HostAllocator<uint16_t> > EcalCPUDigisProducer::dataebtmp

private

Definition at line 66 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

dataeetmp

std::vector<uint16_t, cms::cuda::HostAllocator<uint16_t> > EcalCPUDigisProducer::dataeetmp

private

Definition at line 66 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

digisInEBToken_

edm::EDGetTokenT<InputProduct> EcalCPUDigisProducer::digisInEBToken_

private

Definition at line 36 of file EcalCPUDigisProducer.cc.

Referenced by acquire().

digisInEEToken_

edm::EDGetTokenT<InputProduct> EcalCPUDigisProducer::digisInEEToken_

private

Definition at line 37 of file EcalCPUDigisProducer.cc.

Referenced by acquire().

digisOutEBToken_

edm::EDPutTokenT<EBDigiCollection> EcalCPUDigisProducer::digisOutEBToken_

private

Definition at line 40 of file EcalCPUDigisProducer.cc.

Referenced by produce().

digisOutEEToken_

edm::EDPutTokenT<EEDigiCollection> EcalCPUDigisProducer::digisOutEEToken_

private

Definition at line 41 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityChIdErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityChIdErrorsToken_

private

Definition at line 53 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityGainErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityGainErrorsToken_

private

Definition at line 51 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityGainSwitchErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityGainSwitchErrorsToken_

private

Definition at line 52 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebSrFlagToken_

edm::EDPutTokenT<EBSrFlagCollection> EcalCPUDigisProducer::ebSrFlagToken_

private

Definition at line 47 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityChIdErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityChIdErrorsToken_

private

Definition at line 58 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityGainErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityGainErrorsToken_

private

Definition at line 56 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityGainSwitchErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityGainSwitchErrorsToken_

private

Definition at line 57 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeSrFlagToken_

edm::EDPutTokenT<EESrFlagCollection> EcalCPUDigisProducer::eeSrFlagToken_

private

Definition at line 48 of file EcalCPUDigisProducer.cc.

Referenced by produce().

idsebtmp

std::vector<uint32_t, cms::cuda::HostAllocator<uint32_t> > EcalCPUDigisProducer::idsebtmp

private

Definition at line 65 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

idseetmp

std::vector<uint32_t, cms::cuda::HostAllocator<uint32_t> > EcalCPUDigisProducer::idseetmp

private

Definition at line 65 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

integrityBlockSizeErrorsToken_

edm::EDPutTokenT<EcalElectronicsIdCollection> EcalCPUDigisProducer::integrityBlockSizeErrorsToken_

private

Definition at line 62 of file EcalCPUDigisProducer.cc.

Referenced by produce().

integrityTTIdErrorsToken_

edm::EDPutTokenT<EcalElectronicsIdCollection> EcalCPUDigisProducer::integrityTTIdErrorsToken_

private

Definition at line 61 of file EcalCPUDigisProducer.cc.

Referenced by produce().

produceDummyIntegrityCollections_

bool EcalCPUDigisProducer::produceDummyIntegrityCollections_

private

Definition at line 44 of file EcalCPUDigisProducer.cc.

Referenced by produce().