edm::TransformerBase Class Reference

#include <TransformerBase.h>

Inheritance diagram for edm::TransformerBase:

Public Member Functions
	TransformerBase ()=default
virtual	~TransformerBase () noexcept(false)=default

Protected Types
using	PreTransformFunction = std::function< std::any(edm::WrapperBase const &, edm::WaitingTaskWithArenaHolder)>
using	TransformFunction = std::function< std::unique_ptr< edm::WrapperBase >(std::any)>

Protected Member Functions
void	extendUpdateLookup (ProducerBase const &, ModuleDescription const &iModuleDesc, ProductResolverIndexHelper const &iHelper)
std::size_t	findMatchingIndex (ProducerBase const &iBase, edm::BranchDescription const &) const
ProductResolverIndex	prefetchImp (std::size_t iIndex) const
void	registerTransformAsyncImp (ProducerBase &, EDPutToken, const TypeID &id, std::string instanceName, PreTransformFunction, TransformFunction)
void	registerTransformImp (ProducerBase &, EDPutToken, const TypeID &id, std::string instanceName, TransformFunction)
void	transformImpAsync (WaitingTaskHolder iTask, std::size_t iIndex, edm::ActivityRegistry *iAct, ProducerBase const &iBase, edm::EventForTransformer &) const

Private Types
enum	InfoColumns {   kResolverIndex, kType, kToken, kPreTransform,   kTransform }

Private Attributes
SoATuple< ProductResolverIndex, TypeID, EDPutToken, PreTransformFunction, TransformFunction >	transformInfo_

Detailed Description

Definition at line 33 of file TransformerBase.h.

Member Typedef Documentation

PreTransformFunction

using edm::TransformerBase::PreTransformFunction = std::function<std::any(edm::WrapperBase const&, edm::WaitingTaskWithArenaHolder)>

protected

Definition at line 42 of file TransformerBase.h.

TransformFunction

using edm::TransformerBase::TransformFunction = std::function<std::unique_ptr<edm::WrapperBase>(std::any)>

protected

Definition at line 41 of file TransformerBase.h.

Member Enumeration Documentation

InfoColumns

enum edm::TransformerBase::InfoColumns

private

Enumerator
kResolverIndex
kType
kToken
kPreTransform
kTransform

Definition at line 61 of file TransformerBase.h.

{ kResolverIndex, kType, kToken, kPreTransform, kTransform };

Constructor & Destructor Documentation

TransformerBase()

edm::TransformerBase::TransformerBase ( )

default

~TransformerBase()

virtual edm::TransformerBase::~TransformerBase ( )

virtualdefaultnoexcept

Member Function Documentation

extendUpdateLookup()

void edm::TransformerBase::extendUpdateLookup ( ProducerBase const &  iBase, ModuleDescription const &  iModuleDesc, ProductResolverIndexHelper const &  iHelper  )

protected

Definition at line 94 of file TransformerBase.cc.

References edm::ProductResolverIndexHelper::index(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, edm::ModuleDescription::moduleLabel(), edm::ModuleDescription::processName(), edm::PRODUCT_TYPE, transformInfo_, and edm::ProducerBase::typeLabelList().

Referenced by edm::stream::impl::Transformer::extendUpdateLookup(), edm::one::impl::Transformer< T >::extendUpdateLookup(), edm::limited::impl::Transformer< T >::extendUpdateLookup(), and edm::global::impl::Transformer< T >::extendUpdateLookup().

                                                                                      {
    auto const& list = iBase.typeLabelList();

    for (auto it = transformInfo_.begin<0>(); it != transformInfo_.end<0>(); ++it) {
      auto const& putInfo = list[*it];
      *it = iHelper.index(PRODUCT_TYPE,
                          putInfo.typeID_,
                          iModuleDesc.moduleLabel().c_str(),
                          putInfo.productInstanceName_.c_str(),
                          iModuleDesc.processName().c_str());
    }
  }

findMatchingIndex()

std::size_t edm::TransformerBase::findMatchingIndex ( ProducerBase const &  iBase, edm::BranchDescription const &  iBranch  ) const

protected

Definition at line 73 of file TransformerBase.cc.

References cms::cuda::assert(), newFWLiteAna::found, edm::BranchDescription::productInstanceName(), edm::ProducerBase::typeLabelList(), and edm::BranchDescription::unwrappedTypeID().

Referenced by edm::stream::impl::Transformer::transformIndex_(), edm::one::impl::Transformer< T >::transformIndex_(), edm::limited::impl::Transformer< T >::transformIndex_(), and edm::global::impl::Transformer< T >::transformIndex_().

                                                                                            {
    auto const& list = iBase.typeLabelList();

    std::size_t index = 0;
    bool found = false;
    for (auto const& element : list) {
      if (not element.isTransform_) {
        continue;
      }
      if (element.typeID_ == iBranch.unwrappedTypeID() &&
          element.productInstanceName_ == iBranch.productInstanceName()) {
        found = true;
        break;
      }
      ++index;
    }
    assert(found);
    return index;
  }

prefetchImp()

ProductResolverIndex edm::TransformerBase::prefetchImp ( std::size_t  iIndex ) const

inlineprotected

Definition at line 49 of file TransformerBase.h.

References kResolverIndex, and transformInfo_.

Referenced by edm::stream::impl::Transformer::transformPrefetch_(), edm::one::impl::Transformer< T >::transformPrefetch_(), edm::limited::impl::Transformer< T >::transformPrefetch_(), and edm::global::impl::Transformer< T >::transformPrefetch_().

{ return transformInfo_.get<kResolverIndex>(iIndex); }

registerTransformAsyncImp()

void edm::TransformerBase::registerTransformAsyncImp ( ProducerBase &  iBase, EDPutToken  iToken, const TypeID &  id, std::string  instanceName, PreTransformFunction  iPreFunc, TransformFunction  iFunc  )

protected

Definition at line 63 of file TransformerBase.cc.

References l1ctLayer2EG_cff::id, edm::EDPutToken::index(), eostools::move(), transformInfo_, and edm::ProducerBase::transforms().

Referenced by edm::stream::impl::Transformer::registerTransformAsync(), edm::one::impl::Transformer< T >::registerTransformAsync(), edm::limited::impl::Transformer< T >::registerTransformAsync(), and edm::global::impl::Transformer< T >::registerTransformAsync().

                                                                           {
    auto transformPut = iBase.transforms(id, std::move(instanceName));
    transformInfo_.emplace_back(iToken.index(), id, transformPut, std::move(iPreFunc), std::move(iFunc));
  }

registerTransformImp()

void edm::TransformerBase::registerTransformImp ( ProducerBase &  iBase, EDPutToken  iToken, const TypeID &  id, std::string  instanceName, TransformFunction  iFunc  )

protected

Definition at line 56 of file TransformerBase.cc.

References l1ctLayer2EG_cff::id, edm::EDPutToken::index(), eostools::move(), transformInfo_, and edm::ProducerBase::transforms().

Referenced by edm::stream::impl::Transformer::registerTransform(), edm::one::impl::Transformer< T >::registerTransform(), edm::limited::impl::Transformer< T >::registerTransform(), and edm::global::impl::Transformer< T >::registerTransform().

                                                                                                                 {
    auto transformPut = iBase.transforms(id, std::move(instanceName));
    PreTransformFunction ptf;
    transformInfo_.emplace_back(iToken.index(), id, transformPut, std::move(ptf), std::move(iFunc));
  }

transformImpAsync()

void edm::TransformerBase::transformImpAsync ( edm::WaitingTaskHolder  iHolder, std::size_t  iIndex, edm::ActivityRegistry *  iAct, ProducerBase const &  iBase, edm::EventForTransformer &  iEvent  ) const

protected

Definition at line 109 of file TransformerBase.cc.

References any(), utilities::cache(), CMS_SA_ALLOW, edm::WaitingTaskHolder::doneWaiting(), edm::ModuleCallingContext::getStreamContext(), edm::WaitingTaskHolder::group(), patZpeak::handle, iEvent, kPreTransform, kResolverIndex, kToken, kTransform, kType, edm::make_waiting_task(), eostools::move(), Types::optional, edm::ProducerBase::putTokenIndexToProductResolverIndex(), transformInfo_, and findQualityFiles::v.

Referenced by edm::stream::impl::Transformer::transformAsync_(), edm::one::impl::Transformer< T >::transformAsync_(), edm::limited::impl::Transformer< T >::transformAsync_(), and edm::global::impl::Transformer< T >::transformAsync_().

                                                                                {
    auto const& mcc = iEvent.moduleCallingContext();
    if (transformInfo_.get<kPreTransform>(iIndex)) {
      std::optional<decltype(iEvent.get(transformInfo_.get<kType>(iIndex), transformInfo_.get<kResolverIndex>(iIndex)))>
          handle;
      //transform acquiring signal
      TransformAcquiringSignalSentry sentry(iAct, *mcc.getStreamContext(), mcc);
      CMS_SA_ALLOW try {
        handle = iEvent.get(transformInfo_.get<kType>(iIndex), transformInfo_.get<kResolverIndex>(iIndex));
      } catch (...) {
        iHolder.doneWaiting(std::current_exception());
        return;
      }
      if (handle->wrapper()) {
        auto cache = std::make_shared<std::any>();
        auto nextTask =
            edm::make_waiting_task([holder = iHolder, cache, iIndex, this, &iBase, handle = *handle, iEvent, iAct](
                                       std::exception_ptr const* iPtr) mutable {
              if (iPtr) {
                holder.doneWaiting(*iPtr);
              } else {
                //transform signal
                auto mcc = iEvent.moduleCallingContext();
                TransformSignalSentry sentry(iAct, *mcc.getStreamContext(), mcc);
                iEvent.put(iBase.putTokenIndexToProductResolverIndex()[transformInfo_.get<kToken>(iIndex).index()],
                           transformInfo_.get<kTransform>(iIndex)(std::move(*cache)),
                           handle);
              }
            });
        WaitingTaskWithArenaHolder wta(*iHolder.group(), nextTask);
        CMS_SA_ALLOW try {
          *cache = transformInfo_.get<kPreTransform>(iIndex)(*(handle->wrapper()), wta);
        } catch (...) {
          wta.doneWaiting(std::current_exception());
        }
      }
    } else {
      CMS_SA_ALLOW try {
        auto handle = iEvent.get(transformInfo_.get<kType>(iIndex), transformInfo_.get<kResolverIndex>(iIndex));

        if (handle.wrapper()) {
          std::any v = handle.wrapper();
          //transform signal
          TransformSignalSentry sentry(iAct, *mcc.getStreamContext(), mcc);
          iEvent.put(iBase.putTokenIndexToProductResolverIndex()[transformInfo_.get<kToken>(iIndex).index()],
                     transformInfo_.get<kTransform>(iIndex)(std::move(v)),
                     handle);
        }
      } catch (...) {
        iHolder.doneWaiting(std::current_exception());
      }
    }
  }

Member Data Documentation

transformInfo_

SoATuple<ProductResolverIndex, TypeID, EDPutToken, PreTransformFunction, TransformFunction> edm::TransformerBase::transformInfo_

private

Definition at line 62 of file TransformerBase.h.

Referenced by extendUpdateLookup(), prefetchImp(), registerTransformAsyncImp(), registerTransformImp(), and transformImpAsync().