#include <limits.h>
#include <stdbool.h>
#include <stdlib.h>
#include "core/core.h"
#include "xt/xt_core.h"
#include "xt/xt_redist.h"
#include "xt/xt_mpi.h"
#include "xt/xt_request.h"
#include "xt/xt_sort.h"
#include "core/ppm_xfuncs.h"
#include "xt_redist_internal.h"

Include dependency graph for xt_redist.c:

Functions
Xt_redist	xt_redist_copy (Xt_redist redist)

void	xt_redist_delete (Xt_redist redist)

void	xt_redist_s_exchange (Xt_redist redist, int num_arrays, const void src_data, void dst_data)

void	xt_redist_a_exchange (Xt_redist redist, int num_arrays, const void src_data, void dst_data, Xt_request *request)

void	xt_redist_s_exchange1 (Xt_redist redist, const void src_data, void dst_data)

void	xt_redist_a_exchange1 (Xt_redist redist, const void src_data, void dst_data, Xt_request *request)

int	xt_redist_get_num_send_msg (Xt_redist redist)

int	xt_redist_get_num_recv_msg (Xt_redist redist)

MPI_Datatype	xt_redist_get_send_MPI_Datatype (Xt_redist redist, int rank)

MPI_Datatype	xt_redist_get_recv_MPI_Datatype (Xt_redist redist, int rank)

MPI_Datatype	xt_redist_get_MPI_Datatype (Xt_redist redist, int rank, enum xt_msg_direction direction)

MPI_Comm	xt_redist_get_MPI_Comm (Xt_redist redist)

int	xt_redist_get_msg_ranks (Xt_redist redist, enum xt_msg_direction direction, int restrict ranks)

void	xt_redist_msgs_strided_copy (size_t n, const struct Xt_redist_msg restrict src, size_t src_stride, struct Xt_redist_msg restrict dst, size_t dst_stride, MPI_Comm comm)

void	xt_redist_msgs_strided_destruct (size_t n, struct Xt_redist_msg *msgs, MPI_Comm comm, size_t ofs_stride)

void	xt_redist_check_comms (Xt_redist *redists, int num_redists, MPI_Comm comm)

static size_t	xt_ranks_uniq_count (size_t num_rank_sets, const size_t restrict num_ranks, const int const ranks[num_rank_sets])

unsigned	xt_redist_agg_msg_count (size_t num_redists, enum xt_msg_direction direction, const Xt_redist redists[num_redists], size_t num_ranks[num_redists], int *restrict ranks[num_redists])

MPI_Datatype	xt_create_compound_datatype (size_t count, const MPI_Aint displacements[count], const MPI_Datatype datatypes[count], const int block_lengths[count], MPI_Comm comm)

Detailed Description

Copyright: Copyright (C) 2016 Jörg Behrens behre.nosp@m.ns@d.nosp@m.krz.d.nosp@m.e Moritz Hanke hanke.nosp@m.@dkr.nosp@m.z.de Thomas Jahns jahns.nosp@m.@dkr.nosp@m.z.de

Author: Jörg Behrens behre.nosp@m.ns@d.nosp@m.krz.d.nosp@m.e Moritz Hanke hanke.nosp@m.@dkr.nosp@m.z.de Thomas Jahns jahns.nosp@m.@dkr.nosp@m.z.de

Definition in file xt_redist.c.

Function Documentation

◆ xt_create_compound_datatype()

MPI_Datatype xt_create_compound_datatype	(	size_t	count,
		const MPI_Aint	displacements[count],
		const MPI_Datatype	datatypes[count],
		const int	block_lengths[count],
		MPI_Comm	comm
	)

Generates a new MPI derived datatype from a number of MPI derived datatypes.

Parameters

[in]	count	number of datatypes
[in]	displacements	byte displacement of each block
[in]	datatypes	type of elements in each block
[in]	block_lengths	number of elements in each block
[in]	comm	communicator

Returns: new MPI derived datatype

Definition at line 239 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_ranks_uniq_count()

static size_t xt_ranks_uniq_count	(	size_t	num_rank_sets,
		const size_t *restrict	num_ranks,
		const int *const	ranks[num_rank_sets]
	)

static

Definition at line 188 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_a_exchange()

void xt_redist_a_exchange	(	Xt_redist	redist,
		int	num_arrays,
		const void **	src_data,
		void **	dst_data,
		Xt_request *	request
	)

asynchronous redistribution of data

Parameters

[in]	redist	redistribution structure
[in]	num_arrays	number of base addresses in src_data and dst_data
[in]	src_data	array containing the addresses of the first elements of the input data
[in,out]	dst_data	array containing the addresses of the first elements of the output data
[out]	request	pointer to a request object that can be used to complete an asynchronous exchange

Remarks: The above implies that NULL or any other invalid pointer must not be used in either src_data or dst_data.

See Also: correct_addresses

Definition at line 79 of file xt_redist.c.

◆ xt_redist_a_exchange1()

void xt_redist_a_exchange1	(	Xt_redist	redist,
		const void *	src_data,
		void *	dst_data,
		Xt_request *	request
	)

asynchronous redistribution of data - single array case

Parameters

[in]	redist	redistribution structure
[in]	src_data	address of the first element of the input data
[in,out]	dst_data	address of the first element of the output data
[out]	request	pointer to a request object that can be used to complete an asynchronous exchange

Remarks: The above implies that NULL or any other invalid pointer must not be used in either src_data or dst_data.

Definition at line 91 of file xt_redist.c.

◆ xt_redist_agg_msg_count()

unsigned xt_redist_agg_msg_count	(	size_t	num_redists,
		enum xt_msg_direction	direction,
		const Xt_redist	redists[num_redists],
		size_t	num_ranks[num_redists],
		int *restrict	ranks[num_redists]
	)

Determines number of processes that receive data from/send data to the local processes by any redists provided to this routine.

Parameters

[in]	num_redists	number of redistribution objects
[in]	direction	specifices whether the of outgoing or incoming message is to be determined
[in]	redists	redistribution objects
[out]	num_ranks	number of incoming/outgoing messages per redist
[out]	ranks	ranks of communicator partners for each redist

Returns: Number of processes that receive data from/send data to the local process.

Remarks: the user needs to ensure that rank arrays are big enough to hold all ranks

Definition at line 217 of file xt_redist.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ xt_redist_check_comms()

void xt_redist_check_comms	(	Xt_redist *	redists,
		int	num_redists,
		MPI_Comm	comm
	)

Checks whether a number of redists are based on the same communicator. This is a requirement in case these redists are to be combined into a redist collection.

Parameters

[in]	redists	redistribution objects to be checked
[in]	num_redists	number of redistribution objects is redists
[in]	comm	reference communicator

Remarks: In case this check fails, it will abort the program.

Definition at line 169 of file xt_redist.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ xt_redist_copy()

Xt_redist xt_redist_copy ( Xt_redist redist )

redist copy constructor

Parameters

[in,out] redist redistribution structure

Definition at line 63 of file xt_redist.c.

◆ xt_redist_delete()

void xt_redist_delete ( Xt_redist redist )

destructor

Parameters

[in,out] redist redistribution structure

Definition at line 68 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_get_MPI_Comm()

MPI_Comm xt_redist_get_MPI_Comm ( Xt_redist redist )

returns a MPI communicator, which the redistribution is based on

Parameters

[in] redist redistribution structure

Returns: MPI communicator, which the redistribution is based on

Definition at line 123 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_get_MPI_Datatype()

MPI_Datatype xt_redist_get_MPI_Datatype	(	Xt_redist	redist,
		int	rank,
		enum xt_msg_direction	direction
	)

Gets a MPI derived datatype that encodes all data sent/received in a specified message.

Parameters

[in]	redist	redistribution object
[in]	rank	MPI rank of the communicator partner
[in]	direction	specifices whether the datatype for an outgoing or incoming message is requested

Returns: Datatype for the specified message. The return value is MPI_DATATYPE_NULL, if no data for the specified message.

Definition at line 117 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_get_msg_ranks()

int xt_redist_get_msg_ranks	(	Xt_redist	redist,
		enum xt_msg_direction	direction,
		int restrict	ranks
	)

Gets the ranks of all processes that receive data from/send data to the local process in the exchanges defined by the redist.

Parameters

[in]	redist	redistribution object
[in]	direction	specifices whether ranks for the outgoing or incoming messages are requested
[out]	ranks	ranks for all outgoing/incoming messages

Returns: number of outgoing/incoming message

