Interface des messages pour le type Type. Plus de détails...

#include <arcane/parallel/mpithread/HybridParallelDispatch.h>

Graphe d'héritage de Arcane::MessagePassing::HybridParallelDispatch< Type >:

Graphe de collaboration de Arcane::MessagePassing::HybridParallelDispatch< Type >:

Classes
class	AllToAllVariableInfo

class	MinMaxSumInfo

class	ReduceInfo

Types publics
using	AllDispatchView = ArrayView< HybridParallelDispatch< Type > * >

Types publics hérités de Arcane::IParallelDispatchT< Type >
typedef Parallel::Request	Request

typedef Parallel::eReduceType	eReduceType

using	PointToPointMessageInfo = Parallel::PointToPointMessageInfo

Fonctions membres publiques
	HybridParallelDispatch (ITraceMng tm, HybridParallelMng parallel_mng, HybridMessageQueue message_queue, ArrayView< HybridParallelDispatch< Type > > all_dispatchs)

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, Integer proc, 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

Int32	globalRank () const

Fonctions membres publiques hérités de Arccore::TraceAccessor
	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

Fonctions membres publiques hérités de Arcane::IParallelDispatchT< Type >
virtual void	broadcast (ArrayView< Type > send_buf, Int32 rank)=0

virtual void	gather (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf, Int32 rank)=0

virtual void	gatherVariable (ConstArrayView< Type > send_buf, Array< Type > &recv_buf, Int32 rank)=0

virtual void	scatterVariable (ConstArrayView< Type > send_buf, ArrayView< Type > recv_buf, Int32 root)=0

virtual Request	send (ConstArrayView< Type > send_buffer, Int32 rank, bool is_blocked)=0

virtual Request	recv (ArrayView< Type > recv_buffer, Int32 rank, bool is_blocked)=0

virtual void	send (ConstArrayView< Type > send_buffer, Int32 rank)=0

virtual void	recv (ArrayView< Type > recv_buffer, Int32 rank)=0

virtual void	sendRecv (ConstArrayView< Type > send_buffer, ArrayView< Type > recv_buffer, Int32 proc)=0

Fonctions membres publiques hérités de Arccore::ReferenceCounterImpl
void	addReference ()

void	removeReference ()

void	_internalAddReference ()

bool	_internalRemoveReference ()

Fonctions membres publiques hérités de Arccore::MessagePassing::ITypeDispatcher< Type >
virtual void	broadcast (Span< Type > send_buf, Int32 rank)=0

virtual void	gather (Span< const Type > send_buf, Span< Type > recv_buf, Int32 rank)=0

virtual void	gatherVariable (Span< const Type > send_buf, Array< Type > &recv_buf, Int32 rank)=0

virtual void	scatterVariable (Span< const Type > send_buf, Span< Type > recv_buf, Int32 root)=0

virtual void	allToAll (Span< const Type > send_buf, Span< Type > recv_buf, Int32 count)=0

virtual 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)=0

virtual Request	send (Span< const Type > send_buffer, Int32 rank, bool is_blocked)=0

virtual Request	receive (Span< Type > recv_buffer, Int32 rank, bool is_blocked)=0

virtual Request	nonBlockingBroadcast (Span< Type > send_buf, Int32 rank)=0

virtual Request	nonBlockingGather (Span< const Type > send_buf, Span< Type > recv_buf, Int32 rank)=0

virtual Request	nonBlockingAllToAll (Span< const Type > send_buf, Span< Type > recv_buf, Int32 count)=0

virtual 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)=0

Attributs publics
AllDispatchView	m_all_dispatchs

ReduceInfo	m_reduce_infos

MinMaxSumInfo	m_min_max_sum_infos

Fonctions membres privées
	ARCCORE_INTERNAL_DEFINE_REFERENCE_COUNTED_INCLASS_METHODS ()

void	_collectiveBarrier ()

void	_allReduceOrScan (eReduceType op, Span< Type > send_buf, bool is_scan)

void	_applyReduceOperator (eReduceType op, Span< Type > result, AllDispatchView dispatch_view, Int32 first_rank, Int32 last_rank)

Attributs privés
HybridParallelMng *	m_parallel_mng = nullptr

Int32	m_local_rank = A_NULL_RANK

Int32	m_local_nb_rank = 0

Int32	m_global_rank = A_NULL_RANK

Int32	m_global_nb_rank = 0

Int32	m_mpi_rank = A_NULL_RANK

Int32	m_mpi_nb_rank = 0

