Basic particle exchanger (uses blocking reduction). More...

#include <arcane/mesh/BasicParticleExchanger.h>

Inheritance diagram for Arcane::mesh::BasicParticleExchanger:

Collaboration diagram for Arcane::mesh::BasicParticleExchanger:

Public Member Functions
	BasicParticleExchanger (const ServiceBuildInfo &sbi)
void	build () override
	Build-level construction of the service.
void	initialize (IItemFamily *item_family) override
	Initializes the exchanger for the item_family item_family.
void	beginNewExchange (Integer nb_particle) override
	Starts a new particle exchange.
IItemFamily *	itemFamily () override
	Associated family.
bool	exchangeItems (Integer nb_particle_finish_exchange, Int32ConstArrayView local_ids, Int32ConstArrayView sub_domains_to_send, ItemGroup item_group, IFunctor *functor) override
	Exchanges particles between sub-domains.
bool	exchangeItems (Integer nb_particle_finish_exchange, Int32ConstArrayView local_ids, Int32ConstArrayView sub_domains_to_send, Int32Array new_particle_local_ids, IFunctor functor) override
	Exchanges particles between sub-domains.
void	sendItems (Integer nb_particle_finish_exchange, Int32ConstArrayView local_ids, Int32ConstArrayView sub_domains_to_send) override
bool	waitMessages (Integer nb_pending_particles, Int32Array new_particle_local_ids, IFunctor functor) override
void	addNewParticles (Integer nb_particle) override
	Adds nb_particle to the current exchange.
void	setVerboseLevel (Integer level) override
	Sets the verbosity level (0 for no messages).
Integer	verboseLevel () const override
	Verbosity level.
IAsyncParticleExchanger *	asyncParticleExchanger () override
	Asynchronism management (returns nullptr if functionality is not available).
void	reset ()
Public Member Functions inherited from Arcane::ArcaneBasicParticleExchangerObject
	ArcaneBasicParticleExchangerObject (const Arcane::ServiceBuildInfo &sbi)
	Constructeur.
virtual	~ArcaneBasicParticleExchangerObject ()
	Destructeur.
CaseOptionsBasicParticleExchanger *	options () const
	Options du jeu de données du service.
Public Member Functions inherited from Arcane::BasicService
	~BasicService () override
	Releases resources.
virtual ISubDomain *	subDomain ()
Public Member Functions inherited from Arcane::AbstractService
	~AbstractService () override
	Destructor.
IServiceInfo *	serviceInfo () const override
	Access to service information. See IServiceInfo for details.
IBase *	serviceParent () const override
	Access to the base interface of main Arcane objects.
IService *	serviceInterface () override
	Returns the low-level IService interface of the service.
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::IService
virtual	~IService ()
	Releases resources.
Public Member Functions inherited from Arcane::MeshAccessor
	MeshAccessor (ISubDomain *sd)
	MeshAccessor (IMesh *mesh)
	MeshAccessor (const MeshHandle &mesh_handle)
Integer	nbCell () const
	Returns the number of cells in the mesh.
Integer	nbFace () const
	Returns the number of faces in the mesh.
Integer	nbEdge () const
	Returns the number of edges in the mesh.
Integer	nbNode () const
	Returns the number of nodes in the mesh.
VariableNodeReal3 &	nodesCoordinates () const
	Returns the coordinates of the mesh nodes.
NodeGroup	allNodes () const
	Returns the group containing all nodes.
EdgeGroup	allEdges () const
	Returns the group containing all edges.
FaceGroup	allFaces () const
	Returns the group containing all faces.
CellGroup	allCells () const
	Returns the group containing all cells.
FaceGroup	outerFaces () const
	Returns the group containing all boundary faces.
NodeGroup	ownNodes () const
	Returns the group containing all nodes specific to this domain.
CellGroup	ownCells () const
	Returns the group containing all cells specific to this domain.
FaceGroup	ownFaces () const
	Group containing all faces specific to this domain.
EdgeGroup	ownEdges () const
	Group containing all edges specific to this domain.
IMesh *	mesh () const
const MeshHandle &	meshHandle () const
Public Member Functions inherited from Arcane::CommonVariables
	CommonVariables (IModule *c)
	Constructs the references of the common variables for the module c.
	CommonVariables (IVariableMng *variable_mng)
	Constructs the references of the common variables for the manager variable_mng.
	CommonVariables (ISubDomain *sd)
	Constructs the references of the common variables for the subdomain sd.
