Message entre SharedMemoryMessageQueue. Plus de détails...

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

Graphe de collaboration de Arcane::MessagePassing::SharedMemoryMessageRequest:

Classes
class	SortFunctor

Types publics
using	SubQueue = SharedMemoryMessageQueue::SubQueue

Fonctions membres publiques
	SharedMemoryMessageRequest (SubQueue *queue, Int64 request_id, MessageRank orig, MessageRank dest, MessageTag tag, ReceiveBufferInfo buf)
	Créé une requête d'envoie.

	SharedMemoryMessageRequest (SubQueue *queue, Int64 request_id, MessageRank orig, MessageRank dest, MessageTag tag, SendBufferInfo buf)
	Créé une requête de réception.

MessageRank	orig ()

MessageRank	dest ()

MessageTag	tag ()

bool	isRecv ()

bool	isDone ()

void	setDone (bool v)

SendBufferInfo	sendBufferInfo ()

ReceiveBufferInfo	receiveBufferInfo ()

SharedMemoryMessageQueue::SubQueue *	queue ()

void	copyFromSender (SharedMemoryMessageRequest *sender)
	Copie dans le message de réception les informations du message d'envoi.

Int64	id () const

void	destroy ()

ISerializer *	recvSerializer ()

const ISerializer *	sendSerializer ()

void	setSource (MessageRank s)

SharedMemoryMessageRequest *	matchingSendRequest ()
	Requête associée dans le cas où c'est un `receive` issu d'un `probe`

void	setMatchingSendRequest (SharedMemoryMessageRequest *r)

Attributs privés
SubQueue *	m_queue

Int64	m_request_id

bool	m_is_recv

MessageRank	m_orig

MessageRank	m_dest

MessageTag	m_tag

bool	m_is_done = false

SharedMemoryMessageRequest *	m_matching_send_request = nullptr

bool	m_is_destroyed = false

SendBufferInfo	m_send_buffer_info

ReceiveBufferInfo	m_receive_buffer_info

Description détaillée

Message entre SharedMemoryMessageQueue.

Cette classe gère à la fois les messages d'envoi et de réception.

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

Documentation des définitions de type membres

◆ SubQueue

using Arcane::MessagePassing::SharedMemoryMessageRequest::SubQueue = SharedMemoryMessageQueue::SubQueue

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

Documentation des constructeurs et destructeur

◆ SharedMemoryMessageRequest() [1/2]

Arcane::MessagePassing::SharedMemoryMessageRequest::SharedMemoryMessageRequest	(	SubQueue *	queue,
		Int64	request_id,
		MessageRank	orig,
		MessageRank	dest,
		MessageTag	tag,
		ReceiveBufferInfo	buf )

inline

Créé une requête d'envoie.

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

Référencé par copyFromSender(), et matchingSendRequest().

Voici le graphe des appelants de cette fonction :

◆ SharedMemoryMessageRequest() [2/2]

Arcane::MessagePassing::SharedMemoryMessageRequest::SharedMemoryMessageRequest	(	SubQueue *	queue,
		Int64	request_id,
		MessageRank	orig,
		MessageRank	dest,
		MessageTag	tag,
		SendBufferInfo	buf )

inline

Créé une requête de réception.

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

Documentation des fonctions membres

◆ copyFromSender()

void Arcane::MessagePassing::SharedMemoryMessageRequest::copyFromSender ( SharedMemoryMessageRequest * sender )

Copie dans le message de réception les informations du message d'envoi.

Si un 'ISerializer' est disponible, l'utilise. Sinon, il s'agit d'une zone mémoire et on recopie directement les valeurs.

Note: Il serait possible si on connait l'origine de la zone mémoire d'éviter une recopie en passant juste le pointeur.

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

Références ARCANE_FATAL, Arcane::ISerializer::copy(), Arcane::MemoryResourceMng::genericCopy(), et SharedMemoryMessageRequest().

Voici le graphe d'appel pour cette fonction :

◆ dest()

MessageRank Arcane::MessagePassing::SharedMemoryMessageRequest::dest ( )

inline

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

◆ destroy()

void Arcane::MessagePassing::SharedMemoryMessageRequest::destroy ( )

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

◆ id()

Int64 Arcane::MessagePassing::SharedMemoryMessageRequest::id ( ) const

inline

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

◆ isDone()

bool Arcane::MessagePassing::SharedMemoryMessageRequest::isDone ( )

inline

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

◆ isRecv()

