xmp_intrinsic_mpi.c File Reference

#include "xmp_internal.h"

Include dependency graph for xmp_intrinsic_mpi.c:

Functions
void	_XMP_mpi_atomic_define (int target_rank, _XMP_coarray_t *c, size_t offset, int value, size_t elmt_size)
void	_XMP_mpi_atomic_ref (int target_rank, _XMP_coarray_t *c, size_t offset, int *value, size_t elmt_size)

Function Documentation

_XMP_mpi_atomic_define()

void _XMP_mpi_atomic_define	(	int	target_rank,
		_XMP_coarray_t *	c,
		size_t	offset,
		int	value,
		size_t	elmt_size
	)

{
  if(elmt_size != sizeof(int)){
    _XMP_fatal("invalid element-size was specified for _XMP_mpi_atomic_define");
  }
 
  MPI_Win win = _XMP_mpi_coarray_get_window(c, /*is_acc*/false);
  MPI_Aint raddr = (MPI_Aint)( _XMP_mpi_coarray_get_remote_addr(c, target_rank, /*is_acc*/false) + elmt_size * offset );
 
  // MPI RMA is used even if the target is same to the origin because of avoiding public/private window synchronization
  // MPI_Accumulate with MPI_REPLACE act as MPI_Put
  MPI_Accumulate(&value, 1, MPI_INT,
                 target_rank, raddr, 1, MPI_INT,
                 MPI_REPLACE, win);
 
  MPI_Win_flush(target_rank, win);
}

Here is the call graph for this function:

Here is the caller graph for this function:

_XMP_mpi_atomic_ref()

void _XMP_mpi_atomic_ref	(	int	target_rank,
		_XMP_coarray_t *	c,
		size_t	offset,
		int *	value,
		size_t	elmt_size
	)

{
  if(elmt_size != sizeof(int)){
    _XMP_fatal("invalid element-size was specified for _XMP_mpi_atomic_ref");
  }
 
  MPI_Win win = _XMP_mpi_coarray_get_window(c, /*is_acc*/false);
  MPI_Aint raddr = (MPI_Aint)( _XMP_mpi_coarray_get_remote_addr(c, target_rank, /*is_acc*/false) + elmt_size * offset );
 
  // MPI RMA is used even if the target is same to the origin because of avoiding public/private window synchronization
  // MPI_Fetch_and_op or MPI_Get_accumulate with MPI_NO_OP act as MPI_Get
  MPI_Fetch_and_op(NULL, value, MPI_INT,
                   target_rank, raddr,
                   MPI_NO_OP, win);
 
  MPI_Win_flush(target_rank, win);
}

Here is the call graph for this function:

Here is the caller graph for this function: