Service providing HIP streams to (reentrant) algorithms. More...

#include <PerEventStreamSvc.h>

Inheritance diagram for AthHIP::PerEventStreamSvc:

Collaboration diagram for AthHIP::PerEventStreamSvc:

Public Member Functions
Function(s) inherited from @c AthAlgTool
virtual StatusCode	initialize () override
	Initialize the tool.
Function(s) inherited from @c IStreamSvc
virtual hipStream_t	stream (const EventContext &ctx) const override
	Get the HIP stream to use.

Private Attributes
std::unique_ptr< const SG::SlotSpecificObj< Details::Stream, SG::InvalidSlot::Enabled > >	m_streams
	Slot specific HIP stream(s).

Detailed Description

Service providing HIP streams to (reentrant) algorithms.

In a very simple way. By having one HIP stream per concurrent event (slot), and having algorithms all use a single HIP stream for a given event.

Definition at line 27 of file AthHIP/AthHIPComps/src/PerEventStreamSvc.h.

Member Function Documentation

◆ initialize()

StatusCode AthHIP::PerEventStreamSvc::initialize ( )

overridevirtual

Initialize the tool.

Definition at line 14 of file AthHIP/AthHIPComps/src/PerEventStreamSvc.cxx.

                                         {
 
  // Create the streams object.
  m_streams = std::make_unique<
      const SG::SlotSpecificObj<Details::Stream, SG::InvalidSlot::Enabled>>();
 
  // Tell the user what happened.
  ATH_MSG_INFO("Initialized "
               << std::distance(m_streams->begin(), m_streams->end())
               << " HIP stream(s):");
  for (const auto& stream : *m_streams) {
    ATH_MSG_INFO("  - " << stream.name());
  }
 
  // Return gracefully.
  return StatusCode::SUCCESS;
}

◆ stream()

hipStream_t AthHIP::PerEventStreamSvc::stream ( const EventContext & ctx ) const

overridevirtual

Get the HIP stream to use.

Parameters

ctx	The event context for which the stream is requested

Returns: The HIP stream to use for the current event context

Definition at line 32 of file AthHIP/AthHIPComps/src/PerEventStreamSvc.cxx.

                                                                   {
 
  // Get the stream corresponding to the current slot.
  assert(m_streams);
  return m_streams->get(ctx)->stream();
}

Member Data Documentation

◆ m_streams

std::unique_ptr< const SG::SlotSpecificObj<Details::Stream, SG::InvalidSlot::Enabled> > AthHIP::PerEventStreamSvc::m_streams

private

Slot specific HIP stream(s).

Definition at line 57 of file AthHIP/AthHIPComps/src/PerEventStreamSvc.h.

The documentation for this class was generated from the following files: