ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer Class Reference

Inheritance diagram for ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer:

Classes
struct	ConfigParameters

Public Member Functions
	HcalDigisSoAProducer (edm::ParameterSet const &ps)
	~HcalDigisSoAProducer () override=default
Public Member Functions inherited from ALPAKA_ACCELERATOR_NAMESPACE::stream::EDProducer<>
void	produce (edm::Event &iEvent, edm::EventSetup const &iSetup) final
Public Member Functions inherited from edm::ProducerBase< edm::stream::EDProducer, Args... >
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const
	ProducerBase ()
std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const
std::vector< bool > const &	recordProvenanceList () const
void	registerProducts (ProducerBase *, ProductRegistry *, ModuleDescription const &)
std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...
void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)
TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...
	~ProducerBase () noexcept(false) override

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

Private Types
using	DeviceCollectionPhase0 = hcal::Phase0DigiDeviceCollection
using	DeviceCollectionPhase1 = hcal::Phase1DigiDeviceCollection
using	HostCollectionPhase0 = hcal::Phase0DigiHostCollection
using	HostCollectionPhase1 = hcal::Phase1DigiHostCollection

Private Member Functions
void	produce (device::Event &, device::EventSetup const &) override

Private Attributes
ConfigParameters	config_
device::EDPutToken< DeviceCollectionPhase1 >	digisF01HEToken_
device::EDPutToken< DeviceCollectionPhase1 >	digisF3HBToken_
device::EDPutToken< DeviceCollectionPhase0 >	digisF5HBToken_
edm::EDGetTokenT< HBHEDigiCollection >	hbheDigiToken_
edm::EDGetTokenT< QIE11DigiCollection >	qie11DigiToken_

Additional Inherited Members
Public Types inherited from edm::ProducerBase< edm::stream::EDProducer, Args... >
using	BranchAliasSetterT = ProductRegistryHelper::BranchAliasSetterT< T >
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const *, const char *, edm::ProductResolverIndex > >
typedef ProductRegistryHelper::TypeLabelList	TypeLabelList
Protected Member Functions inherited from edm::ProducerBase< edm::stream::EDProducer, Args... >
auto	produces (std::string instanceName) noexcept
	declare what type of product will make and with which optional label More...
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
BranchAliasSetterT< ProductType >	produces (std::string instanceName)
BranchAliasSetterT< ProductType >	produces ()
auto	produces () noexcept
ProducesCollector	producesCollector ()

Detailed Description

Definition at line 20 of file HcalDigisSoAProducer.cc.

Member Typedef Documentation

DeviceCollectionPhase0

using ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::DeviceCollectionPhase0 = hcal::Phase0DigiDeviceCollection

private

Definition at line 39 of file HcalDigisSoAProducer.cc.

DeviceCollectionPhase1

using ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::DeviceCollectionPhase1 = hcal::Phase1DigiDeviceCollection

private

Definition at line 38 of file HcalDigisSoAProducer.cc.

HostCollectionPhase0

using ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::HostCollectionPhase0 = hcal::Phase0DigiHostCollection

private

Definition at line 36 of file HcalDigisSoAProducer.cc.

HostCollectionPhase1

using ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::HostCollectionPhase1 = hcal::Phase1DigiHostCollection

private

Definition at line 35 of file HcalDigisSoAProducer.cc.

Constructor & Destructor Documentation

HcalDigisSoAProducer()

ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::HcalDigisSoAProducer ( edm::ParameterSet const &  ps )

explicit

Definition at line 67 of file HcalDigisSoAProducer.cc.

References edm::ParameterSet::getParameter().

      : hbheDigiToken_{consumes(ps.getParameter<edm::InputTag>("hbheDigisLabel"))},
        qie11DigiToken_{consumes(ps.getParameter<edm::InputTag>("qie11DigiLabel"))},
        digisF01HEToken_{produces(ps.getParameter<std::string>("digisLabelF01HE"))},
        digisF5HBToken_{produces(ps.getParameter<std::string>("digisLabelF5HB"))},
        digisF3HBToken_{produces(ps.getParameter<std::string>("digisLabelF3HB"))} {
    config_.maxChannelsF01HE = ps.getParameter<uint32_t>("maxChannelsF01HE");
    config_.maxChannelsF5HB = ps.getParameter<uint32_t>("maxChannelsF5HB");
    config_.maxChannelsF3HB = ps.getParameter<uint32_t>("maxChannelsF3HB");
  }

~HcalDigisSoAProducer()

ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::~HcalDigisSoAProducer ( )

overridedefault

Member Function Documentation

fillDescriptions()

void ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::fillDescriptions ( edm::ConfigurationDescriptions &  confDesc )

static

Definition at line 52 of file HcalDigisSoAProducer.cc.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, ProducerED_cfi::InputTag, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                    {
    edm::ParameterSetDescription desc;

    desc.add<edm::InputTag>("hbheDigisLabel", edm::InputTag("hcalDigis"));
    desc.add<edm::InputTag>("qie11DigiLabel", edm::InputTag("hcalDigis"));
    desc.add<std::string>("digisLabelF01HE", std::string{"f01HEDigis"});
    desc.add<std::string>("digisLabelF5HB", std::string{"f5HBDigis"});
    desc.add<std::string>("digisLabelF3HB", std::string{"f3HBDigis"});
    desc.add<uint32_t>("maxChannelsF01HE", 10000u);
    desc.add<uint32_t>("maxChannelsF5HB", 10000u);
    desc.add<uint32_t>("maxChannelsF3HB", 10000u);

    confDesc.addWithDefaultLabel(desc);
  }

produce()

void ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::produce ( device::Event &  event, device::EventSetup const &  setup  )

overrideprivatevirtual

Implements ALPAKA_ACCELERATOR_NAMESPACE::stream::EDProducer<>.

Definition at line 78 of file HcalDigisSoAProducer.cc.

