Message interface for type Type. More...

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

Inheritance diagram for Arcane::MessagePassing::HybridParallelDispatch< Type >:

Collaboration diagram for Arcane::MessagePassing::HybridParallelDispatch< Type >:

Classes
class	AllToAllVariableInfo
class	ReduceInfo
class	MinMaxSumInfo

Public Types
using	AllDispatchView = ArrayView<HybridParallelDispatch<Type>*>
Public Types inherited from Arcane::IParallelDispatchT< Type >
using	Request = Parallel::Request
using	eReduceType = Parallel::eReduceType
using	PointToPointMessageInfo = Parallel::PointToPointMessageInfo

Public Member Functions
	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
Public Member Functions inherited from Arcane::TraceAccessor
	TraceAccessor (ITraceMng *m)
	Constructs an accessor via the trace manager m.
	TraceAccessor (const TraceAccessor &rhs)
	Copy constructor.
TraceAccessor &	operator= (const TraceAccessor &rhs)
	Copy assignment operator.
virtual	~TraceAccessor ()
	Frees resources.
ITraceMng *	traceMng () const
	Trace manager.
TraceMessage	info () const
	Flow for an information message.
TraceMessage	pinfo () const
	Flow for a parallel information message.
TraceMessage	info (char category) const
	Flow for an information message of a given category.
TraceMessage	pinfo (char category) const
	Flow for a parallel information message of a given category.
TraceMessage	info (bool v) const
	Flow for an information message.
TraceMessage	warning () const
	Flow for a warning message.
TraceMessage	pwarning () const
TraceMessage	error () const
	Flow for an error message.
TraceMessage	perror () const
TraceMessage	log () const
	Flow for a log message.
TraceMessage	plog () const
	Flow for a log message.
TraceMessage	logdate () const
	Flow for a log message preceded by the date.
TraceMessage	fatal () const
	Flow for a fatal error message.
TraceMessage	pfatal () const
	Flow for a parallel fatal error message.
TraceMessageDbg	debug (Trace::eDebugLevel=Trace::Medium) const
	Flow for a debug message.
Trace::eDebugLevel	configDbgLevel () const
	Debug level of the configuration file.
TraceMessage	info (Int32 verbose_level) const
	Flow for an information message of a given level.
TraceMessage	linfo () const
	Flow for an information message with the local information level of this instance.
TraceMessage	linfo (Int32 relative_level) const
	Flow for an information message with the local information level of this instance.
void	fatalMessage (const StandaloneTraceMessage &o) const
Public Member Functions inherited from Arcane::ReferenceCounterImpl
void	addReference ()
void	removeReference ()
void	_internalAddReference ()
bool	_internalRemoveReference ()

Public Attributes
AllDispatchView	m_all_dispatchs
ReduceInfo	m_reduce_infos
MinMaxSumInfo	m_min_max_sum_infos

Private Member Functions
	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)

Private Attributes
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

Additional Inherited Members
Protected Member Functions inherited from Arcane::TraceAccessor
void	_setLocalVerboseLevel (Int32 v)
Int32	_localVerboseLevel () const

Detailed Description

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

Message interface for type Type.

Definition at line 108 of file HybridParallelDispatch.h.

Member Typedef Documentation

◆ AllDispatchView

template<class Type>

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

Definition at line 267 of file HybridParallelDispatch.h.

Constructor & Destructor Documentation

◆ HybridParallelDispatch()

template<class Type>

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

Definition at line 55 of file HybridParallelDispatch.cc.

◆ ~HybridParallelDispatch()

template<class Type>

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

override

Definition at line 90 of file HybridParallelDispatch.cc.

Member Function Documentation

◆ _allReduceOrScan()

template<class Type>

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

private

Definition at line 842 of file 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

Definition at line 812 of file HybridParallelDispatch.cc.

◆ _collectiveBarrier()

template<class Type>

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

private

Definition at line 1043 of file HybridParallelDispatch.cc.

◆ allGather() [1/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 194 of file HybridParallelDispatch.h.

◆ allGather() [2/2]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 323 of file HybridParallelDispatch.cc.

◆ allGatherVariable() [1/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 198 of file HybridParallelDispatch.h.

◆ allGatherVariable() [2/2]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 374 of file HybridParallelDispatch.cc.

◆ allReduce() [1/3]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 233 of file HybridParallelDispatch.h.

◆ allReduce() [2/3]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 931 of file HybridParallelDispatch.cc.

◆ allReduce() [3/3]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 774 of file 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

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 214 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 473 of file 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

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 218 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

◆ broadcast() [1/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 190 of file HybridParallelDispatch.h.

◆ broadcast() [2/2]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 289 of file 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

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 241 of file 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

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 202 of file HybridParallelDispatch.cc.

◆ finalize()

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 99 of file HybridParallelDispatch.cc.

◆ gather() [1/3]

template<class Type>

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

overridevirtual

Reimplemented from Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 1034 of file HybridParallelDispatch.cc.

◆ gather() [2/3]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 202 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 359 of file HybridParallelDispatch.cc.

◆ gatherVariable() [1/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 206 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 408 of file HybridParallelDispatch.cc.

◆ globalRank()

template<class Type>

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

inline

Definition at line 268 of file HybridParallelDispatch.h.

◆ nonBlockingAllGather()

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 951 of file HybridParallelDispatch.cc.

◆ nonBlockingAllReduce()

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 940 of file HybridParallelDispatch.cc.

◆ nonBlockingAllToAll()

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 985 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 997 of file HybridParallelDispatch.cc.

◆ nonBlockingBroadcast()

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 962 of file HybridParallelDispatch.cc.

◆ nonBlockingGather()

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 973 of file HybridParallelDispatch.cc.

◆ receive() [1/2]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 736 of file HybridParallelDispatch.cc.

◆ receive() [2/2]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 708 of file HybridParallelDispatch.cc.

◆ recv() [1/2]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 753 of file HybridParallelDispatch.cc.

◆ recv() [2/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 229 of file HybridParallelDispatch.h.

◆ scan() [1/2]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 1025 of file HybridParallelDispatch.cc.

◆ scan() [2/2]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 1014 of file HybridParallelDispatch.cc.

◆ scatterVariable() [1/2]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 210 of file 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 )

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 422 of file HybridParallelDispatch.cc.

◆ send() [1/4]

template<class Type>

void Arcane::MessagePassing::HybridParallelDispatch< Type >::send	(	ConstArrayView< Type >	send_buffer,
		Integer	proc )

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 699 of file HybridParallelDispatch.cc.

◆ send() [2/4]

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 225 of file HybridParallelDispatch.h.

◆ send() [3/4]

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 719 of file HybridParallelDispatch.cc.

◆ send() [4/4]

template<class Type>

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

overridevirtual

Implements Arcane::MessagePassing::ITypeDispatcher< Type >.

Definition at line 688 of file HybridParallelDispatch.cc.

◆ sendRecv()

template<class Type>

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

overridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 762 of file HybridParallelDispatch.cc.

◆ toArccoreDispatcher()

template<class Type>

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

inlineoverridevirtual

Implements Arcane::IParallelDispatchT< Type >.

Definition at line 253 of file HybridParallelDispatch.h.

Member Data Documentation

◆ m_all_dispatchs

template<class Type>

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

Definition at line 269 of file HybridParallelDispatch.h.

◆ m_alltoallv_infos

template<class Type>

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

private

Definition at line 277 of file HybridParallelDispatch.h.

◆ m_broadcast_view

template<class Type>

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

private

Definition at line 273 of file HybridParallelDispatch.h.

◆ m_const_view

template<class Type>

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

private

Definition at line 274 of file HybridParallelDispatch.h.

◆ m_global_nb_rank

template<class Type>

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

private

Definition at line 261 of file HybridParallelDispatch.h.

◆ m_global_rank

template<class Type>

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

private

Definition at line 260 of file HybridParallelDispatch.h.

◆ m_local_nb_rank

template<class Type>

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

private

Definition at line 259 of file HybridParallelDispatch.h.

◆ m_local_rank

template<class Type>

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

private

Definition at line 258 of file HybridParallelDispatch.h.

◆ m_message_queue

template<class Type>

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

private

Definition at line 286 of file HybridParallelDispatch.h.

◆ m_min_max_sum_infos

template<class Type>

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

Definition at line 282 of file HybridParallelDispatch.h.

◆ m_mpi_dispatcher

template<class Type>

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

private

Definition at line 287 of file HybridParallelDispatch.h.

◆ m_mpi_nb_rank

template<class Type>

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

private

Definition at line 263 of file HybridParallelDispatch.h.

◆ m_mpi_rank

template<class Type>

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

private

Definition at line 262 of file HybridParallelDispatch.h.

◆ m_parallel_mng

template<class Type>

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

private

Definition at line 257 of file HybridParallelDispatch.h.

◆ m_recv_view

template<class Type>

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

private

Definition at line 275 of file HybridParallelDispatch.h.

◆ m_reduce_infos

template<class Type>

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

Definition at line 281 of file HybridParallelDispatch.h.

◆ m_send_view

template<class Type>

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

private

Definition at line 276 of file HybridParallelDispatch.h.

The documentation for this class was generated from the following files:

Classes

Public Types

Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ AllDispatchView

Constructor & Destructor Documentation

◆ HybridParallelDispatch()

◆ ~HybridParallelDispatch()

Member Function Documentation

◆ _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/4]

◆ send() [2/4]

◆ send() [3/4]

◆ send() [4/4]

◆ sendRecv()

◆ toArccoreDispatcher()

Member Data Documentation

◆ 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