Interface des messages pour le type Type. Plus de détails...
#include <arcane/parallel/thread/SharedMemoryParallelDispatch.h>
Classes | |
class | MinMaxSumInfo |
class | ReduceInfo |
class | ResizableArrayRef |
Types publics | |
using | Request = Parallel::Request |
using | PointToPointMessageInfo = Parallel::PointToPointMessageInfo |
using | MessageRank = Parallel::MessageRank |
using | MessageTag = Parallel::MessageTag |
typedef Parallel::eReduceType | eReduceType |
![]() | |
using | Request = Parallel::Request |
using | eReduceType = Parallel::eReduceType |
using | PointToPointMessageInfo = Parallel::PointToPointMessageInfo |
Fonctions membres publiques | |
SharedMemoryParallelDispatch (ITraceMng *tm, SharedMemoryParallelMng *parallel_mng, ISharedMemoryMessageQueue *message_queue, impl::ShareMemoryDispatcherContainer< Type > &containers) | |
void | finalize () override |
void | broadcast (Span< Type > send_buf, Int32 sub_domain) override |
void | allGather (Span< const Type > send_buf, Span< Type > recv_buf) override |
void | allGatherVariable (Span< const Type > send_buf, Array< Type > &recv_buf) override |
void | gather (Span< const Type > send_buf, Span< Type > recv_buf, Int32 rank) override |
void | gatherVariable (Span< const Type > send_buf, Array< Type > &recv_buf, Int32 rank) override |
void | scatterVariable (Span< const Type > send_buf, Span< Type > recv_buf, Int32 root) override |
void | allReduce (eReduceType op, Span< Type > send_buf) override |
void | allToAll (Span< const Type > send_buf, Span< Type > recv_buf, Int32 count) override |
void | allToAllVariable (Span< const Type > send_buf, ConstArrayView< Int32 > send_count, ConstArrayView< Int32 > send_index, Span< Type > recv_buf, ConstArrayView< Int32 > recv_count, ConstArrayView< Int32 > recv_index) override |
Request | send (Span< const Type > send_buffer, Int32 proc, bool is_blocked) override |
Request | send (Span< const Type > send_buffer, const PointToPointMessageInfo &message) override |
Request | receive (Span< Type > recv_buffer, Int32 rank, bool is_blocked) override |
Request | receive (Span< Type > recv_buffer, const PointToPointMessageInfo &message) override |
Request | nonBlockingAllReduce (eReduceType op, Span< const Type > send_buf, Span< Type > recv_buf) override |
Request | nonBlockingAllGather (Span< const Type > send_buf, Span< Type > recv_buf) override |
Request | nonBlockingBroadcast (Span< Type > send_buf, Int32 rank) override |
Request | nonBlockingGather (Span< const Type > send_buf, Span< Type > recv_buf, Int32 rank) override |
Request | nonBlockingAllToAll (Span< const Type > send_buf, Span< Type > recv_buf, Int32 count) override |
Request | nonBlockingAllToAllVariable (Span< const Type > send_buf, ConstArrayView< Int32 > send_count, ConstArrayView< Int32 > send_index, Span< Type > recv_buf, ConstArrayView< Int32 > recv_count, ConstArrayView< Int32 > recv_index) override |
Request | gather (Arccore::MessagePassing::GatherMessageInfo< Type > &) override |
void | broadcast (ArrayView< Type > send_buf, Integer sub_domain) override |
void | allGather (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf) override |
void | allGatherVariable (ConstArrayView< Type > send_buf, Array< Type > &recv_buf) override |
void | gather (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf, Integer rank) override |
void | gatherVariable (ConstArrayView< Type > send_buf, Array< Type > &recv_buf, Integer rank) override |
void | scatterVariable (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf, Integer root) override |
void | allToAll (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf, Integer count) override |
void | allToAllVariable (ConstArrayView< Type > send_buf, Int32ConstArrayView send_count, Int32ConstArrayView send_index, ArrayView< Type > recv_buf, Int32ConstArrayView recv_count, Int32ConstArrayView recv_index) override |
Request | send (ConstArrayView< Type > send_buffer, Integer proc, bool is_blocked) override |
Request | recv (ArrayView< Type > recv_buffer, Int32 rank, bool is_blocked) override |
void | allReduce (eReduceType op, ArrayView< Type > send_buf) override |
void | send (ConstArrayView< Type > send_buffer, Integer proc) override |
void | recv (ArrayView< Type > recv_buffer, Integer proc) override |
void | sendRecv (ConstArrayView< Type > send_buffer, ArrayView< Type > recv_buffer, Integer proc) override |
Type | allReduce (eReduceType op, Type send_buf) override |
Type | scan (eReduceType op, Type send_buf) override |
void | scan (eReduceType op, ArrayView< Type > send_buf) override |
void | computeMinMaxSum (Type val, Type &min_val, Type &max_val, Type &sum_val, Int32 &min_rank, Int32 &max_rank) override |
void | computeMinMaxSum (ConstArrayView< Type > values, ArrayView< Type > min_values, ArrayView< Type > max_values, ArrayView< Type > sum_values, ArrayView< Int32 > min_ranks, ArrayView< Int32 > max_ranks) override |
ITypeDispatcher< Type > * | toArccoreDispatcher () override |
void | waitAll () |
![]() | |
TraceAccessor (ITraceMng *m) | |
Construit un accesseur via le gestionnaire de trace m. | |
TraceAccessor (const TraceAccessor &rhs) | |
Constructeur par recopie. | |
TraceAccessor & | operator= (const TraceAccessor &rhs) |
Opérateur de recopie. | |
virtual | ~TraceAccessor () |
Libère les ressources. | |
ITraceMng * | traceMng () const |
Gestionnaire de trace. | |
TraceMessage | info () const |
Flot pour un message d'information. | |
TraceMessage | pinfo () const |
Flot pour un message d'information en parallèle. | |
TraceMessage | info (char category) const |
Flot pour un message d'information d'une catégorie donnée. | |
TraceMessage | pinfo (char category) const |
Flot pour un message d'information parallèle d'une catégorie donnée. | |
TraceMessage | info (bool v) const |
Flot pour un message d'information. | |
TraceMessage | warning () const |
Flot pour un message d'avertissement. | |
TraceMessage | pwarning () const |
TraceMessage | error () const |
Flot pour un message d'erreur. | |
TraceMessage | perror () const |
TraceMessage | log () const |
Flot pour un message de log. | |
TraceMessage | plog () const |
Flot pour un message de log. | |
TraceMessage | logdate () const |
Flot pour un message de log précédé de la date. | |
TraceMessage | fatal () const |
Flot pour un message d'erreur fatale. | |
TraceMessage | pfatal () const |
Flot pour un message d'erreur fatale en parallèle. | |
TraceMessageDbg | debug (Trace::eDebugLevel=Trace::Medium) const |
Flot pour un message de debug. | |
Trace::eDebugLevel | configDbgLevel () const |
Niveau debug du fichier de configuration. | |
TraceMessage | info (Int32 verbose_level) const |
Flot pour un message d'information d'un niveau donné | |
TraceMessage | linfo () const |
Flot pour un message d'information avec le niveau d'information local à cette instance. | |
TraceMessage | linfo (Int32 relative_level) const |
Flot pour un message d'information avec le niveau d'information local à cette instance. | |
void | fatalMessage (const StandaloneTraceMessage &o) const |
![]() | |
void | addReference () |
void | removeReference () |
void | _internalAddReference () |
bool | _internalRemoveReference () |
Attributs publics | |
ArrayView< SharedMemoryParallelDispatch< Type > * > | m_all_dispatchs |
ReduceInfo | m_reduce_infos |
Types privés | |
using | BaseClass = SharedMemoryParallelDispatchBase |
Fonctions membres privées | |
void | _allReduceOrScan (eReduceType op, Span< Type > send_buf, bool is_scan) |
Interface des messages pour le type Type.
Définition à la ligne 217 du fichier SharedMemoryParallelDispatch.h.
|
private |
Définition à la ligne 222 du fichier SharedMemoryParallelDispatch.h.
typedef Parallel::eReduceType Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::eReduceType |
Définition à la ligne 270 du fichier SharedMemoryParallelDispatch.h.
using Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::MessageRank = Parallel::MessageRank |
Définition à la ligne 268 du fichier SharedMemoryParallelDispatch.h.
using Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::MessageTag = Parallel::MessageTag |
Définition à la ligne 269 du fichier SharedMemoryParallelDispatch.h.
using Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::PointToPointMessageInfo = Parallel::PointToPointMessageInfo |
Définition à la ligne 267 du fichier SharedMemoryParallelDispatch.h.
using Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::Request = Parallel::Request |
Définition à la ligne 266 du fichier SharedMemoryParallelDispatch.h.
Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::SharedMemoryParallelDispatch | ( | ITraceMng * | tm, |
SharedMemoryParallelMng * | parallel_mng, | ||
ISharedMemoryMessageQueue * | message_queue, | ||
impl::ShareMemoryDispatcherContainer< Type > & | containers ) |
Définition à la ligne 271 du fichier SharedMemoryParallelDispatch.cc.
|
override |
Définition à la ligne 286 du fichier SharedMemoryParallelDispatch.cc.
|
private |
Définition à la ligne 617 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 313 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 436 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 317 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 460 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 352 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 670 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 585 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 333 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 492 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 337 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 309 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 427 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 403 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 389 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 295 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Réimplémentée à partir de Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 784 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 321 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 445 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 325 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 470 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 691 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 679 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 725 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 737 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 702 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 713 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 555 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 535 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 348 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 564 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 765 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 754 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 329 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 483 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 526 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 344 du fichier SharedMemoryParallelDispatch.h.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 546 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 515 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 573 du fichier SharedMemoryParallelDispatch.cc.
|
inlineoverridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 372 du fichier SharedMemoryParallelDispatch.h.
void Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::waitAll | ( | ) |
Définition à la ligne 774 du fichier SharedMemoryParallelDispatch.cc.
ArrayView<SharedMemoryParallelDispatch<Type>*> Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::m_all_dispatchs |
Définition à la ligne 378 du fichier SharedMemoryParallelDispatch.h.
ReduceInfo Arcane::MessagePassing::SharedMemoryParallelDispatch< Type >::m_reduce_infos |
Définition à la ligne 383 du fichier SharedMemoryParallelDispatch.h.