Communications point à point par des 'ISerializer'. Plus de détails...
Graphe de collaboration de Arcane::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 |
Communications point à point par des 'ISerializer'.
Définition à la ligne 38 du fichier PointToPointSerializerMng.h.
| Arcane::MessagePassing::PointToPointSerializerMng::PointToPointSerializerMng | ( | IMessagePassingMng * | mpm | ) |
Définition à la ligne 85 du fichier PointToPointSerializerMng.cc.
| Arcane::MessagePassing::PointToPointSerializerMng::~PointToPointSerializerMng | ( | ) |
Définition à la ligne 94 du fichier PointToPointSerializerMng.cc.
| Ref< ISerializeMessage > Arcane::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.
| Ref< ISerializeMessage > Arcane::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.
Référencé par Arcane::TransferValuesParallelOperation::transferValues().
Voici le graphe des appelants de cette fonction :| Ref< ISerializeMessage > Arcane::MessagePassing::PointToPointSerializerMng::addSendMessage | ( | MessageRank | receiver_rank | ) |
Créé message de sérialisation en envoi.
Définition à la ligne 161 du fichier PointToPointSerializerMng.cc.
Référencé par Arcane::TransferValuesParallelOperation::transferValues().
Voici le graphe des appelants de cette fonction :| bool Arcane::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().
Voici le graphe des appelants de cette fonction :| IMessagePassingMng * Arcane::MessagePassing::PointToPointSerializerMng::messagePassingMng | ( | ) | const |
Gestionnaire de message associé
Définition à la ligne 103 du fichier PointToPointSerializerMng.cc.
| void Arcane::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.
| void Arcane::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().
Voici le graphe d'appel pour cette fonction :| void Arcane::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().
Voici le graphe d'appel pour cette fonction :| Integer Arcane::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.
Définition à la ligne 121 du fichier PointToPointSerializerMng.cc.
Référencé par Arcane::TransferValuesParallelOperation::transferValues().
Voici le graphe des appelants de cette fonction :
|
private |
Définition à la ligne 119 du fichier PointToPointSerializerMng.h.