bool Arcane::MessagePassing::SharedMemoryMessageRequest::isRecv ( )

inline

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

◆ matchingSendRequest()

SharedMemoryMessageRequest * Arcane::MessagePassing::SharedMemoryMessageRequest::matchingSendRequest ( )

inline

Requête associée dans le cas où c'est un receive issu d'un probe

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

Références SharedMemoryMessageRequest().

Voici le graphe d'appel pour cette fonction :

◆ orig()

MessageRank Arcane::MessagePassing::SharedMemoryMessageRequest::orig ( )

inline

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

◆ queue()

SharedMemoryMessageQueue::SubQueue * Arcane::MessagePassing::SharedMemoryMessageRequest::queue ( )

inline

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

◆ receiveBufferInfo()

ReceiveBufferInfo Arcane::MessagePassing::SharedMemoryMessageRequest::receiveBufferInfo ( )

inline

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

◆ recvSerializer()

ISerializer * Arcane::MessagePassing::SharedMemoryMessageRequest::recvSerializer ( )

inline

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

◆ sendBufferInfo()

SendBufferInfo Arcane::MessagePassing::SharedMemoryMessageRequest::sendBufferInfo ( )

inline

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

◆ sendSerializer()

const ISerializer * Arcane::MessagePassing::SharedMemoryMessageRequest::sendSerializer ( )

inline

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

◆ setDone()

void Arcane::MessagePassing::SharedMemoryMessageRequest::setDone ( bool v )

inline

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

◆ setMatchingSendRequest()

void Arcane::MessagePassing::SharedMemoryMessageRequest::setMatchingSendRequest ( SharedMemoryMessageRequest * r )

inline

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

◆ setSource()

void Arcane::MessagePassing::SharedMemoryMessageRequest::setSource ( MessageRank s )

inline

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

◆ tag()

MessageTag Arcane::MessagePassing::SharedMemoryMessageRequest::tag ( )

inline

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

Documentation des données membres

◆ m_dest

MessageRank Arcane::MessagePassing::SharedMemoryMessageRequest::m_dest

private

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

◆ m_is_destroyed

bool Arcane::MessagePassing::SharedMemoryMessageRequest::m_is_destroyed = false

private

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

◆ m_is_done

bool Arcane::MessagePassing::SharedMemoryMessageRequest::m_is_done = false

private

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

◆ m_is_recv

bool Arcane::MessagePassing::SharedMemoryMessageRequest::m_is_recv

private

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

◆ m_matching_send_request

SharedMemoryMessageRequest* Arcane::MessagePassing::SharedMemoryMessageRequest::m_matching_send_request = nullptr

private

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

◆ m_orig

MessageRank Arcane::MessagePassing::SharedMemoryMessageRequest::m_orig

private

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

◆ m_queue

SubQueue* Arcane::MessagePassing::SharedMemoryMessageRequest::m_queue

private

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

◆ m_receive_buffer_info

ReceiveBufferInfo Arcane::MessagePassing::SharedMemoryMessageRequest::m_receive_buffer_info

private

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

◆ m_request_id

Int64 Arcane::MessagePassing::SharedMemoryMessageRequest::m_request_id

private

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

◆ m_send_buffer_info

SendBufferInfo Arcane::MessagePassing::SharedMemoryMessageRequest::m_send_buffer_info

private

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

◆ m_tag

MessageTag Arcane::MessagePassing::SharedMemoryMessageRequest::m_tag

private

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

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

Classes

Types publics

Fonctions membres publiques

Attributs privés

Description détaillée

Documentation des définitions de type membres

◆ SubQueue

Documentation des constructeurs et destructeur

◆ SharedMemoryMessageRequest() [1/2]

◆ SharedMemoryMessageRequest() [2/2]

Documentation des fonctions membres

◆ copyFromSender()

◆ dest()

◆ destroy()

◆ id()

◆ isDone()

◆ isRecv()

◆ matchingSendRequest()

◆ orig()

◆ queue()

◆ receiveBufferInfo()

◆ recvSerializer()

◆ sendBufferInfo()

◆ sendSerializer()

◆ setDone()

◆ setMatchingSendRequest()

◆ setSource()

◆ tag()

Documentation des données membres

◆ m_dest

◆ m_is_destroyed

◆ m_is_done

◆ m_is_recv

◆ m_matching_send_request

◆ m_orig

◆ m_queue

◆ m_receive_buffer_info

◆ m_request_id

◆ m_send_buffer_info

◆ m_tag