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 |
![]() | |
typedef Parallel::Request | Request |
typedef Parallel::eReduceType | 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) |
Membres hérités additionnels | |
![]() | |
using | Request = Parallel::Request |
using | PointToPointMessageInfo = Parallel::PointToPointMessageInfo |
using | MessageRank = Parallel::MessageRank |
using | MessageTag = Parallel::MessageTag |
![]() | |
SharedMemoryParallelDispatchBase (ITraceMng *tm, SharedMemoryParallelMng *parallel_mng, ISharedMemoryMessageQueue *message_queue, ArrayView< SharedMemoryParallelDispatchBase * > all_dispatchs_base) | |
void | _genericAllToAll (ConstMemoryView send_buf, MutableMemoryView recv_buf, Int32 count) |
void | _genericAllGather (ConstMemoryView send_buf, MutableMemoryView recv_buf) |
void | _genericAllGatherVariable (ConstMemoryView send_buf, IResizableArray *recv_buf) |
void | _genericAllToAllVariable (ConstMemoryView send_buf, Span< const Int32 > send_count, Span< const Int32 > send_index, MutableMemoryView recv_buf, Span< const Int32 > recv_count, Span< const Int32 > recv_index) |
void | _genericScatterVariable (ConstMemoryView send_buf, MutableMemoryView recv_buf, Int32 root) |
Request | _genericSend (ConstMemoryView send_buffer, const PointToPointMessageInfo &message2) |
Request | _genericReceive (MutableMemoryView recv_buffer, const PointToPointMessageInfo &message2) |
void | _genericBroadcast (MutableMemoryView send_buf, Int32 rank) |
void | _collectiveBarrier () |
![]() | |
void | _setLocalVerboseLevel (Int32 v) |
Int32 | _localVerboseLevel () const |
![]() | |
ConstMemoryView | m_const_view |
MutableMemoryView | m_recv_view |
ConstMemoryView | m_send_view |
SharedMemoryParallelMng * | m_parallel_mng = nullptr |
Int32 | m_rank = -1 |
Int32 | m_nb_rank = 0 |
ISharedMemoryMessageQueue * | m_message_queue = nullptr |
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 273 du fichier SharedMemoryParallelDispatch.cc.
|
override |
Définition à la ligne 288 du fichier SharedMemoryParallelDispatch.cc.
|
private |
Définition à la ligne 619 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 438 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 462 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 672 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 587 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 494 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 429 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 405 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 391 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 297 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Réimplémentée à partir de Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 786 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 447 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 472 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 693 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 681 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 727 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 739 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 704 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 715 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 557 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 537 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 566 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 767 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 756 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 485 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 528 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 548 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::MessagePassing::ITypeDispatcher< Type >.
Définition à la ligne 517 du fichier SharedMemoryParallelDispatch.cc.
|
overridevirtual |
Implémente Arcane::IParallelDispatchT< Type >.
Définition à la ligne 575 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 776 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.