Arcane  v4.1.0.0
Documentation développeur
Chargement...
Recherche...
Aucune correspondance
Classes | Fonctions membres publiques | Fonctions membres privées | Attributs privés | Liste de tous les membres
Référence de la classe Arcane::MessagePassing::SharedMemoryMessageQueue

File de messages entre les rangs partagés par un SharedMemoryParallelMng. Plus de détails...

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

+ Graphe d'héritage de Arcane::MessagePassing::SharedMemoryMessageQueue:
+ Graphe de collaboration de Arcane::MessagePassing::SharedMemoryMessageQueue:

Classes

class  SubQueue
 File pour les messages d'un rang en mémoire partagée. Plus de détails...
 

Fonctions membres publiques

void init (Int32 nb_thread) override
 
void waitAll (ArrayView< Request > requests) override
 
void waitSome (Int32 rank, ArrayView< Request > requests, ArrayView< bool > requests_done, bool is_non_blockign) override
 
void setTraceMng (Int32 rank, ITraceMng *tm) override
 
Request addReceive (const PointToPointMessageInfo &message, ReceiveBufferInfo buf) override
 
Request addSend (const PointToPointMessageInfo &message, SendBufferInfo buf) override
 
MessageId probe (const PointToPointMessageInfo &message) override
 
MessageSourceInfo legacyProbe (const PointToPointMessageInfo &message) override
 

Fonctions membres privées

SubQueue * _getSubQueue (MessageRank rank)
 
Int64 _getNextRequestId ()
 
Request _request (SharedMemoryMessageRequest *tmr)
 
SubQueue * _getSourceSubQueue (const MP::PointToPointMessageInfo &message)
 
SubQueue * _getDestinationSubQueue (const MP::PointToPointMessageInfo &message)
 

Attributs privés

Int32 m_nb_thread = 0
 
UniqueArray< SubQueue * > m_sub_queues
 
std::atomic< Int64 > m_atomic_request_id
 

Membres hérités additionnels

- Types publics hérités de Arcane::MessagePassing::ISharedMemoryMessageQueue
using MessageSourceInfo = Parallel::MessageSourceInfo
 

Description détaillée

File de messages entre les rangs partagés par un SharedMemoryParallelMng.

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

Documentation des constructeurs et destructeur

◆ SharedMemoryMessageQueue()

Arcane::MessagePassing::SharedMemoryMessageQueue::SharedMemoryMessageQueue ( )
inline

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

◆ ~SharedMemoryMessageQueue()

Arcane::MessagePassing::SharedMemoryMessageQueue::~SharedMemoryMessageQueue ( )
override

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

Documentation des fonctions membres

◆ _getDestinationSubQueue()

SharedMemoryMessageQueue::SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getDestinationSubQueue ( const MP::PointToPointMessageInfo & message)
private

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

◆ _getNextRequestId()

Int64 Arcane::MessagePassing::SharedMemoryMessageQueue::_getNextRequestId ( )
inlineprivate

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

◆ _getSourceSubQueue()

SharedMemoryMessageQueue::SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getSourceSubQueue ( const MP::PointToPointMessageInfo & message)
private

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

◆ _getSubQueue()

SubQueue * Arcane::MessagePassing::SharedMemoryMessageQueue::_getSubQueue ( MessageRank rank)
inlineprivate

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

◆ _request()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::_request ( SharedMemoryMessageRequest * tmr)
private

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

◆ addReceive()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::addReceive ( const PointToPointMessageInfo & message,
ReceiveBufferInfo buf )
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ addSend()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::addSend ( const PointToPointMessageInfo & message,
SendBufferInfo buf )
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ init()

void Arcane::MessagePassing::SharedMemoryMessageQueue::init ( Int32 nb_thread)
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ legacyProbe()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::legacyProbe ( const PointToPointMessageInfo & message)
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ probe()

auto Arcane::MessagePassing::SharedMemoryMessageQueue::probe ( const PointToPointMessageInfo & message)
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ setTraceMng()

void Arcane::MessagePassing::SharedMemoryMessageQueue::setTraceMng ( Int32 rank,
ITraceMng * tm )
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ waitAll()

void Arcane::MessagePassing::SharedMemoryMessageQueue::waitAll ( ArrayView< Request > requests)
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

◆ waitSome()

void Arcane::MessagePassing::SharedMemoryMessageQueue::waitSome ( Int32 rank,
ArrayView< Request > requests,
ArrayView< bool > requests_done,
bool is_non_blockign )
overridevirtual

Implémente Arcane::MessagePassing::ISharedMemoryMessageQueue.

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

Documentation des données membres

◆ m_atomic_request_id

std::atomic<Int64> Arcane::MessagePassing::SharedMemoryMessageQueue::m_atomic_request_id
private

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

◆ m_nb_thread

Int32 Arcane::MessagePassing::SharedMemoryMessageQueue::m_nb_thread = 0
private

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

◆ m_sub_queues

UniqueArray<SubQueue*> Arcane::MessagePassing::SharedMemoryMessageQueue::m_sub_queues
private

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

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