virtual	~CommonVariables ()
	Releases resources.
Int32	globalIteration () const
	Current iteration number.
Real	globalTime () const
	Current time.
Real	globalOldTime () const
	Previous current time.
Real	globalFinalTime () const
	Final time of the simulation.
Real	globalDeltaT () const
	Current Delta T.
Real	globalCPUTime () const
	CPU time used (in seconds).
Real	globalOldCPUTime () const
	Previous CPU time used (in seconds).
Real	globalElapsedTime () const
	Clock time (elapsed) used (in seconds).
Real	globalOldElapsedTime () const
	Previous clock time (elapsed) used (in seconds).
Public Member Functions inherited from Arcane::IParticleExchanger
virtual	~IParticleExchanger ()=default
	Releases resources.

Private Member Functions
void	_clearMessages ()
void	_serializeMessage (ISerializeMessage *sm, Int32ConstArrayView acc_ids, Int64Array &items_to_send_uid, Int64Array &items_to_send_cells_uid)
void	_deserializeMessage (ISerializeMessage message, Int64Array &items_to_create_unique_id, Int64Array &items_to_create_cells_unique_id, Int32Array &items_to_create_local_id, Int32Array &items_to_create_cells_local_id, ItemGroup item_group, Int32Array new_particle_local_ids)
void	_addItemsToSend (Int32ConstArrayView local_ids, Int32ConstArrayView sub_domains_to_send, Int32ConstArrayView communicating_sub_domains, UniqueArray< SharedArray< Int32 > > &ids_to_send)
void	_sendPendingMessages ()
void	_generateSendItems (Int32ConstArrayView local_ids, Int32ConstArrayView sub_domains_to_send)
void	_checkInitialized ()
bool	_waitMessages (Integer nb_pending_particles, ItemGroup item_group, Int32Array new_particle_local_ids, IFunctor functor)
void	_waitMessages (ItemGroup item_group, Int32Array new_particle_local_ids, IFunctor functor)

Private Attributes
IItemFamily *	m_item_family = nullptr
IParallelMng *	m_parallel_mng = nullptr
UniqueArray< ISerializeMessage * >	m_accumulate_infos
Int32	m_rank = A_NULL_RANK
Timer *	m_timer = nullptr
	Timer.
Real	m_total_time_functor = 0.0
Real	m_total_time_waiting = 0.0
VariableList	m_variables_to_exchange
	List of variables to exchange.
UniqueArray< ISerializeMessage * >	m_pending_messages
	List of messages pending sending.
UniqueArray< ISerializeMessage * >	m_waiting_messages
	List of messages sent but currently being processed.
Ref< ISerializeMessageList >	m_message_list
Int64	m_nb_total_particle_finish_exchange = 0
bool	m_exchange_finished = true
Integer	m_nb_loop = 0
bool	m_print_info = false
Int64	m_last_nb_to_exchange = 0
Integer	m_current_nb_reduce = 0
Integer	m_last_nb_reduce = 0
Int64	m_nb_particle_send = 0
Int32	m_verbose_level = 1
Int32	m_debug_exchange_items_level = 0
Int64	m_serialize_id = 1
	Message number. Useful for debugging.
Int32	m_max_nb_message_without_reduce = 15
bool	m_support_shmem_variables = false

Friends
class	AsyncParticleExchanger

Additional Inherited Members
Static Public Member Functions inherited from Arcane::ArcaneBasicParticleExchangerObject
template<typename ServiceClassType>
static void	fillServiceInfo (Arcane::ServiceInfo *si)
Public Attributes inherited from Arcane::CommonVariables
VariableScalarInt32	m_global_iteration
	Current iteration.
VariableScalarReal	m_global_time
	Current time.
VariableScalarReal	m_global_deltat
	Global Delta T.
VariableScalarReal	m_global_old_time
	Time previous to the current time.
VariableScalarReal	m_global_old_deltat
	Delta T at the time previous to the global time.
VariableScalarReal	m_global_final_time
	Final time of the case.
VariableScalarReal	m_global_old_cpu_time
	Previous CPU time used (in seconds).
VariableScalarReal	m_global_cpu_time
	CPU time used (in seconds).
VariableScalarReal	m_global_old_elapsed_time
	Previous clock time used (in seconds).
VariableScalarReal	m_global_elapsed_time
	Clock time used (in seconds).
