xmpc_gmove.c File Reference

#include <stdlib.h>
#include "xmp_internal.h"

Include dependency graph for xmpc_gmove.c:

Macros
#define	XMP_DBG   0
#define	DBG_RANK   0

Functions
void	xmpc_gmv_g_alloc (_XMP_gmv_desc_t **gmv_desc, _XMP_array_t *ap)
void	xmpc_gmv_g_dim_info (_XMP_gmv_desc_t *gp, int i, int kind, int lb, int len, int st)
void	xmpc_gmv_l_alloc (_XMP_gmv_desc_t **gmv_desc, void *local_data, int n)
void	xmpc_gmv_l_dim_info (_XMP_gmv_desc_t *gp, int i, int a_lb, int a_len, int kind, int lb, int len, int st)
void	xmpc_gmv_dealloc (_XMP_gmv_desc_t *gp)
void	xmpc_gmv_do (_XMP_gmv_desc_t *gmv_desc_leftp, _XMP_gmv_desc_t *gmv_desc_rightp, int mode)

Variables
void(*	_XMP_pack_comm_set )(void *sendbuf, int sendbuf_size, _XMP_array_t *a, _XMP_comm_set_t *comm_set[][_XMP_N_MAX_DIM])
void(*	_XMP_unpack_comm_set )(void *recvbuf, int recvbuf_size, _XMP_array_t *a, _XMP_comm_set_t *comm_set[][_XMP_N_MAX_DIM])
_XMP_nodes_t *	gmv_nodes
int	n_gmv_nodes

Macro Definition Documentation

DBG_RANK

#define DBG_RANK   0

XMP_DBG

#define XMP_DBG   0

Function Documentation

xmpc_gmv_dealloc()

void xmpc_gmv_dealloc

(

_XMP_gmv_desc_t *

gp

)

                                     {
 
  _XMP_free(gp->kind);
  _XMP_free(gp->lb);
  _XMP_free(gp->ub);
  _XMP_free(gp->st);
 
  _XMP_free(gp->a_lb);
  _XMP_free(gp->a_ub);
 
  _XMP_free(gp);
 
}

Here is the call graph for this function:

xmpc_gmv_do()

void xmpc_gmv_do	(	_XMP_gmv_desc_t *	gmv_desc_leftp,
		_XMP_gmv_desc_t *	gmv_desc_rightp,
		int	mode
	)

{
 
  _XMP_pack_comm_set = _XMPC_pack_comm_set;
  _XMP_unpack_comm_set = _XMPC_unpack_comm_set;
 
  if (gmv_desc_leftp->is_global && gmv_desc_rightp->is_global){
    _XMP_gmove_garray_garray(gmv_desc_leftp, gmv_desc_rightp, mode);
  }
  else if (gmv_desc_leftp->is_global && !gmv_desc_rightp->is_global){
    if (gmv_desc_rightp->ndims == 0){
      _XMP_gmove_garray_scalar(gmv_desc_leftp, gmv_desc_rightp->local_data, mode);
    }
    else {
      _XMP_array_t *a = NULL;
      _XMPC_larray_alloc(&a, gmv_desc_rightp,
                           gmv_desc_leftp->a_desc->type, gmv_desc_leftp->a_desc->align_template);
      _XMP_gmove_garray_larray(gmv_desc_leftp, gmv_desc_rightp, mode);
      _XMP_finalize_array_desc(a);
    }
  }
  else if (!gmv_desc_leftp->is_global && gmv_desc_rightp->is_global){
    if (gmv_desc_leftp->ndims == 0){
      _XMP_gmove_scalar_garray(gmv_desc_leftp->local_data, gmv_desc_rightp, mode);
    }
    else {
 
      _XMP_ASSERT(gmv_desc_rightp->a_desc);
 
      // create a temporal descriptor for the "non-distributed" LHS array (to be possible used
      // in _XMP_gmove_1to1)
      _XMP_array_t *a = NULL;
      _XMPC_larray_alloc(&a, gmv_desc_leftp,
                         gmv_desc_rightp->a_desc->type, gmv_desc_rightp->a_desc->align_template);
      _XMP_gmove_larray_garray(gmv_desc_leftp, gmv_desc_rightp, mode);
      _XMP_finalize_array_desc(a);
 
    }
  }
  else {
    _XMP_fatal("gmv_do: both sides are local.");
  }
 
}

xmpc_gmv_g_alloc()

void xmpc_gmv_g_alloc	(	_XMP_gmv_desc_t **	gmv_desc,
		_XMP_array_t *	ap
	)

{
  _XMP_gmv_desc_t *gp;
  int n = ap->dim;
 
  gp = (_XMP_gmv_desc_t *)_XMP_alloc(sizeof(_XMP_gmv_desc_t));
 
  gp->kind = (int *)_XMP_alloc(sizeof(int) * n);
  gp->lb = (int *)_XMP_alloc(sizeof(int) * n);
  gp->ub = (int *)_XMP_alloc(sizeof(int) * n);
  gp->st = (int *)_XMP_alloc(sizeof(int) * n);
  
  if (!gp || !gp->kind || !gp->lb || !gp->st)
    _XMP_fatal("gmv_g_alloc: cannot alloc memory");
 
  gp->is_global = true;
  gp->ndims = n;
  gp->a_desc = ap;
 
  gp->local_data = NULL;
  gp->a_lb = NULL;
  gp->a_ub = NULL;
 
  *gmv_desc = gp;
}

Here is the call graph for this function:

xmpc_gmv_g_dim_info()

void xmpc_gmv_g_dim_info	(	_XMP_gmv_desc_t *	gp,
		int	i,
		int	kind,
		int	lb,
		int	len,
		int	st
	)

{
  gp->kind[i] = kind;
 
  switch (kind){
  case XMP_N_GMOVE_ALL:
    gp->lb[i] = gp->a_desc->info[i].ser_lower;
    gp->ub[i] = gp->a_desc->info[i].ser_upper;
    gp->st[i] = 1;
    break;
  case XMP_N_GMOVE_INDEX:
  case XMP_N_GMOVE_RANGE:
    gp->lb[i] = lb;
    gp->ub[i] = lb + st * (len - 1);
    gp->st[i] = st;
    break;
  default:
    _XMP_fatal("wrong gmove kind");
  }
 
}

Here is the call graph for this function:

xmpc_gmv_l_alloc()

void xmpc_gmv_l_alloc	(	_XMP_gmv_desc_t **	gmv_desc,
		void *	local_data,
		int	n
	)

{
  _XMP_gmv_desc_t *gp;
 
  gp = (_XMP_gmv_desc_t *)_XMP_alloc(sizeof(_XMP_gmv_desc_t));
 
  gp->kind = (int *)_XMP_alloc(sizeof(int) * n);
  gp->lb = (int *)_XMP_alloc(sizeof(int) * n);
  gp->ub = (int *)_XMP_alloc(sizeof(int) * n);
  gp->st = (int *)_XMP_alloc(sizeof(int) * n);
  gp->a_lb = (int *)_XMP_alloc(sizeof(int) * n);
  gp->a_ub = (int *)_XMP_alloc(sizeof(int) * n);
 
  gp->is_global = false;
  gp->ndims = n;
  gp->a_desc = NULL;
 
  gp->local_data = local_data;
 
  *gmv_desc = gp;
}

Here is the call graph for this function:

xmpc_gmv_l_dim_info()

void xmpc_gmv_l_dim_info	(	_XMP_gmv_desc_t *	gp,
		int	i,
		int	a_lb,
		int	a_len,
		int	kind,
		int	lb,
		int	len,
		int	st
	)

{
  gp->a_lb[i] = a_lb; // always 0
  gp->a_ub[i] = a_len - 1;
 
  gp->kind[i] = kind;
 
  switch (kind){
  case XMP_N_GMOVE_ALL:
    gp->lb[i] = a_lb;
    gp->ub[i] = a_len - 1;
    gp->st[i] = 1;
    break;
  case XMP_N_GMOVE_INDEX:
  case XMP_N_GMOVE_RANGE:
    gp->lb[i] = lb;
    gp->ub[i] = lb + st * (len - 1);
    gp->st[i] = st;
    break;
  default:
    _XMP_fatal("wrong gmove kind");
  }
 
}

Here is the call graph for this function:

Variable Documentation

_XMP_pack_comm_set

void(* _XMP_pack_comm_set) (void *sendbuf, int sendbuf_size, _XMP_array_t *a, _XMP_comm_set_t *comm_set[][_XMP_N_MAX_DIM])

_XMP_unpack_comm_set

void(* _XMP_unpack_comm_set) (void *recvbuf, int recvbuf_size, _XMP_array_t *a, _XMP_comm_set_t *comm_set[][_XMP_N_MAX_DIM])

gmv_nodes

_XMP_nodes_t* gmv_nodes

n_gmv_nodes

int n_gmv_nodes