Arcane  v3.16.0.0
Documentation développeur
Chargement...
Recherche...
Aucune correspondance
Référence de la classe Arcane::MpiSerializeDispatcher
+ Graphe d'héritage de Arcane::MpiSerializeDispatcher:
+ Graphe de collaboration de Arcane::MpiSerializeDispatcher:

Classes

class  ReceiveSerializerSubRequest
 
class  SendSerializerSubRequest
 Sous-requête d'envoi. Plus de détails...
 
class  SerializeSubRequest
 

Fonctions membres publiques

 MpiSerializeDispatcher (MpiAdapter *adapter, IMessagePassingMng *message_passing_mng)
 
Ref< ISerializeMessageListcreateSerializeMessageListRef () override
 Créé une liste de messages de sérialisation.
 
Request sendSerializer (const ISerializer *s, const PointToPointMessageInfo &message) override
 Message d'envoi.
 
Request receiveSerializer (ISerializer *s, const PointToPointMessageInfo &message) override
 Message de réception.
 
void broadcastSerializer (ISerializer *values, MessageRank rank)
 
ITraceMngtraceMng () const
 

Fonctions membres protégées

Request _recvSerializerBytes (Span< Byte > bytes, MessageRank rank, MessageTag tag, bool is_blocking)
 
Request _recvSerializerBytes (Span< Byte > bytes, MessageId message_id, bool is_blocking)
 

Fonctions membres privées

BasicSerializer_castSerializer (ISerializer *serializer)
 
const BasicSerializer_castSerializer (const ISerializer *serializer)
 
void _checkBigMessage (Int64 message_size)
 
Request _sendSerializerWithTag (ISerializer *values, MessageRank rank, MessageTag mpi_tag, bool is_blocking)
 
Request _sendSerializerBytes (Span< const Byte > bytes, MessageRank rank, MessageTag tag, bool is_blocking)
 
void _init ()
 

Attributs privés

friend MpiSerializeMessageList
 
MpiAdapterm_adapter = nullptr
 
IMessagePassingMngm_message_passing_mng = nullptr
 
ITraceMngm_trace = nullptr
 
Int64 m_serialize_buffer_size
 
Int64 m_max_serialize_buffer_size
 
UniqueArray< SerializeSubRequest * > m_sub_requests
 
bool m_is_trace_serializer = false
 
MPI_Datatype m_byte_serializer_datatype
 
Request sendSerializer (const ISerializer *s, const PointToPointMessageInfo &message, bool force_one_message)
 
Int64 serializeBufferSize () const
 
Request legacySendSerializer (ISerializer *values, const PointToPointMessageInfo &message)
 
void legacyReceiveSerializer (ISerializer *values, MessageRank rank, MessageTag mpi_tag)
 
void checkFinishedSubRequests ()
 
MpiAdapteradapter () const
 
static MessageTag nextSerializeTag (MessageTag tag)
 

Description détaillée

Définition à la ligne 29 du fichier MpiSerializeDispatcher.h.

Documentation des constructeurs et destructeur

◆ MpiSerializeDispatcher()

Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::MpiSerializeDispatcher ( MpiAdapter * adapter,
IMessagePassingMng * message_passing_mng )
explicit

Définition à la ligne 207 du fichier MpiSerializeDispatcher.cc.

◆ ~MpiSerializeDispatcher()

Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::~MpiSerializeDispatcher ( )
override

Définition à la ligne 223 du fichier MpiSerializeDispatcher.cc.

Documentation des fonctions membres

◆ _castSerializer()

BasicSerializer * Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_castSerializer ( ISerializer * serializer)
private

Définition à la ligne 570 du fichier MpiSerializeDispatcher.cc.

◆ _checkBigMessage()

void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_checkBigMessage ( Int64 message_size)
private

Définition à la ligne 432 du fichier MpiSerializeDispatcher.cc.

◆ _init()

void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_init ( )
private

Définition à la ligne 242 du fichier MpiSerializeDispatcher.cc.

◆ _recvSerializerBytes() [1/2]

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_recvSerializerBytes ( Span< Byte > bytes,
MessageId message_id,
bool is_blocking )
protected

Définition à la ligne 316 du fichier MpiSerializeDispatcher.cc.

◆ _recvSerializerBytes() [2/2]

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_recvSerializerBytes ( Span< Byte > bytes,
MessageRank rank,
MessageTag tag,
bool is_blocking )
protected

