Communications point à point par des 'ISerializer'. Plus de détails...

#include </__w/arcaneframework.github.io/arcaneframework.github.io/framework/arccore/src/message_passing/arccore/message_passing/PointToPointSerializerMng.h>

Graphe de collaboration de Arccore::MessagePassing::PointToPointSerializerMng:

Classes
class	Impl

Fonctions membres publiques
	PointToPointSerializerMng (IMessagePassingMng *mpm)

	PointToPointSerializerMng (const PointToPointSerializerMng &)=delete

PointToPointSerializerMng &	operator= (const PointToPointSerializerMng &)=delete

IMessagePassingMng *	messagePassingMng () const
	Gestionnaire de message associé

void	processPendingMessages ()
	Envoie les messages de la liste qui ne l'ont pas encore été.

Integer	waitMessages (eWaitType wt, std::function< void(ISerializeMessage *)> functor)
	Attend que les messages aient terminé leur exécution.

bool	hasMessages () const
	Indique s'il reste des messages qui ne sont pas encore terminés.

Ref< ISerializeMessage >	addReceiveMessage (MessageRank sender_rank)
	Créé un message de sérialisation en réception.

Ref< ISerializeMessage >	addReceiveMessage (MessageId message_id)
	Créé un message de sérialisation en réception.

Ref< ISerializeMessage >	addSendMessage (MessageRank receiver_rank)
	Créé message de sérialisation en envoi.

void	setDefaultTag (MessageTag default_tag)
	Tag par défaut utilisé pour les messages.

void	setStrategy (ISerializeMessage::eStrategy strategy)
	Stratégie utilisée pour les messages.

Attributs privés
Impl *	m_p

Description détaillée

Communications point à point par des 'ISerializer'.

Définition à la ligne 38 du fichier PointToPointSerializerMng.h.

Documentation des constructeurs et destructeur

◆ PointToPointSerializerMng()

Arccore::MessagePassing::PointToPointSerializerMng::PointToPointSerializerMng ( IMessagePassingMng * mpm )

Définition à la ligne 85 du fichier PointToPointSerializerMng.cc.

◆ ~PointToPointSerializerMng()

Arccore::MessagePassing::PointToPointSerializerMng::~PointToPointSerializerMng ( )

Définition à la ligne 94 du fichier PointToPointSerializerMng.cc.

Documentation des fonctions membres

◆ addReceiveMessage() [1/2]

Ref< ISerializeMessage > Arccore::MessagePassing::PointToPointSerializerMng::addReceiveMessage ( MessageId message_id )

Créé un message de sérialisation en réception.

sender_rank est le rang de celui qui envoie le message correspondant. Il est possible de spécifier un rang nul pour indiquer qu'on souhaite recevoir de n'importe qui.

Définition à la ligne 183 du fichier PointToPointSerializerMng.cc.

◆ addReceiveMessage() [2/2]

Ref< ISerializeMessage > Arccore::MessagePassing::PointToPointSerializerMng::addReceiveMessage ( MessageRank sender_rank )

Créé un message de sérialisation en réception.

sender_rank est le rang de celui qui envoie le message correspondant. Il est possible de spécifier un rang nul pour indiquer qu'on souhaite recevoir de n'importe qui.

Définition à la ligne 172 du fichier PointToPointSerializerMng.cc.

◆ addSendMessage()

Ref< ISerializeMessage > Arccore::MessagePassing::PointToPointSerializerMng::addSendMessage ( MessageRank receiver_rank )

Créé message de sérialisation en envoi.

Définition à la ligne 161 du fichier PointToPointSerializerMng.cc.

◆ hasMessages()

bool Arccore::MessagePassing::PointToPointSerializerMng::hasMessages ( ) const

Indique s'il reste des messages qui ne sont pas encore terminés.

Définition à la ligne 130 du fichier PointToPointSerializerMng.cc.

Référencé par setDefaultTag(), et setStrategy().

◆ messagePassingMng()

IMessagePassingMng * Arccore::MessagePassing::PointToPointSerializerMng::messagePassingMng ( ) const

Gestionnaire de message associé

Définition à la ligne 103 du fichier PointToPointSerializerMng.cc.

◆ processPendingMessages()

void Arccore::MessagePassing::PointToPointSerializerMng::processPendingMessages ( )

Envoie les messages de la liste qui ne l'ont pas encore été.

Il n'est en général pas nécessaire d'appeler cette méthode car cele est fait automatiquement lors de l'appel à waitMessages().

Définition à la ligne 112 du fichier PointToPointSerializerMng.cc.

◆ setDefaultTag()

void Arccore::MessagePassing::PointToPointSerializerMng::setDefaultTag ( MessageTag default_tag )

Tag par défaut utilisé pour les messages.

Cette méthode ne peut être appelée que s'il n'y a pas de messages en cours (hasMessages()==false). Tous les rangs de messagePassingMng() doivent utiliser le même tag.

Définition à la ligne 139 du fichier PointToPointSerializerMng.cc.

Références hasMessages().

◆ setStrategy()

void Arccore::MessagePassing::PointToPointSerializerMng::setStrategy ( ISerializeMessage::eStrategy strategy )

Stratégie utilisée pour les messages.

Cette méthode ne peut être appelée que s'il n'y a pas de messages en cours (hasMessages()==false). Tous les rangs de messagePassingMng() doivent utiliser la même stratégie.

Définition à la ligne 150 du fichier PointToPointSerializerMng.cc.

Références hasMessages().

◆ waitMessages()

Integer Arccore::MessagePassing::PointToPointSerializerMng::waitMessages	(	eWaitType	wt,
		std::function< void(ISerializeMessage *)>	functor
	)

Attend que les messages aient terminé leur exécution.

Le type d'attente est spécifié par wt.

Renvoie: le nombre de messages complètement exécutés ou (-1) s'ils l'ont tous été.

Définition à la ligne 121 du fichier PointToPointSerializerMng.cc.

Documentation des données membres

◆ m_p

Impl* Arccore::MessagePassing::PointToPointSerializerMng::m_p

private

Définition à la ligne 119 du fichier PointToPointSerializerMng.h.

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

Classes

Fonctions membres publiques

Attributs privés