YetAnotherCoupler: src/core/yac_mpi.c File Reference

#include "config.h"
#include <assert.h>
#include <inttypes.h>
#include <limits.h>
#include <stdbool.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <mpi.h>
#include "yac_mpi_internal.h"
#include "geometry.h"
#include "ensure_array_size.h"
#include "ppm/core.h"

Include dependency graph for yac_mpi.c:

Go to the source code of this file.

Macros
#define	XSTR(s) STR(s)

#define	STR(s) #s

#define	USE_P2P_ALLTOALLV

#define	YAC_ALLTOALL_P2P_TYPE(NAME, TYPE, TYPE_SIZE, MPI_TYPE)

#define	OPENMPI_WORKAROUND

Functions
int	yac_mpi_is_initialised ()

void	yac_yaxt_init (MPI_Comm comm)

void	yac_yaxt_init_f2c (MPI_Fint comm)

static void	yac_yaxt_cleanup ()

void	yac_mpi_init ()

void	yac_mpi_cleanup ()

void	yac_mpi_finalize ()

void	yac_mpi_error (int error_code, MPI_Comm comm)

void	yac_alltoallv_p2p (void const send_buffer, size_t const sendcounts, size_t const sdispls, void recv_buffer, size_t const recvcounts, size_t const rdispls, size_t dt_size, MPI_Datatype dt, MPI_Comm comm)

void	yac_alltoallv_p2p_group (void const send_buffer, int const sendcounts, int const sdispls, void recv_buffer, int const recvcounts, int const rdispls, size_t dt_size, MPI_Datatype dt, struct yac_group_comm group_comm)

static int	nearest_power_of_two (int x)

void	yac_allreduce_sum_dble (double *buffer, int count, struct yac_group_comm group_comm)

static int	log2_ (int x)

void	yac_allgather_uint64 (const uint64_t sendbuf, uint64_t recvbuf, int count, struct yac_group_comm group_comm)

void	yac_bcast_group (void *buffer, int count, MPI_Datatype datatype, int root, struct yac_group_comm group_comm)

struct yac_group_comm	yac_group_comm_new (MPI_Comm comm)

void	yac_group_comm_delete (struct yac_group_comm group_comm)

int	yac_group_comm_get_rank (struct yac_group_comm group_comm)

int	yac_group_comm_get_size (struct yac_group_comm group_comm)

int	yac_group_comm_get_global_rank (struct yac_group_comm group_comm)

int	yac_group_comm_get_global_size (struct yac_group_comm group_comm)

void	yac_group_comm_split (struct yac_group_comm group_comm, int split_rank, struct yac_group_comm local_group_comm, struct yac_group_comm remote_group_comm)

MPI_Datatype	yac_get_bounding_circle_mpi_datatype (MPI_Comm comm)

MPI_Datatype	yac_create_resized (MPI_Datatype dt, size_t new_size, MPI_Comm comm)

void	yac_generate_alltoallv_args (int count, size_t const sendcounts, size_t recvcounts, size_t sdispls, size_t rdispls, MPI_Comm comm)

void	yac_get_comm_buffers (int count, size_t sendcounts, size_t recvcounts, size_t sdispls, size_t rdispls, MPI_Comm comm)

void	yac_free_comm_buffers (size_t sendcounts, size_t recvcounts, size_t sdispls, size_t rdispls)

Variables
static int	mpi_initialised_by_yac = 0

static int	yaxt_initialised_by_yac = 0

static int	init_count = 0

static int	yaxt_init_count = 0

static size_t *	comm_buffer = NULL

static size_t	comm_buffer_array_size = 0

static int	comm_buffer_in_use = 0

Macro Definition Documentation

◆ OPENMPI_WORKAROUND

#define OPENMPI_WORKAROUND

◆ STR

#define STR ( s ) #s

Definition at line 75 of file yac_mpi.c.

◆ USE_P2P_ALLTOALLV

#define USE_P2P_ALLTOALLV

◆ XSTR

#define XSTR ( s ) STR(s)

Definition at line 74 of file yac_mpi.c.

◆ YAC_ALLTOALL_P2P_TYPE

#define YAC_ALLTOALL_P2P_TYPE	(	NAME,
		TYPE,
		TYPE_SIZE,
		MPI_TYPE
	)

Value:

  void yac_alltoallv_ ## NAME ## _p2p( \
    TYPE const * send_buffer, size_t const * sendcounts, size_t const * sdispls, \
    TYPE * recv_buffer, size_t const * recvcounts, size_t const * rdispls, \
    MPI_Comm comm) { \
    yac_alltoallv_p2p( \
      (void const *)send_buffer, sendcounts, sdispls, \
      (void *)recv_buffer, recvcounts, rdispls, \
      TYPE_SIZE, MPI_TYPE, comm); \
  }

Definition at line 216 of file yac_mpi.c.

Function Documentation

◆ log2_()

static int log2_ ( int x )

static

Definition at line 351 of file yac_mpi.c.

Here is the caller graph for this function:

◆ nearest_power_of_two()

static int nearest_power_of_two ( int x )

static

Definition at line 278 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_allgather_uint64()

void yac_allgather_uint64	(	const uint64_t *	sendbuf,
		uint64_t *	recvbuf,
		int	count,
		struct yac_group_comm	group_comm
	)

Examples: test_group_comm.c.

Definition at line 359 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_allreduce_sum_dble()

void yac_allreduce_sum_dble	(	double *	buffer,
		int	count,
		struct yac_group_comm	group_comm
	)

Examples: test_group_comm.c.

Definition at line 287 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_alltoallv_p2p()

void yac_alltoallv_p2p	(	void const *	send_buffer,
		size_t const *	sendcounts,
		size_t const *	sdispls,
		void *	recv_buffer,
		size_t const *	recvcounts,
		size_t const *	rdispls,
		size_t	dt_size,
		MPI_Datatype	dt,
		MPI_Comm	comm
	)

Definition at line 129 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_alltoallv_p2p_group()

void yac_alltoallv_p2p_group	(	void const *	send_buffer,
		int const *	sendcounts,
		int const *	sdispls,
		void *	recv_buffer,
		int const *	recvcounts,
		int const *	rdispls,
		size_t	dt_size,
		MPI_Datatype	dt,
		struct yac_group_comm	group_comm
	)

Definition at line 234 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_bcast_group()

void yac_bcast_group	(	void *	buffer,
		int	count,
		MPI_Datatype	datatype,
		int	root,
		struct yac_group_comm	group_comm
	)

Examples: test_group_comm.c.

Definition at line 403 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_create_resized()

MPI_Datatype yac_create_resized	(	MPI_Datatype	dt,
		size_t	new_size,
		MPI_Comm	comm
	)

Definition at line 548 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_free_comm_buffers()

void yac_free_comm_buffers	(	size_t *	sendcounts,
		size_t *	recvcounts,
		size_t *	sdispls,
		size_t *	rdispls
	)

Definition at line 624 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_generate_alltoallv_args()

void yac_generate_alltoallv_args	(	int	count,
		size_t const *	sendcounts,
		size_t *	recvcounts,
		size_t *	sdispls,
		size_t *	rdispls,
		MPI_Comm	comm
	)

Definition at line 569 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_get_bounding_circle_mpi_datatype()

MPI_Datatype yac_get_bounding_circle_mpi_datatype ( MPI_Comm comm )

Definition at line 528 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_get_comm_buffers()

void yac_get_comm_buffers	(	int	count,
		size_t **	sendcounts,
		size_t **	recvcounts,
		size_t **	sdispls,
		size_t **	rdispls,
		MPI_Comm	comm
	)

Definition at line 593 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_group_comm_delete()

void yac_group_comm_delete ( struct yac_group_comm group_comm )

Examples: test_group_comm.c.

Definition at line 478 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_group_comm_get_global_rank()

int yac_group_comm_get_global_rank ( struct yac_group_comm group_comm )

Examples: test_group_comm.c.

Definition at line 491 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_group_comm_get_global_size()

int yac_group_comm_get_global_size ( struct yac_group_comm group_comm )

Examples: test_group_comm.c.

Definition at line 497 of file yac_mpi.c.

◆ yac_group_comm_get_rank()

int yac_group_comm_get_rank ( struct yac_group_comm group_comm )

Examples: test_group_comm.c.

Definition at line 483 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_group_comm_get_size()

int yac_group_comm_get_size ( struct yac_group_comm group_comm )

Examples: test_group_comm.c.

Definition at line 487 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_group_comm_new()

struct yac_group_comm yac_group_comm_new ( MPI_Comm comm )

Examples: test_group_comm.c.

Definition at line 468 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_group_comm_split()

void yac_group_comm_split	(	struct yac_group_comm	group_comm,
		int	split_rank,
		struct yac_group_comm *	local_group_comm,
		struct yac_group_comm *	remote_group_comm
	)

Examples: test_group_comm.c.

Definition at line 503 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_mpi_cleanup()

void yac_mpi_cleanup ( )

Definition at line 95 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_mpi_error()

void yac_mpi_error	(	int	error_code,
		MPI_Comm	comm
	)

report error return of MPI call

Parameters

[in]	error_code	return code of an MPI call
[in]	comm	communicator which was used for the respective MPI call

Examples: test_mpi_error.c.

Definition at line 116 of file yac_mpi.c.

◆ yac_mpi_finalize()

void yac_mpi_finalize ( )

Definition at line 108 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_mpi_init()

void yac_mpi_init ( )

Definition at line 77 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_mpi_is_initialised()

int yac_mpi_is_initialised ( )

Definition at line 32 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_yaxt_cleanup()

static void yac_yaxt_cleanup ( )

static

Definition at line 65 of file yac_mpi.c.

Here is the caller graph for this function:

◆ yac_yaxt_init()

void yac_yaxt_init ( MPI_Comm comm )

Definition at line 40 of file yac_mpi.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ yac_yaxt_init_f2c()

void yac_yaxt_init_f2c ( MPI_Fint comm )

Definition at line 60 of file yac_mpi.c.

Here is the call graph for this function:

Variable Documentation

◆ comm_buffer

size_t* comm_buffer = NULL

static

Definition at line 28 of file yac_mpi.c.

◆ comm_buffer_array_size

size_t comm_buffer_array_size = 0

static

Definition at line 29 of file yac_mpi.c.

◆ comm_buffer_in_use

int comm_buffer_in_use = 0

static

Definition at line 30 of file yac_mpi.c.

◆ init_count

int init_count = 0

static

Definition at line 25 of file yac_mpi.c.

◆ mpi_initialised_by_yac

int mpi_initialised_by_yac = 0

static

Definition at line 23 of file yac_mpi.c.

◆ yaxt_init_count

int yaxt_init_count = 0

static

Definition at line 26 of file yac_mpi.c.

◆ yaxt_initialised_by_yac

int yaxt_initialised_by_yac = 0

static

Definition at line 24 of file yac_mpi.c.

Macros

Functions

Variables

Macro Definition Documentation

◆ OPENMPI_WORKAROUND

◆ STR

◆ USE_P2P_ALLTOALLV

◆ XSTR

◆ YAC_ALLTOALL_P2P_TYPE

Function Documentation

◆ log2_()

◆ nearest_power_of_two()

◆ yac_allgather_uint64()

◆ yac_allreduce_sum_dble()

◆ yac_alltoallv_p2p()

◆ yac_alltoallv_p2p_group()

◆ yac_bcast_group()

◆ yac_create_resized()

◆ yac_free_comm_buffers()

◆ yac_generate_alltoallv_args()

◆ yac_get_bounding_circle_mpi_datatype()

◆ yac_get_comm_buffers()

◆ yac_group_comm_delete()

◆ yac_group_comm_get_global_rank()

◆ yac_group_comm_get_global_size()

◆ yac_group_comm_get_rank()

◆ yac_group_comm_get_size()

◆ yac_group_comm_new()

◆ yac_group_comm_split()

◆ yac_mpi_cleanup()

◆ yac_mpi_error()

◆ yac_mpi_finalize()

◆ yac_mpi_init()

◆ yac_mpi_is_initialised()

◆ yac_yaxt_cleanup()

◆ yac_yaxt_init()

◆ yac_yaxt_init_f2c()

Variable Documentation

◆ comm_buffer

◆ comm_buffer_array_size

◆ comm_buffer_in_use

◆ init_count

◆ mpi_initialised_by_yac

◆ yaxt_init_count

◆ yaxt_initialised_by_yac