cms::alpakatools::EventCache< Event > Class Template Reference

#include <EventCache.h>

Public Types
using	Device = alpaka::Dev< Event >
using	Platform = alpaka::Platform< Device >

Public Member Functions
	EventCache ()
std::shared_ptr< Event >	get (Device dev)

Private Member Functions
void	clear ()
std::shared_ptr< Event >	makeOrGet (Device dev)

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

Detailed Description

template<typename Event>
class cms::alpakatools::EventCache< Event >

Definition at line 19 of file EventCache.h.

Member Typedef Documentation

Device

template<typename Event >

using cms::alpakatools::EventCache< Event >::Device = alpaka::Dev<Event>

Definition at line 34 of file EventCache.h.

Platform

template<typename Event >

using cms::alpakatools::EventCache< Event >::Platform = alpaka::Platform<Device>

Definition at line 35 of file EventCache.h.

Constructor & Destructor Documentation

EventCache()

template<typename Event >

cms::alpakatools::EventCache< Event >::EventCache ( )

inline

Definition at line 39 of file EventCache.h.

: cache_(devices<Platform>().size()) {}

Member Function Documentation

clear()

template<typename Event >

void cms::alpakatools::EventCache< Event >::clear ( void  )

inlineprivate

Definition at line 80 of file EventCache.h.

References cms::alpakatools::EventCache< Event >::cache_, and cms::alpakatools::size.

                 {
      // 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
      // EventCache lives through multiple tests (and go through
      // multiple shutdowns of the framework).
      cache_.clear();
      cache_.resize(devices<Platform>().size());
    }

get()

template<typename Event >

std::shared_ptr<Event> cms::alpakatools::EventCache< Event >::get ( Device  dev )

inline

Definition at line 47 of file EventCache.h.

References edmPickEvents::event, cms::alpakatools::EventCache< Event >::makeOrGet(), and eostools::move().

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().

                                         {
      auto event = makeOrGet(dev);
      // captured work has completed, or a just-created event
      if (alpaka::isComplete(*event)) {
        return event;
      }

      // Got an event with incomplete captured work. Try again until we
      // get a completed (or a just-created) event. Need to keep all
      // incomplete events until a completed event is found in order to
      // avoid ping-pong with an incomplete event.
      std::vector<std::shared_ptr<Event>> ptrs{std::move(event)};
      bool completed;
      do {
        event = makeOrGet(dev);
        completed = alpaka::isComplete(*event);
        if (not completed) {
          ptrs.emplace_back(std::move(event));
        }
      } while (not completed);
      return event;
    }

makeOrGet()

template<typename Event >

std::shared_ptr<Event> cms::alpakatools::EventCache< Event >::makeOrGet ( Device  dev )

inlineprivate

Definition at line 71 of file EventCache.h.

References cms::alpakatools::EventCache< Event >::cache_, and ALPAKA_ACCELERATOR_NAMESPACE::brokenline::constexpr().

Referenced by cms::alpakatools::EventCache< Event >::get().

                                               {
      return cache_[alpaka::getNativeHandle(dev)].makeOrGet([dev]() {
        // We want non-busy waits
        bool constexpr busyWait = false;
        return std::make_unique<Event>(dev, busyWait);
      });
    }

Member Data Documentation

cache_

template<typename Event >

std::vector<edm::ReusableObjectHolder<Event> > cms::alpakatools::EventCache< Event >::cache_

private

Definition at line 90 of file EventCache.h.

Referenced by cms::alpakatools::EventCache< Event >::clear(), and cms::alpakatools::EventCache< Event >::makeOrGet().