Protected Member Functions inherited from Arcane::BasicService
	BasicService (const ServiceBuildInfo &)
Protected Member Functions inherited from Arcane::AbstractService
	AbstractService (const ServiceBuildInfo &)
	Constructor from a ServiceBuildInfo.
Protected Member Functions inherited from Arcane::TraceAccessor
void	_setLocalVerboseLevel (Int32 v)
Int32	_localVerboseLevel () const
Protected Member Functions inherited from Arcane::IService
	IService ()
	Constructor.

Detailed Description

Basic particle exchanger (uses blocking reduction).

Definition at line 62 of file BasicParticleExchanger.h.

Constructor & Destructor Documentation

◆ BasicParticleExchanger()

Arcane::mesh::BasicParticleExchanger::BasicParticleExchanger ( const ServiceBuildInfo & sbi )

explicit

Definition at line 37 of file BasicParticleExchanger.cc.

◆ ~BasicParticleExchanger()

Arcane::mesh::BasicParticleExchanger::~BasicParticleExchanger ( )

override

Definition at line 46 of file BasicParticleExchanger.cc.

Member Function Documentation

◆ _addItemsToSend()

void Arcane::mesh::BasicParticleExchanger::_addItemsToSend	(	Int32ConstArrayView	local_ids,
		Int32ConstArrayView	sub_domains_to_send,
		Int32ConstArrayView	communicating_sub_domains,
		UniqueArray< SharedArray< Int32 > > &	ids_to_send )

private

Definition at line 274 of file BasicParticleExchanger.cc.

◆ _checkInitialized()

void Arcane::mesh::BasicParticleExchanger::_checkInitialized ( )

private

Definition at line 635 of file BasicParticleExchanger.cc.

◆ _clearMessages()

void Arcane::mesh::BasicParticleExchanger::_clearMessages ( )

private

Definition at line 82 of file BasicParticleExchanger.cc.

◆ _deserializeMessage()

void Arcane::mesh::BasicParticleExchanger::_deserializeMessage	(	ISerializeMessage *	message,
		Int64Array &	items_to_create_unique_id,
		Int64Array &	items_to_create_cells_unique_id,
		Int32Array &	items_to_create_local_id,
		Int32Array &	items_to_create_cells_local_id,
		ItemGroup	item_group,
		Int32Array *	new_particle_local_ids )

private

Definition at line 540 of file BasicParticleExchanger.cc.

◆ _generateSendItems()

void Arcane::mesh::BasicParticleExchanger::_generateSendItems	(	Int32ConstArrayView	local_ids,
		Int32ConstArrayView	sub_domains_to_send )

private

Definition at line 200 of file BasicParticleExchanger.cc.

◆ _sendPendingMessages()

void Arcane::mesh::BasicParticleExchanger::_sendPendingMessages ( )

private

Definition at line 445 of file BasicParticleExchanger.cc.

◆ _serializeMessage()

void Arcane::mesh::BasicParticleExchanger::_serializeMessage	(	ISerializeMessage *	sm,
		Int32ConstArrayView	acc_ids,
		Int64Array &	items_to_send_uid,
		Int64Array &	items_to_send_cells_uid )

private

Definition at line 469 of file BasicParticleExchanger.cc.

◆ _waitMessages() [1/2]

bool Arcane::mesh::BasicParticleExchanger::_waitMessages	(	Integer	nb_pending_particles,
		ItemGroup	item_group,
		Int32Array *	new_particle_local_ids,
		IFunctor *	functor )

private

Definition at line 341 of file BasicParticleExchanger.cc.

◆ _waitMessages() [2/2]

void Arcane::mesh::BasicParticleExchanger::_waitMessages	(	ItemGroup	item_group,
		Int32Array *	new_particle_local_ids,
		IFunctor *	functor )

private

Definition at line 384 of file BasicParticleExchanger.cc.

◆ addNewParticles()

void Arcane::mesh::BasicParticleExchanger::addNewParticles ( Integer nb_particle )

overridevirtual

Adds nb_particle to the current exchange.

This method allows indicating that new particles will participate in the exchange, for example following their creation.

Implements Arcane::IParticleExchanger.

Definition at line 625 of file BasicParticleExchanger.cc.

◆ asyncParticleExchanger()

IAsyncParticleExchanger * Arcane::mesh::BasicParticleExchanger::asyncParticleExchanger ( )

