xmp_reflect_gpu.c File Reference

#include "xmp_internal.h"
#include <stdio.h>
#include <stdlib.h>
#include <inttypes.h>
#include "xacc_internal.h"

Include dependency graph for xmp_reflect_gpu.c:

Data Structures
struct	stride_t

Macros
#define	TLOG_LOG(log)   do{}while(0)
#define	BARRIER()

Functions
void	_XMP_reflect_do_gpu (_XMP_array_t *array_desc)
void	_XMP_reflect_init_gpu (void *acc_addr, _XMP_array_t *array_desc)
void	_XMP_set_reflect_gpu (_XMP_array_t *a, int dim, int lwidth, int uwidth, int is_periodic)
void	_XMP_reflect_gpu (void *dev_addr, _XMP_array_t *a)
void	_XMP_init_reflect_sched_gpu (_XMP_reflect_sched_t *sched)
void	_XMP_finalize_reflect_sched_gpu (_XMP_reflect_sched_t *sched, _Bool free_buf)

Macro Definition Documentation

BARRIER

#define BARRIER

(

)

TLOG_LOG

#define TLOG_LOG

(

log

)

do{}while(0)

Function Documentation

_XMP_finalize_reflect_sched_gpu()

void _XMP_finalize_reflect_sched_gpu	(	_XMP_reflect_sched_t *	sched,
		_Bool	free_buf
	)

{
  if(sched == NULL) return;
 
  if (sched->datatype_lo != MPI_DATATYPE_NULL) MPI_Type_free(&sched->datatype_lo);
  if (sched->datatype_hi != MPI_DATATYPE_NULL) MPI_Type_free(&sched->datatype_hi);
 
  for (int j = 0; j < 4; j++){
    if (sched->req[j] != MPI_REQUEST_NULL) MPI_Request_free(&sched->req[j]);
  }
 
  if(useHostBuffer){
    _XACC_host_free(&(sched->lo_send_host_buf));
    _XACC_host_free(&(sched->lo_recv_host_buf));
  }
 
  if (free_buf && packVector){
    _XACC_memory_free(&(sched->lo_send_buf_mem));
    _XACC_memory_free(&(sched->lo_recv_buf_mem));
  }
 
  if(sched->lo_async_id){
    _XACC_queue_destroy(&(sched->lo_async_id));
  }
  if(sched->hi_async_id){
    _XACC_queue_destroy(&(sched->hi_async_id));
  }
 
  sched->dev_mem = NULL;
}

Here is the caller graph for this function:

_XMP_init_reflect_sched_gpu()

void _XMP_init_reflect_sched_gpu

(

_XMP_reflect_sched_t *

sched

)

{
  if(sched == NULL) return;
 
  sched->is_periodic = -1; /* not used yet */
  sched->datatype_lo = MPI_DATATYPE_NULL;
  sched->datatype_hi = MPI_DATATYPE_NULL;
  for (int j = 0; j < 4; j++) sched->req[j] = MPI_REQUEST_NULL;
  sched->lo_send_buf_mem = NULL;
  sched->lo_recv_buf_mem = NULL;
  sched->hi_send_buf_mem = NULL;
  sched->hi_recv_buf_mem = NULL;
  sched->lo_send_host_buf = NULL;
  sched->lo_recv_host_buf = NULL;
  sched->hi_send_host_buf = NULL;
  sched->hi_recv_host_buf = NULL;
 
  sched->lo_async_id = _XACC_QUEUE_NULL;
  sched->hi_async_id = _XACC_QUEUE_NULL;
 
  sched->dev_mem = NULL;
}

Here is the caller graph for this function:

_XMP_reflect_do_gpu()

void _XMP_reflect_do_gpu

(

_XMP_array_t *

array_desc

)

                                                  {
  _XMP_RETURN_IF_SINGLE;
 
  //  _XMP_reflect_start(array_desc, 0);
  //  _XMP_reflect_wait(array_desc);
  _XMP_reflect_(array_desc, 0);
}

Here is the caller graph for this function:

_XMP_reflect_gpu()

void _XMP_reflect_gpu	(	void *	dev_addr,
		_XMP_array_t *	a
	)

{
  _XMP_reflect_init_gpu(dev_addr, a);
  _XMP_reflect_do_gpu(a);
}

Here is the call graph for this function:

Here is the caller graph for this function:

_XMP_reflect_init_gpu()

void _XMP_reflect_init_gpu	(	void *	acc_addr,
		_XMP_array_t *	array_desc
	)

{
  _XMP_RETURN_IF_SINGLE;
 
  static char isFlagSetted = 0;
  if(! isFlagSetted ){
    char *mode_str = getenv("XACC_COMM_MODE");
    if(mode_str !=  NULL){
      int mode = atoi(mode_str);
      switch(mode){
      default:
      case 0:
        packVector = 1;
        useHostBuffer = 1;
        break;
      case 1:
        packVector = 1;
        useHostBuffer = 0;
        break;
      case 2:
        packVector = 0;
        useHostBuffer = 0;
        break;
      }
    }
    isFlagSetted = 1;
  }
  //printf("reflect mode (%d, %d)\n", packVector, useHostBuffer);
 
  if (!a->is_allocated){
    _xmpf_set_reflect_flag = 0;
    return;
  }
 
  if (!_xmpf_set_reflect_flag){
    for (int i = 0; i < a->dim; i++){
      _XMP_array_info_t *ai = &(a->info[i]);
      _xmp_lwidth[i] = ai->shadow_size_lo;
      _xmp_uwidth[i] = ai->shadow_size_hi;
      _xmp_is_periodic[i] = 0;
    }
  }
 
  _XMP_reflect_sched(a, _xmp_lwidth, _xmp_uwidth, _xmp_is_periodic, 0, dev_addr);
 
  _xmpf_set_reflect_flag = 0;
  for (int i = 0; i < a->dim; i++){
    _xmp_lwidth[i] = 0;
    _xmp_uwidth[i] = 0;
    _xmp_is_periodic[i] = 0;
  }
}

Here is the caller graph for this function:

_XMP_set_reflect_gpu()

void _XMP_set_reflect_gpu	(	_XMP_array_t *	a,
		int	dim,
		int	lwidth,
		int	uwidth,
		int	is_periodic
	)

{
  _xmpf_set_reflect_flag = 1;
  _xmp_lwidth[dim] = lwidth;
  _xmp_uwidth[dim] = uwidth;
  _xmp_is_periodic[dim] = is_periodic;
}

Here is the caller graph for this function: