xmpco_get_expr.c File Reference

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

Include dependency graph for xmpco_get_expr.c:

Macros
#define	SCHEME_DirectGet   20
#define	SCHEME_BufferGet   21
#define	SCHEME_ExtraDirectGet   22
#define	SCHEME_ExtraBufferGet   23

Functions
void	_XMPCO_coarrayInit_get ()
void	XMPCO_GET_scalarExpr (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *result)
void	XMPCO_GET_arrayExpr (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *result, int rank, int skip[], int count[])
void	_XMPCO_getVector_DMA (void *descPtr, char *baseAddr, int bytes, int coindex, void *descDMA, size_t offsetDMA, char *nameDMA)
void	_XMPCO_getVector_buffer (void *descPtr, char *baseAddr, int bytesRU, int coindex, char *result, int bytes)

Macro Definition Documentation

SCHEME_BufferGet

#define SCHEME_BufferGet   21

SCHEME_DirectGet

#define SCHEME_DirectGet   20

SCHEME_ExtraBufferGet

#define SCHEME_ExtraBufferGet   23

SCHEME_ExtraDirectGet

#define SCHEME_ExtraDirectGet   22

Function Documentation

_XMPCO_coarrayInit_get()

void _XMPCO_coarrayInit_get

(

void

)

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

Here is the call graph for this function:

_XMPCO_getVector_buffer()

void _XMPCO_getVector_buffer	(	void *	descPtr,
		char *	baseAddr,
		int	bytesRU,
		int	coindex,
		char *	result,
		int	bytes
	)

{
  size_t rest1, rest2, bufSize;
  char *src, *dst;
 
  src = baseAddr;
  dst = result;
  bufSize = _XMPCO_get_localBufSize();
 
  // communication for every buffer size
  for (rest1 = bytesRU, rest2 = bytes;
       rest1 > bufSize;
       rest1 -= bufSize, rest2 -=bufSize) {
    _XMPCO_getVector_DMA(descPtr, src, bufSize, coindex,
                   _localBuf_desc, _localBuf_offset, _localBuf_name);
 
    _XMPCO_debugPrint("=e=MEMCPY %d bytes, cont\'d\n"
                            "  from: \'%s\'\n"
                            "  to  : addr=%p\n",
                            bufSize,
                            _localBuf_name,
                            dst);
    (void)memcpy(dst, _localBuf_baseAddr, bufSize);
 
    src += bufSize;
    dst += bufSize;
  }
 
  _XMPCO_getVector_DMA(descPtr, src, rest1, coindex,
                 _localBuf_desc, _localBuf_offset, _localBuf_name);
 
  _XMPCO_debugPrint("=e=MEMCPY %d bytes, final\n"
                          "  from: \'%s\'\n"
                          "  to  : addr=%p\n",
                          rest2,
                          _localBuf_name,
                          dst);
  (void)memcpy(dst, _localBuf_baseAddr, rest2);
}

Here is the call graph for this function:

_XMPCO_getVector_DMA()

void _XMPCO_getVector_DMA	(	void *	descPtr,
		char *	baseAddr,
		int	bytes,
		int	coindex,
		void *	descDMA,
		size_t	offsetDMA,
		char *	nameDMA
	)

{
  char* desc = _XMPCO_get_descForMemoryChunk(descPtr);
  size_t offset = _XMPCO_get_offsetInMemoryChunk(descPtr, baseAddr);
 
  _XMPCO_debugPrint("=e=GET_VECTOR RDMA-DMA %d bytes\n"
                    "  from: remote[%d] \'%s\' + %zd\n"
                    "  to  : %s + %zd\n",
                    bytes,
                    coindex, _XMPCO_get_nameOfCoarray(descPtr), offset,
                    nameDMA, offsetDMA);
 
  // ACTION
  _XMP_coarray_contiguous_get(coindex-1,
                            descDMA,   desc,
                            offsetDMA, offset,
                            bytes,     bytes);
}

Here is the call graph for this function:

Here is the caller graph for this function:

XMPCO_GET_arrayExpr()

void XMPCO_GET_arrayExpr	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	result,
		int	rank,
		int	skip[],
		int	count[]
	)

