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< ISerializeMessageList > | createSerializeMessageListRef () 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) |
ITraceMng * | traceMng () 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 |
MpiAdapter * | m_adapter = nullptr |
IMessagePassingMng * | m_message_passing_mng = nullptr |
ITraceMng * | m_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 () |
MpiAdapter * | adapter () const |
static MessageTag | nextSerializeTag (MessageTag tag) |
Définition à la ligne 29 du fichier MpiSerializeDispatcher.h.
|
explicit |
Définition à la ligne 207 du fichier MpiSerializeDispatcher.cc.
|
override |
Définition à la ligne 223 du fichier MpiSerializeDispatcher.cc.
|
private |
Définition à la ligne 570 du fichier MpiSerializeDispatcher.cc.
|
private |
Définition à la ligne 432 du fichier MpiSerializeDispatcher.cc.
|
private |
Définition à la ligne 242 du fichier MpiSerializeDispatcher.cc.
|
protected |
Définition à la ligne 316 du fichier MpiSerializeDispatcher.cc.
|
protected |
Définition à la ligne 330 du fichier MpiSerializeDispatcher.cc.
|
private |
Définition à la ligne 348 du fichier MpiSerializeDispatcher.cc.
|
inline |
Définition à la ligne 67 du fichier MpiSerializeDispatcher.h.
void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::broadcastSerializer | ( | ISerializer * | values, |
MessageRank | rank ) |
Définition à la ligne 526 du fichier MpiSerializeDispatcher.cc.
void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::checkFinishedSubRequests | ( | ) |
Définition à la ligne 409 du fichier MpiSerializeDispatcher.cc.
|
overridevirtual |
Créé une liste de messages de sérialisation.
Implémente Arcane::MessagePassing::ISerializeDispatcher.
Définition à la ligne 582 du fichier MpiSerializeDispatcher.cc.
void Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::legacyReceiveSerializer | ( | ISerializer * | values, |
MessageRank | rank, | ||
MessageTag | mpi_tag ) |
Définition à la ligne 369 du fichier MpiSerializeDispatcher.cc.
Request Arcane::MessagePassing::Mpi::MpiSerializeDispatcher::legacySendSerializer | ( | ISerializer * | values, |
const PointToPointMessageInfo & | message ) |
Définition à la ligne 258 du fichier MpiSerializeDispatcher.cc.
|
static |
Définition à la ligne 233 du fichier MpiSerializeDispatcher.cc.
|
overridevirtual |
Message de réception.
Implémente Arcane::MessagePassing::ISerializeDispatcher.
Définition à la ligne 500 du fichier MpiSerializeDispatcher.cc.
|
overridevirtual |
Message d'envoi.
Implémente Arcane::MessagePassing::ISerializeDispatcher.
Définition à la ligne 444 du fichier MpiSerializeDispatcher.cc.
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.
|
inline |
Définition à la ligne 62 du fichier MpiSerializeDispatcher.h.
|
inline |
Définition à la ligne 72 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 82 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 89 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 88 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 86 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 83 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 85 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 87 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 84 du fichier MpiSerializeDispatcher.h.
|
private |
Définition à la ligne 32 du fichier MpiSerializeDispatcher.h.