Remarks: the user needs to ensure that array ranks is big enough to hold all ranks

Definition at line 128 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_get_num_recv_msg()

int xt_redist_get_num_recv_msg ( Xt_redist redist )

gets the number of messages received by the local process in an exchange operation

Parameters

[in] redist redistribution structure

Returns: number of messages received in the exchange operation

Definition at line 102 of file xt_redist.c.

◆ xt_redist_get_num_send_msg()

int xt_redist_get_num_send_msg ( Xt_redist redist )

gets the number of messages send from the local process in an exchange operation

Parameters

[in] redist redistribution structure

Returns: number of messages sent in the exchange operation

Definition at line 97 of file xt_redist.c.

◆ xt_redist_get_recv_MPI_Datatype()

MPI_Datatype xt_redist_get_recv_MPI_Datatype	(	Xt_redist	redist,
		int	rank
	)

gets a copy of the MPI_Datatype used for the data of the recv operation with the given rank

Parameters

[in]	redist	redistribution structure
[in]	rank	MPI rank

Returns: MPI_Datatype for the data of the recv operation with the given rank

Remarks: returns MPI_DATATYPE_NULL if there is no recv operation with the given rank

Definition at line 112 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_get_send_MPI_Datatype()

MPI_Datatype xt_redist_get_send_MPI_Datatype	(	Xt_redist	redist,
		int	rank
	)

gets a copy of the MPI_Datatype used for the data of the send operation with the given rank

Parameters

[in]	redist	redistribution structure
[in]	rank	MPI rank

Returns: MPI_Datatype for the data of the send operation with the given rank

Remarks: returns MPI_DATATYPE_NULL if there is no send operation with the given rank

Definition at line 107 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_msgs_strided_copy()

void xt_redist_msgs_strided_copy	(	size_t	n,
		const struct Xt_redist_msg *restrict	src,
		size_t	src_stride,
		struct Xt_redist_msg *restrict	dst,
		size_t	dst_stride,
		MPI_Comm	comm
	)

Definition at line 136 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_msgs_strided_destruct()

void xt_redist_msgs_strided_destruct	(	size_t	n,
		struct Xt_redist_msg *	msgs,
		MPI_Comm	comm,
		size_t	ofs_stride
	)

Definition at line 156 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_s_exchange()

void xt_redist_s_exchange	(	Xt_redist	redist,
		int	num_arrays,
		const void **	src_data,
		void **	dst_data
	)

synchronous redistribution of data

Parameters

[in]	redist	redistribution structure
[in]	num_arrays	number of base addresses in src_data and dst_data
[in]	src_data	array containing the addresses of the first elements of the input data
[in,out]	dst_data	array containing the addresses of the first elements of the output data

Remarks: The above implies that NULL or any other invalid pointer must not be used in either src_data or dst_data.

See Also: correct_addresses

Definition at line 73 of file xt_redist.c.

Here is the caller graph for this function:

◆ xt_redist_s_exchange1()

void xt_redist_s_exchange1	(	Xt_redist	redist,
		const void *	src_data,
		void *	dst_data
	)

synchronous redistribution of data - single array case

Parameters

[in]	redist	redistribution structure
[in]	src_data	address of the first element of the input data
[in,out]	dst_data	address of the first element of the output data

Remarks: The above implies that NULL or any other invalid pointer must not be used in either src_data or dst_data.

Definition at line 86 of file xt_redist.c.

Functions

Detailed Description

Function Documentation

◆ xt_create_compound_datatype()

◆ xt_ranks_uniq_count()

◆ xt_redist_a_exchange()

◆ xt_redist_a_exchange1()

◆ xt_redist_agg_msg_count()

◆ xt_redist_check_comms()

◆ xt_redist_copy()

◆ xt_redist_delete()

◆ xt_redist_get_MPI_Comm()

◆ xt_redist_get_MPI_Datatype()

◆ xt_redist_get_msg_ranks()

◆ xt_redist_get_num_recv_msg()

◆ xt_redist_get_num_send_msg()

◆ xt_redist_get_recv_MPI_Datatype()

◆ xt_redist_get_send_MPI_Datatype()

◆ xt_redist_msgs_strided_copy()

◆ xt_redist_msgs_strided_destruct()

◆ xt_redist_s_exchange()

◆ xt_redist_s_exchange1()