EcalCPUDigisProducer Class Reference

Inheritance diagram for EcalCPUDigisProducer:

Public Member Functions
	EcalCPUDigisProducer (edm::ParameterSet const &ps)
	~EcalCPUDigisProducer () override=default
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::DigisCollection< calo::common::DevStoragePolicy > >

Private Member Functions
void	acquire (edm::Event const &, edm::EventSetup const &, edm::WaitingTaskWithArenaHolder) override
template<typename ProductType , typename... ARGS>
edm::EDPutTokenT< ProductType >	dummyProduces (ARGS &&... args)
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< EcalPSInputDigiCollection >	ecalPseudoStripInputsToken_
edm::EDPutTokenT< EcalTrigPrimDigiCollection >	ecalTriggerPrimitivesToken_
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_
edm::EDPutTokenT< EcalElectronicsIdCollection >	integrityZSXtalIdErrorsToken_
edm::EDPutTokenT< EcalPnDiodeDigiCollection >	pnDiodeDigisToken_
bool	produceDummyIntegrityCollections_

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

Member Typedef Documentation

InputProduct

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

private

Definition at line 41 of file EcalCPUDigisProducer.cc.

Constructor & Destructor Documentation

EcalCPUDigisProducer()

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

explicit

Definition at line 96 of file EcalCPUDigisProducer.cc.

References edm::ParameterSet::getParameter().

    :  // 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 collections
      ebSrFlagToken_{dummyProduces<EBSrFlagCollection>()},
      eeSrFlagToken_{dummyProduces<EESrFlagCollection>()},

      // dummy integrity for xtal data
      ebIntegrityGainErrorsToken_{dummyProduces<EBDetIdCollection>("EcalIntegrityGainErrors")},
      ebIntegrityGainSwitchErrorsToken_{dummyProduces<EBDetIdCollection>("EcalIntegrityGainSwitchErrors")},
      ebIntegrityChIdErrorsToken_{dummyProduces<EBDetIdCollection>("EcalIntegrityChIdErrors")},

      // dummy integrity for xtal data - EE specific (to be rivisited towards EB+EE common collection)
      eeIntegrityGainErrorsToken_{dummyProduces<EEDetIdCollection>("EcalIntegrityGainErrors")},
      eeIntegrityGainSwitchErrorsToken_{dummyProduces<EEDetIdCollection>("EcalIntegrityGainSwitchErrors")},
      eeIntegrityChIdErrorsToken_{dummyProduces<EEDetIdCollection>("EcalIntegrityChIdErrors")},

      // dummy integrity errors
      integrityTTIdErrorsToken_{dummyProduces<EcalElectronicsIdCollection>("EcalIntegrityTTIdErrors")},
      integrityZSXtalIdErrorsToken_{dummyProduces<EcalElectronicsIdCollection>("EcalIntegrityZSXtalIdErrors")},
      integrityBlockSizeErrorsToken_{dummyProduces<EcalElectronicsIdCollection>("EcalIntegrityBlockSizeErrors")},

      //
      pnDiodeDigisToken_{dummyProduces<EcalPnDiodeDigiCollection>()},

      // dummy TCC collections
      ecalTriggerPrimitivesToken_{dummyProduces<EcalTrigPrimDigiCollection>("EcalTriggerPrimitives")},
      ecalPseudoStripInputsToken_{dummyProduces<EcalPSInputDigiCollection>("EcalPseudoStripInputs")}
// constructor body
{}

~EcalCPUDigisProducer()

EcalCPUDigisProducer::~EcalCPUDigisProducer ( )

overridedefault

Member Function Documentation

acquire()

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

overrideprivate

Definition at line 136 of file EcalCPUDigisProducer.cc.

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

                                                                             {
  // 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()));
}

dummyProduces()

template<typename ProductType , typename... ARGS>

edm::EDPutTokenT<ProductType> EcalCPUDigisProducer::dummyProduces ( ARGS &&...  args )

inlineprivate

Definition at line 34 of file EcalCPUDigisProducer.cc.

References writedatasetfile::args, and produceDummyIntegrityCollections_.

                                                            {
    return (produceDummyIntegrityCollections_) ? produces<ProductType>(std::forward<ARGS>(args)...)
                                               : edm::EDPutTokenT<ProductType>{};
  }

fillDescriptions()

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

static

Definition at line 82 of file EcalCPUDigisProducer.cc.

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

                                                                                  {
  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);
}

produce()

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

overrideprivate