References cms::cuda::assert(), digisF01HEToken_, digisF3HBToken_, digisF5HBToken_, photonIsolationHIProducer_cfi::hbhe, hbheDigiToken_, HcalBarrel, HcalEndcap, QIE11DataFrame::HEADER_WORDS, mps_fire::i, l1ctLayer2EG_cff::id, HBHEDataFrame::MAXSAMPLES, eostools::move(), or, hcalTTPDigis_cfi::presamples, qie11DigiToken_, ecalGpuTask_cfi::sample, QIE11DataFrame::samples(), riemannFit::stride, PortableHostCollection< T >::view(), and QIE11DataFrame::WORDS_PER_SAMPLE.

                                                                                      {
    const auto& hbheDigis = event.get(hbheDigiToken_);
    const auto& qie11Digis = event.get(qie11DigiToken_);

    //Get the number of samples in data from the first digi
    const int stride = HBHEDataFrame::MAXSAMPLES / 2 + 1;
    const int size = hbheDigis.size() * stride;  // number of channels * stride

    // stack host memory in the queue
    HostCollectionPhase0 hf5_(size, event.queue());

    // device product
    DeviceCollectionPhase0 df5_(size, event.queue());

    // set SoA_Scalar;
    hf5_.view().stride() = stride;
    hf5_.view().size() = hbheDigis.size();

    for (unsigned int i = 0; i < hbheDigis.size(); ++i) {
      auto const hbhe = hbheDigis[i];
      auto const id = hbhe.id().rawId();
      auto const presamples = hbhe.presamples();
      uint16_t header_word = (1 << 15) | (0x5 << 12) | (0 << 10) | ((hbhe.sample(0).capid() & 0x3) << 8);

      auto hf5_vi = hf5_.view()[i];
      hf5_vi.ids() = id;
      hf5_vi.npresamples() = presamples;
      hf5_vi.data()[0] = header_word;
      //TODO:: get HEADER_WORDS/WORDS_PER_SAMPLE from DataFormat
      for (unsigned int i = 0; i < hf5_.view().stride() - 1; i++) {
        uint16_t s0 = (0 << 7) | (static_cast<uint8_t>(hbhe.sample(2 * i).adc()) & 0x7f);
        uint16_t s1 = (0 << 7) | (static_cast<uint8_t>(hbhe.sample(2 * i + 1).adc()) & 0x7f);
        uint16_t sample = (s1 << 8) | s0;
        hf5_vi.data()[i + 1] = sample;
      }
    }
    // copy hf5 to df5
    alpaka::memcpy(event.queue(), df5_.buffer(), hf5_.const_buffer());
    event.emplace(digisF5HBToken_, std::move(df5_));

    if (qie11Digis.empty()) {
      event.emplace(digisF01HEToken_);
      event.emplace(digisF3HBToken_);

    } else {
      auto size_f1 = 0;
      auto size_f3 = 0;

      // count the size of the SOA;
      for (unsigned int i = 0; i < qie11Digis.size(); i++) {
        auto const digi = QIE11DataFrame{qie11Digis[i]};

        if (digi.flavor() == 0 or digi.flavor() == 1) {
          if (digi.detid().subdetId() == HcalEndcap) {
            size_f1++;
          }
        } else if (digi.flavor() == 3) {
          if (digi.detid().subdetId() == HcalBarrel) {
            size_f3++;
          }
        }
      }
      auto const nsamples = qie11Digis.samples();
      auto const stride01 = nsamples * QIE11DataFrame::WORDS_PER_SAMPLE + QIE11DataFrame::HEADER_WORDS;

      // stack host memory in the queue
      HostCollectionPhase1 hf1_(size_f1, event.queue());
      HostCollectionPhase1 hf3_(size_f3, event.queue());

      // device product
      DeviceCollectionPhase1 df1_(size_f1, event.queue());
      DeviceCollectionPhase1 df3_(size_f3, event.queue());

      // set SoA_Scalar;
      hf1_.view().stride() = stride01;
      hf3_.view().stride() = stride01;

      unsigned int i_f1 = 0;  //counters for f1 digis
      unsigned int i_f3 = 0;  //counters for f3 digis

      for (unsigned int i = 0; i < qie11Digis.size(); i++) {
        auto const digi = QIE11DataFrame{qie11Digis[i]};
        assert(digi.samples() == qie11Digis.samples() && "collection nsamples must equal per digi samples");

        if (digi.flavor() == 0 or digi.flavor() == 1) {
          if (digi.detid().subdetId() != HcalEndcap)
            continue;
          auto hf01_vi = hf1_.view()[i_f1];

          hf01_vi.ids() = digi.detid().rawId();
          for (int hw = 0; hw < QIE11DataFrame::HEADER_WORDS + digi.samples(); hw++) {
            hf01_vi.data()[hw] = (qie11Digis[i][hw]);
          }
          i_f1++;
        } else if (digi.flavor() == 3) {
          if (digi.detid().subdetId() != HcalBarrel)
            continue;
          auto hf03_vi = hf3_.view()[i_f3];

          hf03_vi.ids() = digi.detid().rawId();

          for (int hw = 0; hw < QIE11DataFrame::HEADER_WORDS + digi.samples(); hw++) {
            hf03_vi.data()[hw] = (qie11Digis[i][hw]);
          }
          i_f3++;
        }
      }

      hf1_.view().size() = size_f1;
      hf3_.view().size() = size_f3;

      alpaka::memcpy(event.queue(), df1_.buffer(), hf1_.const_buffer());
      alpaka::memcpy(event.queue(), df3_.buffer(), hf3_.const_buffer());

      event.emplace(digisF01HEToken_, std::move(df1_));
      event.emplace(digisF3HBToken_, std::move(df3_));
    }
  }

Member Data Documentation

config_

ConfigParameters ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::config_

private

Definition at line 49 of file HcalDigisSoAProducer.cc.

digisF01HEToken_

device::EDPutToken<DeviceCollectionPhase1> ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::digisF01HEToken_

private

Definition at line 42 of file HcalDigisSoAProducer.cc.

Referenced by produce().

digisF3HBToken_

device::EDPutToken<DeviceCollectionPhase1> ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::digisF3HBToken_

private

Definition at line 44 of file HcalDigisSoAProducer.cc.

Referenced by produce().

digisF5HBToken_

device::EDPutToken<DeviceCollectionPhase0> ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::digisF5HBToken_

private

Definition at line 43 of file HcalDigisSoAProducer.cc.

Referenced by produce().

hbheDigiToken_

edm::EDGetTokenT<HBHEDigiCollection> ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::hbheDigiToken_

private

Definition at line 31 of file HcalDigisSoAProducer.cc.

Referenced by produce().

qie11DigiToken_

edm::EDGetTokenT<QIE11DigiCollection> ALPAKA_ACCELERATOR_NAMESPACE::HcalDigisSoAProducer::qie11DigiToken_

private

Definition at line 32 of file HcalDigisSoAProducer.cc.

Referenced by produce().