xmpco_put.c File Reference

#include <assert.h>
#include "xmpco_internal.h"
#include "_xmpco_putget.h"

Include dependency graph for xmpco_put.c:

Macros
#define	SCHEME_DirectPut   10
#define	SCHEME_BufferPut   11
#define	SCHEME_ExtraDirectPut   12
#define	SCHEME_ExtraBufferPut   13

Functions
void	_XMPCO_coarrayInit_put ()
void	XMPCO_PUT_scalarStmt (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *rhs, SyncMode sync_mode)
void	XMPCO_PUT_arrayStmt (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *rhsAddr, int rank, int skip[], int skip_rhs[], int count[], SyncMode sync_mode)
void	XMPCO_PUT_spread (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *rhs, int rank, int skip[], int count[], SyncMode sync_mode)
void	xmpf_coarray_put_err_len_ (void **descPtr, int *len_mold, int *len_src)
void	xmpf_coarray_put_err_size_ (void **descPtr, int *dim, int *size_mold, int *size_src)

Macro Definition Documentation

SCHEME_BufferPut

#define SCHEME_BufferPut   11

SCHEME_DirectPut

#define SCHEME_DirectPut   10

SCHEME_ExtraBufferPut

#define SCHEME_ExtraBufferPut   13

SCHEME_ExtraDirectPut

#define SCHEME_ExtraDirectPut   12

Function Documentation

_XMPCO_coarrayInit_put()

void _XMPCO_coarrayInit_put

(

void

)

{
  _localBuf_desc = _XMPCO_get_infoOfLocalBuf(&_localBuf_baseAddr,
                                              &_localBuf_offset,
                                              &_localBuf_name);
  _localBuf_size = _XMPCO_get_localBufSize();
}

Here is the call graph for this function:

XMPCO_PUT_arrayStmt()

void XMPCO_PUT_arrayStmt	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	rhsAddr,
		int	rank,
		int	skip[],
		int	skip_rhs[],
		int	count[],
		SyncMode	sync_mode
	)

{
  int coindex0 = _XMPCO_get_initial_image_withDescPtr(coindex, descPtr);
 
  if (element % COMM_UNIT != 0) {
    _XMPCO_fatal("violation of boundary writing to a coindexed variable\n"
                 "  xmpf_coarray_put_array_, " __FILE__);
    return;
  }
 
  /*--------------------------------------*\
   * Check whether the local address rhs  *
   * is already registered for DMA and,   *
   * if so, get the descriptor, etc.      *
  \*--------------------------------------*/
  void *descDMA;
  size_t offsetDMA;
  char *orgAddrDMA;
  char *nameDMA;
  BOOL avail_DMA;
  int scheme;
 
  descDMA = _XMPCO_get_isEagerCommMode() ? NULL :
      _XMPCO_get_desc_fromLocalAddr(rhsAddr, &orgAddrDMA, &offsetDMA, &nameDMA);
  avail_DMA = descDMA ? TRUE : FALSE;
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  scheme = _select_scheme_put_array(avail_DMA);
 
  /*--------------------------------------*\
   * action                               *
  \*--------------------------------------*/
  switch (scheme) {
  case SCHEME_DirectPut:
    _XMPCO_debugPrint("SCHEME_DirectPut/array selected\n");
    _putCoarray_DMA(descPtr, baseAddr, coindex0, rhsAddr,
                    element, rank, skip, skip_rhs, count,
                    descDMA, offsetDMA, nameDMA, sync_mode);
    break;
 
  case SCHEME_BufferPut:
    _XMPCO_debugPrint("SCHEME_BufferPut/array selected\n");
    _putCoarray_buffer(descPtr, baseAddr, coindex0, rhsAddr,
                       element, rank, skip, skip_rhs, count, sync_mode);
    break;
 
  default:
    _XMPCO_fatal("unexpected scheme number in " __FILE__);
  }
}

Here is the call graph for this function:

XMPCO_PUT_scalarStmt()

void XMPCO_PUT_scalarStmt	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	rhs,
		SyncMode	sync_mode
	)

{
  int coindex0 = _XMPCO_get_initial_image_withDescPtr(coindex, descPtr);
 
  /*--------------------------------------*\
   * Check whether the local address rhs  *
   * is already registered for DMA and,   *
   * if so, get the descriptor, etc.      *
  \*--------------------------------------*/
  void *descDMA;
  size_t offsetDMA;
  char *orgAddrDMA;
  char *nameDMA;
  BOOL avail_DMA;
 
  descDMA = _XMPCO_get_isEagerCommMode() ? NULL :
    _XMPCO_get_desc_fromLocalAddr(rhs, &orgAddrDMA, &offsetDMA, &nameDMA);
  avail_DMA = descDMA ? TRUE : FALSE;
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  int scheme = _select_scheme_put_scalar(element, avail_DMA);
 
  /*--------------------------------------*\
   * action                               *
  \*--------------------------------------*/
  size_t elementRU;
 
  switch (scheme) {
  case SCHEME_DirectPut:
    _XMPCO_debugPrint("SCHEME_DirectPut/scalar selected\n");
    assert(avail_DMA);
 
    _putVector_DMA(descPtr, baseAddr, element, coindex0,
                   descDMA, offsetDMA, nameDMA, sync_mode);
    break;
    
  case SCHEME_ExtraDirectPut:
    elementRU = ROUND_UP_COMM(element);
    _XMPCO_debugPrint("SCHEME_ExtraDirectPut/scalar selected. elementRU=%ud\n",
                      elementRU);
    assert(avail_DMA);
 
    _putVector_DMA(descPtr, baseAddr, elementRU, coindex0,
                   descDMA, offsetDMA, nameDMA, sync_mode);
    break;
 
  case SCHEME_BufferPut:
    _XMPCO_debugPrint("SCHEME_BufferPut/scalar selected\n");
 
    _putVector_buffer(descPtr, baseAddr, element, coindex0,
                      rhs, element, sync_mode);
    break;
 
  case SCHEME_ExtraBufferPut:
    elementRU = ROUND_UP_COMM(element);
    _XMPCO_debugPrint("SCHEME_ExtraBufferPut/scalar selected. elementRU=%ud\n",
                      elementRU);
 
    _putVector_buffer(descPtr, baseAddr, elementRU, coindex0,
                      rhs, element, sync_mode);
    break;
 
  default:
    _XMPCO_fatal("unexpected scheme number in " __FILE__);
  }
}

Here is the call graph for this function:

XMPCO_PUT_spread()

void XMPCO_PUT_spread	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	rhs,
		int	rank,
		int	skip[],
		int	count[],
		SyncMode	sync_mode
	)

{
  int coindex0 = _XMPCO_get_initial_image_withDescPtr(coindex, descPtr);
 
  if (element % COMM_UNIT != 0) {
    _XMPCO_fatal("violation of boundary writing a scalar to a coindexed variable\n"
               "   xmpf_coarray_put_spread_, " __FILE__);
    return;
  }
 
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  // only BufferPut
  _XMPCO_debugPrint("SCHEME_BufferPut/spread selected\n");
 
  /*--------------------------------------*\
   * action                               *
  \*--------------------------------------*/
  _spreadCoarray(descPtr, baseAddr, coindex0, rhs,
                 element, rank, skip, count, element, sync_mode);
}

Here is the call graph for this function:

xmpf_coarray_put_err_len_()

void xmpf_coarray_put_err_len_	(	void **	descPtr,
		int *	len_mold,
		int *	len_src
	)

{
  char *name = _XMPCO_get_nameOfCoarray(*descPtr);
 
  _XMPCO_debugPrint("ERROR DETECTED: xmpf_coarray_put_err_len_\n"
                          "  coarray name=\'%s\', len(mold)=%d, len(src)=%d\n",
                          name, *len_mold, *len_src);
 
  _XMPCO_fatal("mismatch length-parameters found in "
                     "put-communication on coarray \'%s\'", name);
}

Here is the call graph for this function:

xmpf_coarray_put_err_size_()

void xmpf_coarray_put_err_size_	(	void **	descPtr,
		int *	dim,
		int *	size_mold,
		int *	size_src
	)

{
  char *name = _XMPCO_get_nameOfCoarray(*descPtr);
 
  _XMPCO_debugPrint("ERROR DETECTED: xmpf_coarray_put_err_size_\n"
                          "  coarray name=\'%s\', i=%d, size(mold,i)=%d, size(src,i)=%d\n",
                          name, *dim, *size_mold, *size_src);
 
  _XMPCO_fatal("Mismatch sizes of %d-th dimension found in "
                     "put-communication on coarray \'%s\'", *dim, name);
}

Here is the call graph for this function: