CommunicationManager Class Reference

HiCR: HiCR::backend::opencl::CommunicationManager Class Reference

HiCR

HiCR
backend
opencl
CommunicationManager

#include <communicationManager.hpp>

Inheritance diagram for HiCR::backend::opencl::CommunicationManager:

Public Member Functions
	CommunicationManager (const std::unordered_map< opencl::Device::deviceIdentifier_t, std::shared_ptr< cl::CommandQueue > > &deviceQueueMap)

	~CommunicationManager ()=default

__INLINE__ void	memcpyAsync (const std::shared_ptr< HiCR::LocalMemorySlot > &destination, const size_t dst_offset, const std::shared_ptr< HiCR::LocalMemorySlot > &source, const size_t src_offset, const size_t size, const cl::CommandQueue *queue)

Public Member Functions inherited from HiCR::CommunicationManager
__INLINE__ void	exchangeGlobalMemorySlots (GlobalMemorySlot::tag_t tag, const std::vector< globalKeyMemorySlotPair_t > &memorySlots)

__INLINE__ std::shared_ptr< GlobalMemorySlot >	getGlobalMemorySlot (GlobalMemorySlot::tag_t tag, GlobalMemorySlot::globalKey_t globalKey)

virtual uint8_t *	serializeGlobalMemorySlot (const std::shared_ptr< HiCR::GlobalMemorySlot > &globalSlot) const

virtual std::shared_ptr< GlobalMemorySlot >	deserializeGlobalMemorySlot (uint8_t *buffer, GlobalMemorySlot::tag_t tag)

virtual std::shared_ptr< GlobalMemorySlot >	promoteLocalMemorySlot (const std::shared_ptr< LocalMemorySlot > &localMemorySlot, GlobalMemorySlot::tag_t tag)

__INLINE__ void	deregisterGlobalMemorySlot (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

__INLINE__ void	destroyGlobalMemorySlot (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

virtual void	destroyPromotedGlobalMemorySlot (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

__INLINE__ void	queryMemorySlotUpdates (std::shared_ptr< LocalMemorySlot > memorySlot)

__INLINE__ void	memcpy (const std::shared_ptr< LocalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< LocalMemorySlot > &source, size_t src_offset, size_t size)

__INLINE__ void	memcpy (const std::shared_ptr< GlobalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< LocalMemorySlot > &source, size_t src_offset, size_t size)

__INLINE__ void	memcpy (const std::shared_ptr< LocalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< GlobalMemorySlot > &source, size_t src_offset, size_t size)

__INLINE__ void	fence (GlobalMemorySlot::tag_t tag)

__INLINE__ void	fence (const std::shared_ptr< LocalMemorySlot > &slot, size_t expectedSent, size_t expectedRecvd)

__INLINE__ void	fence (const std::shared_ptr< GlobalMemorySlot > &slot, size_t expectedSent, size_t expectedRecvd)

__INLINE__ bool	acquireGlobalLock (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

__INLINE__ void	releaseGlobalLock (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

virtual __INLINE__ void	flushSent ()

virtual __INLINE__ void	flushReceived ()

__INLINE__ auto &	getGlobalMemorySlotTagKeyMap ()

__INLINE__ void	setGlobalMemorySlotTagKeyMap (const HiCR::CommunicationManager::globalMemorySlotTagKeyMap_t &globalMemorySlotTagKeyMap)

Additional Inherited Members
Public Types inherited from HiCR::CommunicationManager
using	globalKeyMemorySlotPair_t = std::pair< GlobalMemorySlot::globalKey_t, std::shared_ptr< LocalMemorySlot > >

using	globalKeyToMemorySlotMap_t = std::map< GlobalMemorySlot::globalKey_t, std::shared_ptr< GlobalMemorySlot > >

using	globalMemorySlotTagKeyMap_t = std::map< GlobalMemorySlot::tag_t, globalKeyToMemorySlotMap_t >

Protected Member Functions inherited from HiCR::CommunicationManager
__INLINE__ void	registerGlobalMemorySlot (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

virtual void	queryMemorySlotUpdatesImpl (std::shared_ptr< LocalMemorySlot > memorySlot)=0

virtual void	deregisterGlobalMemorySlotImpl (const std::shared_ptr< GlobalMemorySlot > &memorySlot)

virtual void	destroyGlobalMemorySlotImpl (std::shared_ptr< GlobalMemorySlot > memorySlot)=0

virtual void	memcpyImpl (const std::shared_ptr< LocalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< LocalMemorySlot > &source, size_t src_offset, size_t size)

virtual void	memcpyImpl (const std::shared_ptr< GlobalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< LocalMemorySlot > &source, size_t src_offset, size_t size)

virtual void	memcpyImpl (const std::shared_ptr< LocalMemorySlot > &destination, size_t dst_offset, const std::shared_ptr< GlobalMemorySlot > &source, size_t src_offset, size_t size)

virtual void	fenceImpl (const std::shared_ptr< LocalMemorySlot > &slot, size_t expectedSent, size_t expectedRcvd)

virtual void	fenceImpl (const std::shared_ptr< GlobalMemorySlot > &slot, size_t expectedSent, size_t expectedRcvd)

virtual bool	acquireGlobalLockImpl (std::shared_ptr< GlobalMemorySlot > memorySlot)=0

virtual void	releaseGlobalLockImpl (std::shared_ptr< GlobalMemorySlot > memorySlot)=0

__INLINE__ auto &	getGlobalMemorySlotsToDestroyPerTag ()

__INLINE__ void	increaseMessageRecvCounter (HiCR::LocalMemorySlot &memorySlot) noexcept

__INLINE__ void	increaseMessageSentCounter (HiCR::LocalMemorySlot &memorySlot) noexcept

__INLINE__ void	setMessagesRecv (HiCR::LocalMemorySlot &memorySlot, const size_t count) noexcept

__INLINE__ void	setMessagesSent (HiCR::LocalMemorySlot &memorySlot, const size_t count) noexcept

Detailed Description

Implementation of the Communication Manager for the OpenCL backend.

Constructor & Destructor Documentation

◆ CommunicationManager()

HiCR::backend::opencl::CommunicationManager::CommunicationManager ( const std::unordered_map< opencl::Device::deviceIdentifier_t, std::shared_ptr< cl::CommandQueue > > & deviceQueueMap )

inline

Constructor for the opencl communication manager class for the OpenCL backend.

Parameters

[in] deviceQueueMap map of device ids and command queues

◆ ~CommunicationManager()

HiCR::backend::opencl::CommunicationManager::~CommunicationManager ( )

virtualdefault

Default destructor

Reimplemented from HiCR::CommunicationManager.

Member Function Documentation

◆ memcpyAsync()

__INLINE__ void HiCR::backend::opencl::CommunicationManager::memcpyAsync	(	const std::shared_ptr< HiCR::LocalMemorySlot > &	destination,
		const size_t	dst_offset,
		const std::shared_ptr< HiCR::LocalMemorySlot > &	source,
		const size_t	src_offset,
		const size_t	size,
		const cl::CommandQueue *	queue
	)

inline

Backend-internal asyncrhonous implementation of the memcpy operation. It passes an OpenCL stream as context for later asynchrounous check for completion

For more information, see: memcpyImpl