cms::alpakatools::QueueCache< Queue > Class Template Reference

#include <QueueCache.h>

Public Member Functions
std::shared_ptr< Queue >	get (Device const &dev)
	QueueCache ()

Private Types
using	Device = alpaka::Dev< Queue >
using	Platform = alpaka::Pltf< Device >

Private Member Functions
void	clear ()

Private Attributes
std::vector< edm::ReusableObjectHolder< Queue > >	cache_

Detailed Description

template<typename Queue>
class cms::alpakatools::QueueCache< Queue >

Definition at line 17 of file QueueCache.h.

Member Typedef Documentation

Device

template<typename Queue >

using cms::alpakatools::QueueCache< Queue >::Device = alpaka::Dev<Queue>

private

Definition at line 31 of file QueueCache.h.

Platform

template<typename Queue >

using cms::alpakatools::QueueCache< Queue >::Platform = alpaka::Pltf<Device>

private

Definition at line 32 of file QueueCache.h.

Constructor & Destructor Documentation

QueueCache()

template<typename Queue >

cms::alpakatools::QueueCache< Queue >::QueueCache ( )

inline

Definition at line 37 of file QueueCache.h.

: cache_(alpaka::getDevCount<Platform>()) {}

Member Function Documentation

clear()

template<typename Queue >

void cms::alpakatools::QueueCache< Queue >::clear ( void  )

inlineprivate

Definition at line 48 of file QueueCache.h.

References cms::alpakatools::QueueCache< Queue >::cache_.

                 {
      // Reset the contents of the caches, but leave an
      // edm::ReusableObjectHolder alive for each device. This is needed
      // mostly for the unit tests, where the function-static
      // QueueCache lives through multiple tests (and go through
      // multiple shutdowns of the framework).
      cache_.clear();
      cache_.resize(alpaka::getDevCount<Platform>());
    }

get()

template<typename Queue >

std::shared_ptr<Queue> cms::alpakatools::QueueCache< Queue >::get ( Device const &  dev )

inline

Definition at line 42 of file QueueCache.h.

References cms::alpakatools::QueueCache< Queue >::cache_.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), submitPVValidationJobs.BetterConfigParser::__updateDict(), rrapi.RRApi::columns(), rrapi.RRApi::count(), rrapi.RRApi::data(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), submitPVValidationJobs.BetterConfigParser::getResultingSection(), rrapi.RRApi::report(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), and rrapi.RRApi::workspaces().

                                                {
      return cache_[alpaka::getNativeHandle(dev)].makeOrGet([dev]() { return std::make_unique<Queue>(dev); });
    }

Member Data Documentation

cache_

template<typename Queue >

std::vector<edm::ReusableObjectHolder<Queue> > cms::alpakatools::QueueCache< Queue >::cache_

private

Definition at line 58 of file QueueCache.h.

Referenced by cms::alpakatools::QueueCache< Queue >::clear(), and cms::alpakatools::QueueCache< Queue >::get().