inlineoverridevirtual

Asynchronism management (returns nullptr if functionality is not available).

Implements Arcane::IParticleExchanger.

Definition at line 99 of file BasicParticleExchanger.h.

◆ beginNewExchange()

void Arcane::mesh::BasicParticleExchanger::beginNewExchange ( Integer nb_particle )

overridevirtual

Starts a new particle exchange.

nb_particle is the number of particles in the sub-domain that will take part in a potential exchange.

This method is collective and must be called by all sub-domains.

Implements Arcane::IParticleExchanger.

Definition at line 93 of file BasicParticleExchanger.cc.

References Arcane::IParallelMng::computeMinMaxSum(), Arcane::platform::getCurrentDateTime(), Arcane::TraceAccessor::info(), m_max_nb_message_without_reduce, m_variables_to_exchange, and Arcane::ArcaneBasicParticleExchangerObject::options().

Here is the call graph for this function:

◆ build()

void Arcane::mesh::BasicParticleExchanger::build ( void )

inlineoverridevirtual

Build-level construction of the service.

This method is called right after the constructor.

Reimplemented from Arcane::AbstractService.

Definition at line 74 of file BasicParticleExchanger.h.

◆ exchangeItems() [1/2]

bool Arcane::mesh::BasicParticleExchanger::exchangeItems	(	Integer	nb_particle_finish_exchange,
		Int32ConstArrayView	local_ids,
		Int32ConstArrayView	ranks_to_send,
		Int32Array *	new_particle_local_ids,
		IFunctor *	wait_functor )

overridevirtual

Exchanges particles between sub-domains.

This operation sends the particles from the item_family item_family whose local indices are given by the list local_ids to the sub-domains specified by sub_domains_to_send, and receives from these same sub-domains those that this sub-domain owns. The sent particles are deleted from the item_family item_family and the received ones are added.

Variables associated with the item_family item_family are transferred at the same time as the particles.

This operation is collective and blocking.

If new_particle_local_ids is not null, it will contain in return the array of local indices of the new entities.

If wait_functor is not null, the functor is called during the sending and receiving of messages. It is then possible to perform operations. Operations must not use particles, nor variables on the particles of the exchanged family.

Return values

a true if all exchange phases are finished

Return values

a false otherwise

Todo: improve the documentation

Implements Arcane::IParticleExchanger.

Definition at line 181 of file BasicParticleExchanger.cc.

References Arcane::Array< T >::clear(), and sendItems().

Here is the call graph for this function:

◆ exchangeItems() [2/2]

bool Arcane::mesh::BasicParticleExchanger::exchangeItems	(	Integer	nb_particle_finish_exchange,
		Int32ConstArrayView	local_ids,
		Int32ConstArrayView	sub_domains_to_send,
		ItemGroup	item_group,
		IFunctor *	wait_functor )

overridevirtual

Exchanges particles between sub-domains.

This operation sends the particles from the item_family item_family whose local indices are given by the list local_ids to the sub-domains specified by sub_domains_to_send, and receives from these same sub-domains those that this sub-domain owns. The sent particles are deleted from the item_family item_family and the received ones are added.

Variables associated with the item_family item_family are transferred at the same time as the particles.

This operation is collective and blocking.

If item_group is not null, it will contain the list of new entities in return.

If wait_functor is not null, the functor is called during the sending and receiving of messages. It is then possible to perform operations. Operations must not use particles, nor variables on the particles of the exchanged family.

Return values

a true if all exchange phases are finished

Return values

a false otherwise

Todo: improve the documentation

Implements Arcane::IParticleExchanger.

Definition at line 162 of file BasicParticleExchanger.cc.

References Arcane::ItemGroup::clear(), Arcane::ItemGroup::null(), and sendItems().

Here is the call graph for this function:

◆ initialize()

void Arcane::mesh::BasicParticleExchanger::initialize ( IItemFamily * item_family )

overridevirtual

Initializes the exchanger for the item_family item_family.

Implements Arcane::IParticleExchanger.

Definition at line 59 of file BasicParticleExchanger.cc.

References ARCANE_CHECK_POINTER, Arcane::IParallelMng::commRank(), Arcane::TraceAccessor::info(), m_max_nb_message_without_reduce, m_timer, Arcane::IItemFamily::mesh(), Arcane::IItemFamily::name(), Arcane::ArcaneBasicParticleExchangerObject::options(), Arcane::IMesh::parallelMng(), and Arcane::Timer::TimerReal.