{
  int coindex0 = _XMPCO_get_initial_image_withDescPtr(coindex, descPtr);
 
  if (element % COMM_UNIT != 0) {
    _XMPCO_fatal("violation of boundary in reference of a coindexed object\n"
              "  xmpf_coarray_get_array_, " __FILE__);
    return;
  }
 
  /*--------------------------------------*\
   * Confirm that baseAddr is located in  *
   * the memory chunk corresponding to    *
   * descptr.                             *
  \*--------------------------------------*/
  BOOL pass = _XMPCO_isAddrInMemoryChunk(baseAddr, descPtr);
  if (!pass) {
    _XMPCO_fatal("INTERNAL : illegal baseAddr of mold coarray (in xmpf_coarray_get_array_)\n"
                       "  possibly because of unexpected copy-in interface\n"
                       "  coarray_name=\"%s\", chunk_size=%ud; offset_in_chunk=%ud",
                       _XMPCO_get_nameOfCoarray(descPtr),
                       (unsigned)_XMPCO_get_sizeOfMemoryChunk(descPtr),
                       (unsigned)_XMPCO_get_offsetInMemoryChunk(descPtr, baseAddr));
  }
 
  /*--------------------------------------*\
   * Check whether the local address      *
   * result 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(result, &orgAddrDMA, &offsetDMA, &nameDMA);
  avail_DMA = descDMA ? TRUE : FALSE;
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  int scheme = _select_scheme_get_array(avail_DMA);
 
  /*--------------------------------------*\
   * action                               *
  \*--------------------------------------*/
  switch (scheme) {
  case SCHEME_DirectGet:
    _XMPCO_debugPrint("select SCHEME_DirectGet/array\n");
    _getCoarray(descPtr, baseAddr, coindex0, result,
                element, rank, skip, count,
                descDMA, offsetDMA, nameDMA);
    break;
 
  case SCHEME_BufferGet:
    _XMPCO_debugPrint("select SCHEME_BufferGet/array\n");
    _getCoarray(descPtr, baseAddr, coindex0, result,
                element, rank, skip, count,
                NULL, 0, "(localBuf)");
    break;
 
  default:
    _XMPCO_fatal("undefined scheme number in " __FILE__);
  }
}

Here is the call graph for this function:

XMPCO_GET_scalarExpr()

void XMPCO_GET_scalarExpr	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	result
	)

{
  int coindex0 = _XMPCO_get_initial_image_withDescPtr(coindex, descPtr);
 
  /*--------------------------------------*\
   * Confirm that *baseAddr is located in *
   * the memory chunk corresponding to    *
   * descptr.                             *
  \*--------------------------------------*/
  BOOL pass = _XMPCO_isAddrInMemoryChunk(baseAddr, descPtr);
  if (!pass) {
    _XMPCO_fatal("INTERNAL: illegal baseAddr of mold coarray (in xmpf_coarray_get_scalar_)\n"
                       "  possibly because of unexpected copy-in interface\n"
                       "  coarray_name=\"%s\", chunk_size=%ud; offset_in_chunk=%ud",
                       _XMPCO_get_nameOfCoarray(descPtr),
                       (unsigned)_XMPCO_get_sizeOfMemoryChunk(descPtr),
                       (unsigned)_XMPCO_get_offsetInMemoryChunk(descPtr, baseAddr));
  }
 
  /*--------------------------------------*\
   * Check whether the local address      *
   * result 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(result, &orgAddrDMA, &offsetDMA, &nameDMA);
  avail_DMA = descDMA ? TRUE : FALSE;
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  int scheme = _select_scheme_get_scalar(element, avail_DMA);
 
  switch (scheme) {
  case SCHEME_DirectGet:
    _XMPCO_debugPrint("SCHEME_DirectGet/scalar selected\n");
 
    assert(avail_DMA);
    _XMPCO_getVector_DMA(descPtr, baseAddr, element, coindex0,
                   descDMA, offsetDMA, nameDMA);
    break;
 
  case SCHEME_BufferGet:
    _XMPCO_debugPrint("select SCHEME_BufferGet/scalar\n");
 
    _XMPCO_getVector_buffer(descPtr, baseAddr, element, coindex0,
                      result, element);
    break;
 
  case SCHEME_ExtraBufferGet:
    {
      size_t elementRU = ROUND_UP_COMM(element);
 
      _XMPCO_debugPrint("select SCHEME_ExtraBufferGet/scalar. elementRU=%ud\n",
                              elementRU);
 
      _XMPCO_getVector_buffer(descPtr, baseAddr, elementRU, coindex0,
                        result, element);
    }
    break;
 
  default:
    _XMPCO_fatal("undefined scheme number in " __FILE__);
  }
}

Here is the call graph for this function: