Référence de la classe Arcane::MessagePassing::SharedMemoryMessageQueue

File de messages entre les rangs partagés par un SharedMemoryParallelMng. Plus de détails...

#include <arcane/parallel/thread/SharedMemoryMessageQueue.h>

Graphe d'héritage de Arcane::MessagePassing::SharedMemoryMessageQueue:

Graphe de collaboration de Arcane::MessagePassing::SharedMemoryMessageQueue:

Classes
class	SubQueue
	File pour les messages d'un rang en mémoire partagée. Plus de détails...

Fonctions membres publiques
void	init (Int32 nb_thread) override
void	waitAll (ArrayView< Request > requests) override
void	waitSome (Int32 rank, ArrayView< Request > requests, ArrayView< bool > requests_done, bool is_non_blockign) override
void	setTraceMng (Int32 rank, ITraceMng *tm) override
Request	addReceive (const PointToPointMessageInfo &message, ReceiveBufferInfo buf) override
Request	addSend (const PointToPointMessageInfo &message, SendBufferInfo buf) override
MessageId	probe (const PointToPointMessageInfo &message) override
MessageSourceInfo	legacyProbe (const PointToPointMessageInfo &message) override
Fonctions membres publiques hérités de Arcane::MessagePassing::ISharedMemoryMessageQueue
virtual void	init (Integer nb_thread)=0

Fonctions membres privées
SubQueue *	_getSubQueue (MessageRank rank)
Int64	_getNextRequestId ()
Request	_request (SharedMemoryMessageRequest *tmr)
SubQueue *	_getSourceSubQueue (const MP::PointToPointMessageInfo &message)
SubQueue *	_getDestinationSubQueue (const MP::PointToPointMessageInfo &message)

Attributs privés
Int32	m_nb_thread = 0
UniqueArray< SubQueue * >	m_sub_queues
std::atomic< Int64 >	m_atomic_request_id

Membres hérités additionnels
Types publics hérités de Arcane::MessagePassing::ISharedMemoryMessageQueue
using	MessageSourceInfo = Parallel::MessageSourceInfo

Description détaillée

File de messages entre les rangs partagés par un SharedMemoryParallelMng.

Définition à la ligne 47 du fichier SharedMemoryMessageQueue.h.

Documentation des constructeurs et destructeur

SharedMemoryMessageQueue()

Arcane::MessagePassing::SharedMemoryMessageQueue::SharedMemoryMessageQueue ( )

inline

Définition à la ligne 56 du fichier SharedMemoryMessageQueue.h.

~SharedMemoryMessageQueue()

Arcane::MessagePassing::SharedMemoryMessageQueue::~SharedMemoryMessageQueue ( )

override

Définition à la ligne 612 du fichier SharedMemoryMessageQueue.cc.

Documentation des fonctions membres

_getDestinationSubQueue()

SharedMemoryMessageQueue::SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getDestinationSubQueue ( const MP::PointToPointMessageInfo &  message )

private

Définition à la ligne 649 du fichier SharedMemoryMessageQueue.cc.

_getNextRequestId()

Int64 Arcane::MessagePassing::SharedMemoryMessageQueue::_getNextRequestId ( )

inlineprivate

Définition à la ligne 89 du fichier SharedMemoryMessageQueue.h.

_getSourceSubQueue()

SharedMemoryMessageQueue::SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getSourceSubQueue ( const MP::PointToPointMessageInfo &  message )

private

Définition à la ligne 637 du fichier SharedMemoryMessageQueue.cc.

_getSubQueue()

SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getSubQueue ( MessageRank  rank )

inlineprivate

Définition à la ligne 85 du fichier SharedMemoryMessageQueue.h.

_request()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::_request ( SharedMemoryMessageRequest *  tmr )

private

Définition à la ligne 758 du fichier SharedMemoryMessageQueue.cc.

addReceive()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::addReceive ( const PointToPointMessageInfo &  message, ReceiveBufferInfo  buf  )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 709 du fichier SharedMemoryMessageQueue.cc.

addSend()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::addSend ( const PointToPointMessageInfo &  message, SendBufferInfo  buf  )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 719 du fichier SharedMemoryMessageQueue.cc.

init()

void Arcane::MessagePassing::SharedMemoryMessageQueue::init ( Int32  nb_thread )

override

Définition à la ligne 622 du fichier SharedMemoryMessageQueue.cc.

legacyProbe()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::legacyProbe ( const PointToPointMessageInfo &  message )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 739 du fichier SharedMemoryMessageQueue.cc.

probe()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::probe ( const PointToPointMessageInfo &  message )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 729 du fichier SharedMemoryMessageQueue.cc.

setTraceMng()

void Arcane::MessagePassing::SharedMemoryMessageQueue::setTraceMng ( Int32  rank, ITraceMng *  tm  )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 749 du fichier SharedMemoryMessageQueue.cc.

waitAll()

void Arcane::MessagePassing::SharedMemoryMessageQueue::waitAll ( ArrayView< Request >  requests )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 661 du fichier SharedMemoryMessageQueue.cc.

waitSome()

void Arcane::MessagePassing::SharedMemoryMessageQueue::waitSome ( Int32  rank, ArrayView< Request >  requests, ArrayView< bool >  requests_done, bool  is_non_blockign  )

overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

Définition à la ligne 697 du fichier SharedMemoryMessageQueue.cc.

Documentation des données membres

m_atomic_request_id

std::atomic<Int64> Arcane::MessagePassing::SharedMemoryMessageQueue::m_atomic_request_id

private

Définition à la ligne 81 du fichier SharedMemoryMessageQueue.h.

m_nb_thread

Int32 Arcane::MessagePassing::SharedMemoryMessageQueue::m_nb_thread = 0

private

Définition à la ligne 79 du fichier SharedMemoryMessageQueue.h.

m_sub_queues

UniqueArray<SubQueue*> Arcane::MessagePassing::SharedMemoryMessageQueue::m_sub_queues

private

Définition à la ligne 80 du fichier SharedMemoryMessageQueue.h.

---

La documentation de cette classe a été générée à partir des fichiers suivants :

• SharedMemoryMessageQueue.h
• SharedMemoryMessageQueue.cc