Here is the call graph for this function:

◆ itemFamily()

IItemFamily * Arcane::mesh::BasicParticleExchanger::itemFamily ( )

inlineoverridevirtual

Associated family.

Implements Arcane::IParticleExchanger.

Definition at line 80 of file BasicParticleExchanger.h.

◆ reset()

void Arcane::mesh::BasicParticleExchanger::reset ( )

Definition at line 614 of file BasicParticleExchanger.cc.

◆ sendItems()

void Arcane::mesh::BasicParticleExchanger::sendItems	(	Integer	nb_particle_finish_exchange,
		Int32ConstArrayView	local_ids,
		Int32ConstArrayView	sub_domains_to_send )

overridevirtual

Implements Arcane::IParticleExchanger.

Definition at line 142 of file BasicParticleExchanger.cc.

References Arcane::TraceAccessor::info(), m_timer, and Arcane::ConstArrayView< T >::size().

Referenced by exchangeItems(), and exchangeItems().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ setVerboseLevel()

void Arcane::mesh::BasicParticleExchanger::setVerboseLevel ( Integer level )

inlineoverridevirtual

Sets the verbosity level (0 for no messages).

Implements Arcane::IParticleExchanger.

Definition at line 97 of file BasicParticleExchanger.h.

◆ verboseLevel()

Integer Arcane::mesh::BasicParticleExchanger::verboseLevel ( ) const

inlineoverridevirtual

Verbosity level.

Implements Arcane::IParticleExchanger.

Definition at line 98 of file BasicParticleExchanger.h.

◆ waitMessages()

bool Arcane::mesh::BasicParticleExchanger::waitMessages	(	Integer	nb_pending_particle,
		Int32Array *	new_particle_local_ids,
		IFunctor *	functor )

overridevirtual

Implements Arcane::IParticleExchanger.

Definition at line 332 of file BasicParticleExchanger.cc.

◆ AsyncParticleExchanger

friend class AsyncParticleExchanger

friend

Definition at line 65 of file BasicParticleExchanger.h.

Member Data Documentation

◆ m_accumulate_infos

UniqueArray<ISerializeMessage*> Arcane::mesh::BasicParticleExchanger::m_accumulate_infos

private

Definition at line 109 of file BasicParticleExchanger.h.

◆ m_current_nb_reduce

Integer Arcane::mesh::BasicParticleExchanger::m_current_nb_reduce = 0

private

Definition at line 135 of file BasicParticleExchanger.h.

◆ m_debug_exchange_items_level

Int32 Arcane::mesh::BasicParticleExchanger::m_debug_exchange_items_level = 0

private

Definition at line 140 of file BasicParticleExchanger.h.

◆ m_exchange_finished

bool Arcane::mesh::BasicParticleExchanger::m_exchange_finished = true

private

Definition at line 131 of file BasicParticleExchanger.h.

◆ m_item_family

IItemFamily* Arcane::mesh::BasicParticleExchanger::m_item_family = nullptr

private

Definition at line 107 of file BasicParticleExchanger.h.

◆ m_last_nb_reduce

Integer Arcane::mesh::BasicParticleExchanger::m_last_nb_reduce = 0

private

Definition at line 136 of file BasicParticleExchanger.h.

◆ m_last_nb_to_exchange

Int64 Arcane::mesh::BasicParticleExchanger::m_last_nb_to_exchange = 0

private

Definition at line 134 of file BasicParticleExchanger.h.

◆ m_max_nb_message_without_reduce

Int32 Arcane::mesh::BasicParticleExchanger::m_max_nb_message_without_reduce = 15

private

Maximum number of messages to send before performing the reduction on the number of particles. If (-1) then no limit.

Definition at line 148 of file BasicParticleExchanger.h.

Referenced by beginNewExchange(), and initialize().

◆ m_message_list

Ref<ISerializeMessageList> Arcane::mesh::BasicParticleExchanger::m_message_list

private

Definition at line 127 of file BasicParticleExchanger.h.

◆ m_nb_loop

Integer Arcane::mesh::BasicParticleExchanger::m_nb_loop = 0

private

Definition at line 132 of file BasicParticleExchanger.h.

◆ m_nb_particle_send

Int64 Arcane::mesh::BasicParticleExchanger::m_nb_particle_send = 0

