xmp_coarray_acc.c File Reference

#include "xmp_internal.h"
#include "xmp_constant.h"

Include dependency graph for xmp_coarray_acc.c:

Functions
int	_XMP_coarray_get_total_elmts (void *coarray_desc)
void	_XMP_coarray_attach_acc (_XMP_coarray_t *coarray_desc, void *addr, const size_t coarray_size)
	Attach memory to coarray. More...
void	_XMP_coarray_detach_acc (_XMP_coarray_t *coarray_desc)
	Detach memory from coarray. More...
void	_XMP_coarray_malloc_acc (void **coarray_desc, void *addr)
void	_XMP_coarray_contiguous_put_acc (const int target_image, const _XMP_coarray_t *dst_desc, const _XMP_coarray_t *src_desc, const size_t dst_offset, const size_t src_offset, const size_t dst_elmts, const size_t src_elmts, const int is_dst_on_acc, const int is_src_on_acc)
void	_XMP_coarray_contiguous_get_acc (const int target_image, _XMP_coarray_t *dst_desc, const _XMP_coarray_t *src_desc, const size_t dst_offset, const size_t src_offset, const size_t dst_elmts, const size_t src_elmts, const int is_dst_on_acc, const int is_src_on_acc)

Function Documentation

_XMP_coarray_attach_acc()

void _XMP_coarray_attach_acc	(	_XMP_coarray_t *	coarray_desc,
		void *	addr,
		const size_t	coarray_size
	)

Attach memory to coarray.

{
  _XMP_coarray_set_info(coarray_desc);
 
#ifdef _XMP_MPI3_ONESIDED
  _XMP_mpi_coarray_attach(coarray_desc, addr, coarray_size, true);
#else
  _XMP_fatal("_XMP_coarray_attach_acc is unavailable");
#endif
}

Here is the call graph for this function:

_XMP_coarray_contiguous_get_acc()

void _XMP_coarray_contiguous_get_acc	(	const int	target_image,
		_XMP_coarray_t *	dst_desc,
		const _XMP_coarray_t *	src_desc,
		const size_t	dst_offset,
		const size_t	src_offset,
		const size_t	dst_elmts,
		const size_t	src_elmts,
		const int	is_dst_on_acc,
		const int	is_src_on_acc
	)

{
  int target_rank = target_image;
  size_t elmt_size = dst_desc->elmt_size;
 
  if(!is_dst_on_acc || !is_src_on_acc){
    _XMP_fatal("device to host and host to device put are umimplemented");
  }
 
  if(target_rank == _XMP_world_rank){
#ifdef _XMP_MPI3_ONESIDED
    _XMP_mpi_contiguous_get(target_rank, dst_desc, src_desc, dst_offset, src_offset,
                          dst_elmts, src_elmts, elmt_size, is_dst_on_acc, is_src_on_acc);
#else
    _XMP_fatal("local_contiguous_copy is unimplemented");
#endif
    /* _XMP_local_contiguous_copy((char *)dst_desc->real_addr+dst_offset, (char *)src_desc->real_addr+src_offset, */
    /*                         dst_elmts, src_elmts, elmt_size); */
  }
  else{
#ifdef _XMP_TCA
    /* _XMP_tca_contiguous_get(target_rank, dst_offset, src_offset, dst_desc, src_desc,  */
    /*                    dst_elmts, src_elmts, elmt_size); */
    _XMP_fatal("_XMP_tca_contiguous_get is unimplemented");
#elif _XMP_MPI3_ONESIDED
    _XMP_mpi_contiguous_get(target_rank, dst_desc, src_desc, dst_offset, src_offset,
                          dst_elmts, src_elmts, elmt_size, is_dst_on_acc, is_src_on_acc);
#else
    _XMP_fatal("_XMP_coarray_contiguous_get_acc is unavailable");
#endif
  }
}

Here is the call graph for this function:

_XMP_coarray_contiguous_put_acc()

void _XMP_coarray_contiguous_put_acc	(	const int	target_image,
		const _XMP_coarray_t *	dst_desc,
		const _XMP_coarray_t *	src_desc,
		const size_t	dst_offset,
		const size_t	src_offset,
		const size_t	dst_elmts,
		const size_t	src_elmts,
		const int	is_dst_on_acc,
		const int	is_src_on_acc
	)

{
  int target_rank = target_image;
  size_t elmt_size = dst_desc->elmt_size;
 
  if(!is_dst_on_acc || !is_src_on_acc){
    _XMP_fatal("device to host and host to device put are umimplemented");
  }
  
  if(target_rank == _XMP_world_rank){
#ifdef _XMP_MPI3_ONESIDED
    _XMP_mpi_contiguous_put(target_rank, dst_desc, src_desc, dst_offset, src_offset,
                          dst_elmts, src_elmts, elmt_size, is_dst_on_acc, is_src_on_acc);
#else
    _XMP_fatal("local_contiguous_copy is unimplemented");
#endif
    //_XMP_local_contiguous_copy((char *)dst_desc->real_addr+dst_offset, (char *)src_desc->real_addr+src_offset, 
    //dst_elmts, src_elmts, elmt_size);
  }
  else{
#ifdef _XMP_TCA
    _XMP_tca_contiguous_put(target_rank, dst_offset, src_offset, dst_desc, src_desc, 
                          dst_elmts, src_elmts, elmt_size);
#elif _XMP_MPI3_ONESIDED
    _XMP_mpi_contiguous_put(target_rank, dst_desc, src_desc, dst_offset, src_offset,
                          dst_elmts, src_elmts, elmt_size, is_dst_on_acc, is_src_on_acc);
#else
    _XMP_fatal("_XMP_coarray_contiguous_put_acc is unavailable");
#endif
  }
}

Here is the call graph for this function:

_XMP_coarray_detach_acc()

void _XMP_coarray_detach_acc

(

_XMP_coarray_t *

coarray_desc

)

Detach memory from coarray.

{
#ifdef _XMP_MPI3_ONESIDED
  _XMP_mpi_coarray_detach(coarray_desc, true);
#else
  _XMP_fatal("_XMP_coarray_detach_acc is unavailable");
#endif
}

Here is the call graph for this function:

_XMP_coarray_get_total_elmts()

int _XMP_coarray_get_total_elmts

(

void *

coarray_desc

)

{
  _XMP_coarray_t* c = (_XMP_coarray_t*)coarray_desc;
    
  int total_coarray_elmts = 1;
  for(int i = 0; i < c->coarray_dims; i++){
    total_coarray_elmts *= c->coarray_elmts[i];
  }
  return total_coarray_elmts;
}

Here is the caller graph for this function:

_XMP_coarray_malloc_acc()

void _XMP_coarray_malloc_acc	(	void **	coarray_desc,
		void *	addr
	)

{
  _XMP_coarray_t* c = *coarray_desc;
    
  int total_coarray_elmts = _XMP_coarray_get_total_elmts(c);
 
#ifdef _XMP_TCA
  _XMP_tca_malloc(*coarray_desc, addr, total_coarray_elmts * c->elmt_size);
#elif _XMP_MPI3_ONESIDED
  _XMP_mpi_coarray_malloc(*coarray_desc, addr, total_coarray_elmts * c->elmt_size, true);
#else
  _XMP_fatal("_XMP_coarray_malloc_acc is unavailable");
#endif
}

Here is the call graph for this function: