xmpco_get_stmt.c File Reference

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

Include dependency graph for xmpco_get_stmt.c:

Macros
#define	SCHEME_DirectGetsub   10
#define	SCHEME_BufferGetsub   11
#define	SCHEME_ExtraDirectGetsub   12
#define	SCHEME_ExtraBufferGetsub   13

Functions
void	_XMPCO_coarrayInit_getsub ()
void	XMPCO_GET_arrayStmt (CoarrayInfo_t *descPtr, char *baseAddr, int element, int coindex, char *localAddr, int rank, int skip[], int skip_local[], int count[])

Variables
void *	_localBuf_desc
size_t	_localBuf_offset
char *	_localBuf_baseAddr
int	_localBuf_size
char *	_localBuf_name
void *	_remote_desc
char *	_remote_baseAddr
int	_remote_coindex

Macro Definition Documentation

SCHEME_BufferGetsub

#define SCHEME_BufferGetsub   11

SCHEME_DirectGetsub

#define SCHEME_DirectGetsub   10

SCHEME_ExtraBufferGetsub

#define SCHEME_ExtraBufferGetsub   13

SCHEME_ExtraDirectGetsub

#define SCHEME_ExtraDirectGetsub   12

Function Documentation

_XMPCO_coarrayInit_getsub()

void _XMPCO_coarrayInit_getsub

(

)

{
  _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_GET_arrayStmt()

void XMPCO_GET_arrayStmt	(	CoarrayInfo_t *	descPtr,
		char *	baseAddr,
		int	element,
		int	coindex,
		char *	localAddr,
		int	rank,
		int	skip[],
		int	skip_local[],
		int	count[]
	)

{
  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_getsub_array_, " __FILE__);
    return;
  }
 
  /*--------------------------------------*\
   * Check whether the local address local  *
   * 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(localAddr, &orgAddrDMA, &offsetDMA, &nameDMA);
  avail_DMA = descDMA ? TRUE : FALSE;
 
  /*--------------------------------------*\
   * select scheme                        *
  \*--------------------------------------*/
  int scheme = _select_scheme_getsub_array(avail_DMA);
 
  /*--------------------------------------*\
   * action                               *
  \*--------------------------------------*/
  switch (scheme) {
  case SCHEME_DirectGetsub:
    _XMPCO_debugPrint("SCHEME_DirectGetsub/array selected\n");
    _getsubCoarray_DMA(descPtr, baseAddr, coindex0, localAddr,
                    element, rank, skip, skip_local, count,
                    descDMA, offsetDMA, nameDMA);
    break;
 
  case SCHEME_BufferGetsub:
    _XMPCO_debugPrint("SCHEME_BufferGetsub/array selected\n");
    _getsubCoarray_buffer(descPtr, baseAddr, coindex0, localAddr,
                       element, rank, skip, skip_local, count);
    break;
 
  default:
    _XMPCO_fatal("unexpected scheme number in " __FILE__);
  }
}

Here is the call graph for this function:

Variable Documentation

_localBuf_baseAddr

char* _localBuf_baseAddr

_localBuf_desc

void* _localBuf_desc

_localBuf_name

char* _localBuf_name

_localBuf_offset

size_t _localBuf_offset

_localBuf_size

int _localBuf_size

_remote_baseAddr

char* _remote_baseAddr

_remote_coindex

int _remote_coindex

_remote_desc

void* _remote_desc