private

Definition at line 137 of file BasicParticleExchanger.h.

◆ m_nb_total_particle_finish_exchange

Int64 Arcane::mesh::BasicParticleExchanger::m_nb_total_particle_finish_exchange = 0

private

Definition at line 129 of file BasicParticleExchanger.h.

◆ m_parallel_mng

IParallelMng* Arcane::mesh::BasicParticleExchanger::m_parallel_mng = nullptr

private

Definition at line 108 of file BasicParticleExchanger.h.

◆ m_pending_messages

UniqueArray<ISerializeMessage*> Arcane::mesh::BasicParticleExchanger::m_pending_messages

private

List of messages pending sending.

Definition at line 122 of file BasicParticleExchanger.h.

◆ m_print_info

bool Arcane::mesh::BasicParticleExchanger::m_print_info = false

private

Definition at line 133 of file BasicParticleExchanger.h.

◆ m_rank

Int32 Arcane::mesh::BasicParticleExchanger::m_rank = A_NULL_RANK

private

Definition at line 111 of file BasicParticleExchanger.h.

◆ m_serialize_id

Int64 Arcane::mesh::BasicParticleExchanger::m_serialize_id = 1

private

Message number. Useful for debugging.

Definition at line 142 of file BasicParticleExchanger.h.

◆ m_support_shmem_variables

bool Arcane::mesh::BasicParticleExchanger::m_support_shmem_variables = false

private

Definition at line 150 of file BasicParticleExchanger.h.

◆ m_timer

Timer* Arcane::mesh::BasicParticleExchanger::m_timer = nullptr

private

Timer.

Definition at line 114 of file BasicParticleExchanger.h.

Referenced by initialize(), and sendItems().

◆ m_total_time_functor

Real Arcane::mesh::BasicParticleExchanger::m_total_time_functor = 0.0

private

Definition at line 115 of file BasicParticleExchanger.h.

◆ m_total_time_waiting

Real Arcane::mesh::BasicParticleExchanger::m_total_time_waiting = 0.0

private

Definition at line 116 of file BasicParticleExchanger.h.

◆ m_variables_to_exchange

VariableList Arcane::mesh::BasicParticleExchanger::m_variables_to_exchange

private

List of variables to exchange.

Definition at line 119 of file BasicParticleExchanger.h.

Referenced by beginNewExchange().

◆ m_verbose_level

Int32 Arcane::mesh::BasicParticleExchanger::m_verbose_level = 1

private

Definition at line 139 of file BasicParticleExchanger.h.

◆ m_waiting_messages

UniqueArray<ISerializeMessage*> Arcane::mesh::BasicParticleExchanger::m_waiting_messages

private

List of messages sent but currently being processed.

Definition at line 125 of file BasicParticleExchanger.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ BasicParticleExchanger()

◆ ~BasicParticleExchanger()

Member Function Documentation

◆ _addItemsToSend()

◆ _checkInitialized()

◆ _clearMessages()

◆ _deserializeMessage()

◆ _generateSendItems()

◆ _sendPendingMessages()

◆ _serializeMessage()

◆ _waitMessages() [1/2]

◆ _waitMessages() [2/2]

◆ addNewParticles()

◆ asyncParticleExchanger()

◆ beginNewExchange()

◆ build()

◆ exchangeItems() [1/2]

◆ exchangeItems() [2/2]

◆ initialize()

◆ itemFamily()

◆ reset()

◆ sendItems()

◆ setVerboseLevel()

◆ verboseLevel()

◆ waitMessages()

Friends And Related Symbol Documentation

◆ AsyncParticleExchanger

Member Data Documentation

◆ m_accumulate_infos

◆ m_current_nb_reduce

◆ m_debug_exchange_items_level

◆ m_exchange_finished

◆ m_item_family

◆ m_last_nb_reduce

◆ m_last_nb_to_exchange

◆ m_max_nb_message_without_reduce

◆ m_message_list

◆ m_nb_loop

◆ m_nb_particle_send

◆ m_nb_total_particle_finish_exchange

◆ m_parallel_mng

◆ m_pending_messages

◆ m_print_info

◆ m_rank

◆ m_serialize_id

◆ m_support_shmem_variables

◆ m_timer

◆ m_total_time_functor

◆ m_total_time_waiting

◆ m_variables_to_exchange

◆ m_verbose_level

◆ m_waiting_messages