Span< Type >	m_broadcast_view

Span< const Type >	m_const_view

Span< Type >	m_recv_view

Span< const Type >	m_send_view

AllToAllVariableInfo	m_alltoallv_infos

HybridMessageQueue *	m_message_queue = nullptr

MpiParallelDispatchT< Type > *	m_mpi_dispatcher = nullptr

Membres hérités additionnels
Fonctions membres protégées hérités de Arccore::TraceAccessor
void	_setLocalVerboseLevel (Int32 v)

Int32	_localVerboseLevel () const

Description détaillée

template<class Type>
class Arcane::MessagePassing::HybridParallelDispatch< Type >

Interface des messages pour le type Type.

Définition à la ligne 100 du fichier HybridParallelDispatch.h.

Documentation des définitions de type membres

◆ AllDispatchView

template<class Type >

using Arcane::MessagePassing::HybridParallelDispatch< Type >::AllDispatchView = ArrayView<HybridParallelDispatch<Type>*>

Définition à la ligne 233 du fichier HybridParallelDispatch.h.

Documentation des constructeurs et destructeur

◆ HybridParallelDispatch()

template<class Type >

Arcane::MessagePassing::HybridParallelDispatch< Type >::HybridParallelDispatch	(	ITraceMng *	tm,
		HybridParallelMng *	parallel_mng,
		HybridMessageQueue *	message_queue,
		ArrayView< HybridParallelDispatch< Type > * >	all_dispatchs
	)

Définition à la ligne 55 du fichier HybridParallelDispatch.cc.

◆ ~HybridParallelDispatch()

template<class Type >

Arcane::MessagePassing::HybridParallelDispatch< Type >::~HybridParallelDispatch ( )

override

Définition à la ligne 90 du fichier HybridParallelDispatch.cc.

Documentation des fonctions membres

◆ _allReduceOrScan()

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::_allReduceOrScan	(	eReduceType	op,
		Span< Type >	send_buf,
		bool	is_scan
	)

private

Définition à la ligne 846 du fichier HybridParallelDispatch.cc.

◆ _applyReduceOperator()

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::_applyReduceOperator	(	eReduceType	op,
		Span< Type >	result,
		AllDispatchView	dispatch_view,
		Int32	first_rank,
		Int32	last_rank
	)

private

Définition à la ligne 816 du fichier HybridParallelDispatch.cc.

◆ _collectiveBarrier()

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::_collectiveBarrier ( )

private

Définition à la ligne 1047 du fichier HybridParallelDispatch.cc.

◆ allGather() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allGather	(	ConstArrayView< Type >	send_buf,
		ArrayView< Type >	recv_buf
	)

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 180 du fichier HybridParallelDispatch.h.

◆ allGather() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allGather	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf
	)

overridevirtual

Implémente Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 320 du fichier HybridParallelDispatch.cc.

◆ allGatherVariable() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allGatherVariable	(	ConstArrayView< Type >	send_buf,
		Array< Type > &	recv_buf
	)

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 182 du fichier HybridParallelDispatch.h.

◆ allGatherVariable() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allGatherVariable	(	Span< const Type >	send_buf,
		Array< Type > &	recv_buf
	)

overridevirtual

Implémente Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 371 du fichier HybridParallelDispatch.cc.

◆ allReduce() [1/3]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allReduce	(	eReduceType	op,
		ArrayView< Type >	send_buf
	)

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 201 du fichier HybridParallelDispatch.h.

◆ allReduce() [2/3]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allReduce	(	eReduceType	op,
		Span< Type >	send_buf
	)

overridevirtual

Implémente Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 935 du fichier HybridParallelDispatch.cc.

◆ allReduce() [3/3]

template<class Type >

Type Arcane::MessagePassing::HybridParallelDispatch< Type >::allReduce	(	eReduceType	op,
		Type	send_buf
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 778 du fichier HybridParallelDispatch.cc.

◆ allToAll() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allToAll	(	ConstArrayView< Type >	send_buf,
		ArrayView< Type >	recv_buf,
		Integer	count
	)

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 190 du fichier HybridParallelDispatch.h.

◆ allToAll() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allToAll	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf,
		Int32	count
	)

override

Définition à la ligne 470 du fichier HybridParallelDispatch.cc.

◆ allToAllVariable() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::allToAllVariable	(	ConstArrayView< Type >	send_buf,
		Int32ConstArrayView	send_count,
		Int32ConstArrayView	send_index,
		ArrayView< Type >	recv_buf,
		Int32ConstArrayView	recv_count,
		Int32ConstArrayView	recv_index
	)

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 192 du fichier HybridParallelDispatch.h.

◆ allToAllVariable() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::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

Définition à la ligne 490 du fichier HybridParallelDispatch.cc.

◆ broadcast() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::broadcast	(	ArrayView< Type >	send_buf,
		Integer	sub_domain
	)

inlineoverride

Définition à la ligne 178 du fichier HybridParallelDispatch.h.

◆ broadcast() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::broadcast	(	Span< Type >	send_buf,
		Int32	sub_domain
	)

override

Définition à la ligne 286 du fichier HybridParallelDispatch.cc.

◆ computeMinMaxSum() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::computeMinMaxSum	(	ConstArrayView< Type >	values,
		ArrayView< Type >	min_values,
		ArrayView< Type >	max_values,
		ArrayView< Type >	sum_values,
		ArrayView< Int32 >	min_ranks,
		ArrayView< Int32 >	max_ranks
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 238 du fichier HybridParallelDispatch.cc.

◆ computeMinMaxSum() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::computeMinMaxSum	(	Type	val,
		Type &	min_val,
		Type &	max_val,
		Type &	sum_val,
		Int32 &	min_rank,
		Int32 &	max_rank
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 199 du fichier HybridParallelDispatch.cc.

◆ finalize()

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::finalize ( )

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 99 du fichier HybridParallelDispatch.cc.

◆ gather() [1/3]

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::gather ( Arccore::MessagePassing::GatherMessageInfo< Type > & )

overridevirtual

Réimplémentée à partir de Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 1038 du fichier HybridParallelDispatch.cc.

◆ gather() [2/3]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::gather	(	ConstArrayView< Type >	send_buf,
		ArrayView< Type >	recv_buf,
		Integer	rank
	)

inlineoverride

Définition à la ligne 184 du fichier HybridParallelDispatch.h.

◆ gather() [3/3]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::gather	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf,
		Int32	rank
	)

override

Définition à la ligne 356 du fichier HybridParallelDispatch.cc.

◆ gatherVariable() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::gatherVariable	(	ConstArrayView< Type >	send_buf,
		Array< Type > &	recv_buf,
		Integer	rank
	)

inlineoverride

Définition à la ligne 186 du fichier HybridParallelDispatch.h.

◆ gatherVariable() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::gatherVariable	(	Span< const Type >	send_buf,
		Array< Type > &	recv_buf,
		Int32	rank
	)

override

Définition à la ligne 405 du fichier HybridParallelDispatch.cc.

◆ globalRank()

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::globalRank ( ) const

inline

Définition à la ligne 234 du fichier HybridParallelDispatch.h.

◆ nonBlockingAllGather()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::nonBlockingAllGather	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf
	)

overridevirtual

Implémente Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 955 du fichier HybridParallelDispatch.cc.

◆ nonBlockingAllReduce()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::nonBlockingAllReduce	(	eReduceType	op,
		Span< const Type >	send_buf,
		Span< Type >	recv_buf
	)

overridevirtual

Implémente Arccore::MessagePassing::ITypeDispatcher< Type >.

Définition à la ligne 944 du fichier HybridParallelDispatch.cc.

◆ nonBlockingAllToAll()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::nonBlockingAllToAll	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf,
		Int32	count
	)

override

Définition à la ligne 989 du fichier HybridParallelDispatch.cc.

◆ nonBlockingAllToAllVariable()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::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

Définition à la ligne 1001 du fichier HybridParallelDispatch.cc.

◆ nonBlockingBroadcast()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::nonBlockingBroadcast	(	Span< Type >	send_buf,
		Int32	rank
	)

override

Définition à la ligne 966 du fichier HybridParallelDispatch.cc.

◆ nonBlockingGather()

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::nonBlockingGather	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf,
		Int32	rank
	)

override

Définition à la ligne 977 du fichier HybridParallelDispatch.cc.

◆ receive() [1/2]

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::receive	(	Span< Type >	recv_buffer,
		const PointToPointMessageInfo &	message
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 740 du fichier HybridParallelDispatch.cc.

◆ receive() [2/2]

template<class Type >

Parallel::Request Arcane::MessagePassing::HybridParallelDispatch< Type >::receive	(	Span< Type >	recv_buffer,
		Int32	rank,
		bool	is_blocked
	)

override

Définition à la ligne 712 du fichier HybridParallelDispatch.cc.

◆ recv() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::recv	(	ArrayView< Type >	recv_buffer,
		Integer	proc
	)

override

Définition à la ligne 757 du fichier HybridParallelDispatch.cc.

◆ recv() [2/2]

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::recv	(	ArrayView< Type >	recv_buffer,
		Integer	proc,
		bool	is_blocked
	)

inlineoverride

Définition à la ligne 199 du fichier HybridParallelDispatch.h.

◆ scan() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::scan	(	eReduceType	op,
		ArrayView< Type >	send_buf
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 1029 du fichier HybridParallelDispatch.cc.

◆ scan() [2/2]

template<class Type >

Type Arcane::MessagePassing::HybridParallelDispatch< Type >::scan	(	eReduceType	op,
		Type	send_buf
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 1018 du fichier HybridParallelDispatch.cc.

◆ scatterVariable() [1/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::scatterVariable	(	ConstArrayView< Type >	send_buf,
		ArrayView< Type >	recv_buf,
		Integer	root
	)

inlineoverride

Définition à la ligne 188 du fichier HybridParallelDispatch.h.

◆ scatterVariable() [2/2]

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::scatterVariable	(	Span< const Type >	send_buf,
		Span< Type >	recv_buf,
		Int32	root
	)

override

Définition à la ligne 419 du fichier HybridParallelDispatch.cc.

◆ send() [1/3]

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::send	(	ConstArrayView< Type >	send_buffer,
		Integer	proc,
		bool	is_blocked
	)

inlineoverride

Définition à la ligne 197 du fichier HybridParallelDispatch.h.

◆ send() [2/3]

template<class Type >

Request Arcane::MessagePassing::HybridParallelDispatch< Type >::send	(	Span< const Type >	send_buffer,
		const PointToPointMessageInfo &	message
	)

overridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 723 du fichier HybridParallelDispatch.cc.

◆ send() [3/3]

template<class Type >

auto Arcane::MessagePassing::HybridParallelDispatch< Type >::send	(	Span< const Type >	send_buffer,
		Int32	proc,
		bool	is_blocked
	)

override

Définition à la ligne 692 du fichier HybridParallelDispatch.cc.

◆ sendRecv()

template<class Type >

void Arcane::MessagePassing::HybridParallelDispatch< Type >::sendRecv	(	ConstArrayView< Type >	send_buffer,
		ArrayView< Type >	recv_buffer,
		Integer	proc
	)

override

Définition à la ligne 766 du fichier HybridParallelDispatch.cc.

◆ toArccoreDispatcher()

template<class Type >

ITypeDispatcher< Type > * Arcane::MessagePassing::HybridParallelDispatch< Type >::toArccoreDispatcher ( )

inlineoverridevirtual

Implémente Arcane::IParallelDispatchT< Type >.

Définition à la ligne 219 du fichier HybridParallelDispatch.h.

Documentation des données membres

◆ m_all_dispatchs

template<class Type >

AllDispatchView Arcane::MessagePassing::HybridParallelDispatch< Type >::m_all_dispatchs

Définition à la ligne 235 du fichier HybridParallelDispatch.h.

◆ m_alltoallv_infos

template<class Type >

AllToAllVariableInfo Arcane::MessagePassing::HybridParallelDispatch< Type >::m_alltoallv_infos

private

Définition à la ligne 243 du fichier HybridParallelDispatch.h.

◆ m_broadcast_view

template<class Type >

Span<Type> Arcane::MessagePassing::HybridParallelDispatch< Type >::m_broadcast_view

private

Définition à la ligne 239 du fichier HybridParallelDispatch.h.

◆ m_const_view

template<class Type >

Span<const Type> Arcane::MessagePassing::HybridParallelDispatch< Type >::m_const_view

private

Définition à la ligne 240 du fichier HybridParallelDispatch.h.

◆ m_global_nb_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_global_nb_rank = 0

private

Définition à la ligne 227 du fichier HybridParallelDispatch.h.

◆ m_global_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_global_rank = A_NULL_RANK

private

Définition à la ligne 226 du fichier HybridParallelDispatch.h.

◆ m_local_nb_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_local_nb_rank = 0

private

Définition à la ligne 225 du fichier HybridParallelDispatch.h.

◆ m_local_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_local_rank = A_NULL_RANK

private

Définition à la ligne 224 du fichier HybridParallelDispatch.h.

◆ m_message_queue

template<class Type >

HybridMessageQueue* Arcane::MessagePassing::HybridParallelDispatch< Type >::m_message_queue = nullptr

private

Définition à la ligne 252 du fichier HybridParallelDispatch.h.

◆ m_min_max_sum_infos

template<class Type >

MinMaxSumInfo Arcane::MessagePassing::HybridParallelDispatch< Type >::m_min_max_sum_infos

Définition à la ligne 248 du fichier HybridParallelDispatch.h.

◆ m_mpi_dispatcher

template<class Type >

MpiParallelDispatchT<Type>* Arcane::MessagePassing::HybridParallelDispatch< Type >::m_mpi_dispatcher = nullptr

private

Définition à la ligne 253 du fichier HybridParallelDispatch.h.

◆ m_mpi_nb_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_mpi_nb_rank = 0

private

Définition à la ligne 229 du fichier HybridParallelDispatch.h.

◆ m_mpi_rank

template<class Type >

Int32 Arcane::MessagePassing::HybridParallelDispatch< Type >::m_mpi_rank = A_NULL_RANK

private

Définition à la ligne 228 du fichier HybridParallelDispatch.h.

◆ m_parallel_mng

template<class Type >

HybridParallelMng* Arcane::MessagePassing::HybridParallelDispatch< Type >::m_parallel_mng = nullptr

private

Définition à la ligne 223 du fichier HybridParallelDispatch.h.

◆ m_recv_view

template<class Type >

Span<Type> Arcane::MessagePassing::HybridParallelDispatch< Type >::m_recv_view

private

Définition à la ligne 241 du fichier HybridParallelDispatch.h.

◆ m_reduce_infos

template<class Type >

ReduceInfo Arcane::MessagePassing::HybridParallelDispatch< Type >::m_reduce_infos

Définition à la ligne 247 du fichier HybridParallelDispatch.h.

◆ m_send_view

template<class Type >

Span<const Type> Arcane::MessagePassing::HybridParallelDispatch< Type >::m_send_view

private

Définition à la ligne 242 du fichier HybridParallelDispatch.h.

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

Classes

Types publics

Fonctions membres publiques

Attributs publics

Fonctions membres privées

Attributs privés

Membres hérités additionnels

Description détaillée

Documentation des définitions de type membres

◆ AllDispatchView

Documentation des constructeurs et destructeur

◆ HybridParallelDispatch()

◆ ~HybridParallelDispatch()

Documentation des fonctions membres

◆ _allReduceOrScan()

◆ _applyReduceOperator()

◆ _collectiveBarrier()

◆ allGather() [1/2]

◆ allGather() [2/2]

◆ allGatherVariable() [1/2]

◆ allGatherVariable() [2/2]

◆ allReduce() [1/3]

◆ allReduce() [2/3]

◆ allReduce() [3/3]

◆ allToAll() [1/2]

◆ allToAll() [2/2]

◆ allToAllVariable() [1/2]

◆ allToAllVariable() [2/2]

◆ broadcast() [1/2]

◆ broadcast() [2/2]

◆ computeMinMaxSum() [1/2]

◆ computeMinMaxSum() [2/2]

◆ finalize()

◆ gather() [1/3]

◆ gather() [2/3]

◆ gather() [3/3]

◆ gatherVariable() [1/2]

◆ gatherVariable() [2/2]

◆ globalRank()

◆ nonBlockingAllGather()

◆ nonBlockingAllReduce()

◆ nonBlockingAllToAll()

◆ nonBlockingAllToAllVariable()

◆ nonBlockingBroadcast()

◆ nonBlockingGather()

◆ receive() [1/2]

◆ receive() [2/2]

◆ recv() [1/2]

◆ recv() [2/2]

◆ scan() [1/2]

◆ scan() [2/2]

◆ scatterVariable() [1/2]

◆ scatterVariable() [2/2]

◆ send() [1/3]

◆ send() [2/3]

◆ send() [3/3]

◆ sendRecv()

◆ toArccoreDispatcher()

Documentation des données membres

◆ m_all_dispatchs

◆ m_alltoallv_infos

◆ m_broadcast_view

◆ m_const_view

◆ m_global_nb_rank

◆ m_global_rank

◆ m_local_nb_rank

◆ m_local_rank

◆ m_message_queue

◆ m_min_max_sum_infos

◆ m_mpi_dispatcher

◆ m_mpi_nb_rank

◆ m_mpi_rank

◆ m_parallel_mng

◆ m_recv_view

◆ m_reduce_infos

◆ m_send_view