Definition at line 163 of file EcalCPUDigisProducer.cc.

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

                                                                              {
  // 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));

  digisEB->sort();
  digisEE->sort();

  event.put(digisOutEBToken_, std::move(digisEB));
  event.put(digisOutEEToken_, std::move(digisEE));

  if (produceDummyIntegrityCollections_) {
    // dummy 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(integrityZSXtalIdErrorsToken_);
    event.emplace(integrityBlockSizeErrorsToken_);
    //
    event.emplace(pnDiodeDigisToken_);
    // dummy TCC collections
    event.emplace(ecalTriggerPrimitivesToken_);
    event.emplace(ecalPseudoStripInputsToken_);
  }
}

Member Data Documentation

dataebtmp

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

private

Definition at line 79 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 79 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

digisInEBToken_

edm::EDGetTokenT<InputProduct> EcalCPUDigisProducer::digisInEBToken_

private

Definition at line 42 of file EcalCPUDigisProducer.cc.

Referenced by acquire().

digisInEEToken_

edm::EDGetTokenT<InputProduct> EcalCPUDigisProducer::digisInEEToken_

private

Definition at line 43 of file EcalCPUDigisProducer.cc.

Referenced by acquire().

digisOutEBToken_

edm::EDPutTokenT<EBDigiCollection> EcalCPUDigisProducer::digisOutEBToken_

private

Definition at line 46 of file EcalCPUDigisProducer.cc.

Referenced by produce().

digisOutEEToken_

edm::EDPutTokenT<EEDigiCollection> EcalCPUDigisProducer::digisOutEEToken_

private

Definition at line 47 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityChIdErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityChIdErrorsToken_

private

Definition at line 59 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityGainErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityGainErrorsToken_

private

Definition at line 57 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebIntegrityGainSwitchErrorsToken_

edm::EDPutTokenT<EBDetIdCollection> EcalCPUDigisProducer::ebIntegrityGainSwitchErrorsToken_

private

Definition at line 58 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ebSrFlagToken_

edm::EDPutTokenT<EBSrFlagCollection> EcalCPUDigisProducer::ebSrFlagToken_

private

Definition at line 53 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ecalPseudoStripInputsToken_

edm::EDPutTokenT<EcalPSInputDigiCollection> EcalCPUDigisProducer::ecalPseudoStripInputsToken_

private

Definition at line 75 of file EcalCPUDigisProducer.cc.

Referenced by produce().

ecalTriggerPrimitivesToken_

edm::EDPutTokenT<EcalTrigPrimDigiCollection> EcalCPUDigisProducer::ecalTriggerPrimitivesToken_

private

Definition at line 74 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityChIdErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityChIdErrorsToken_

private

Definition at line 64 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityGainErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityGainErrorsToken_

private

Definition at line 62 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeIntegrityGainSwitchErrorsToken_

edm::EDPutTokenT<EEDetIdCollection> EcalCPUDigisProducer::eeIntegrityGainSwitchErrorsToken_

private

Definition at line 63 of file EcalCPUDigisProducer.cc.

Referenced by produce().

eeSrFlagToken_

edm::EDPutTokenT<EESrFlagCollection> EcalCPUDigisProducer::eeSrFlagToken_

private

Definition at line 54 of file EcalCPUDigisProducer.cc.

Referenced by produce().

idsebtmp

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

private

Definition at line 78 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 78 of file EcalCPUDigisProducer.cc.

Referenced by acquire(), and produce().

integrityBlockSizeErrorsToken_

edm::EDPutTokenT<EcalElectronicsIdCollection> EcalCPUDigisProducer::integrityBlockSizeErrorsToken_

private

Definition at line 69 of file EcalCPUDigisProducer.cc.

Referenced by produce().

integrityTTIdErrorsToken_

edm::EDPutTokenT<EcalElectronicsIdCollection> EcalCPUDigisProducer::integrityTTIdErrorsToken_

private

Definition at line 67 of file EcalCPUDigisProducer.cc.

Referenced by produce().

integrityZSXtalIdErrorsToken_

edm::EDPutTokenT<EcalElectronicsIdCollection> EcalCPUDigisProducer::integrityZSXtalIdErrorsToken_

private

Definition at line 68 of file EcalCPUDigisProducer.cc.

Referenced by produce().

pnDiodeDigisToken_

edm::EDPutTokenT<EcalPnDiodeDigiCollection> EcalCPUDigisProducer::pnDiodeDigisToken_

private

Definition at line 71 of file EcalCPUDigisProducer.cc.

Referenced by produce().

produceDummyIntegrityCollections_

bool EcalCPUDigisProducer::produceDummyIntegrityCollections_

private

Definition at line 50 of file EcalCPUDigisProducer.cc.

Referenced by dummyProduces(), and produce().