Définition à la ligne 330 du fichier MpiSerializeDispatcher.cc.

◆ _sendSerializerBytes()

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::_sendSerializerBytes ( Span< const Byte > bytes,
MessageRank rank,
MessageTag tag,
bool is_blocking )
private

Définition à la ligne 348 du fichier MpiSerializeDispatcher.cc.

◆ adapter()

MpiAdapter * Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::adapter ( ) const
inline

Définition à la ligne 67 du fichier MpiSerializeDispatcher.h.

◆ broadcastSerializer()

void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::broadcastSerializer ( ISerializer * values,
MessageRank rank )

Définition à la ligne 526 du fichier MpiSerializeDispatcher.cc.

◆ checkFinishedSubRequests()

void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::checkFinishedSubRequests ( )

Définition à la ligne 409 du fichier MpiSerializeDispatcher.cc.

◆ createSerializeMessageListRef()

Ref< ISerializeMessageList > Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::createSerializeMessageListRef ( )
overridevirtual

Créé une liste de messages de sérialisation.

Implémente Arcane::MessagePassing::ISerializeDispatcher.

Définition à la ligne 582 du fichier MpiSerializeDispatcher.cc.

◆ legacyReceiveSerializer()

void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::legacyReceiveSerializer ( ISerializer * values,
MessageRank rank,
MessageTag mpi_tag )

Définition à la ligne 369 du fichier MpiSerializeDispatcher.cc.

◆ legacySendSerializer()

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::legacySendSerializer ( ISerializer * values,
const PointToPointMessageInfo & message )

Définition à la ligne 258 du fichier MpiSerializeDispatcher.cc.

◆ nextSerializeTag()

MessageTag Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::nextSerializeTag ( MessageTag tag)
static

Définition à la ligne 233 du fichier MpiSerializeDispatcher.cc.

◆ receiveSerializer()

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::receiveSerializer ( ISerializer * s,
const PointToPointMessageInfo & message )
overridevirtual

Message de réception.

Implémente Arcane::MessagePassing::ISerializeDispatcher.

Définition à la ligne 500 du fichier MpiSerializeDispatcher.cc.

◆ sendSerializer() [1/2]

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::sendSerializer ( const ISerializer * s,
const PointToPointMessageInfo & message )
overridevirtual

Message d'envoi.

Implémente Arcane::MessagePassing::ISerializeDispatcher.

Définition à la ligne 444 du fichier MpiSerializeDispatcher.cc.

◆ sendSerializer() [2/2]

Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::sendSerializer ( const ISerializer * s,
const PointToPointMessageInfo & message,
bool force_one_message )

Définition à la ligne 453 du fichier MpiSerializeDispatcher.cc.

◆ serializeBufferSize()

Int64 Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::serializeBufferSize ( ) const
inline

Définition à la ligne 62 du fichier MpiSerializeDispatcher.h.

◆ traceMng()

ITraceMng * Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::traceMng ( ) const
inline

Définition à la ligne 72 du fichier MpiSerializeDispatcher.h.

Documentation des données membres

◆ m_adapter

MpiAdapter* Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_adapter = nullptr
private

Définition à la ligne 82 du fichier MpiSerializeDispatcher.h.

◆ m_byte_serializer_datatype

MPI_Datatype Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_byte_serializer_datatype
private

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

◆ m_is_trace_serializer

bool Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_is_trace_serializer = false
private

Définition à la ligne 88 du fichier MpiSerializeDispatcher.h.

◆ m_max_serialize_buffer_size

Int64 Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_max_serialize_buffer_size
private

Définition à la ligne 86 du fichier MpiSerializeDispatcher.h.

◆ m_message_passing_mng

IMessagePassingMng* Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_message_passing_mng = nullptr
private

Définition à la ligne 83 du fichier MpiSerializeDispatcher.h.

◆ m_serialize_buffer_size

Int64 Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_serialize_buffer_size
private

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

◆ m_sub_requests

UniqueArray<SerializeSubRequest*> Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_sub_requests
private

Définition à la ligne 87 du fichier MpiSerializeDispatcher.h.

◆ m_trace

ITraceMng* Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::m_trace = nullptr
private

Définition à la ligne 84 du fichier MpiSerializeDispatcher.h.

◆ MpiSerializeMessageList

friend Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::MpiSerializeMessageList
private

Définition à la ligne 32 du fichier MpiSerializeDispatcher.h.


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