xmp_onesided.c File Reference

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

Include dependency graph for xmp_onesided.c:

Functions
void	_XMP_initialize_onesided_functions ()
void	_XMP_finalize_onesided_functions ()

Variables
int	_XMP_flag_put_nb = false
	These variables are temporral. More...
int	_XMP_flag_get_nb = false

Function Documentation

_XMP_finalize_onesided_functions()

void _XMP_finalize_onesided_functions

(

)

{
#ifdef _XMP_GASNET
  _XMP_gasnet_finalize();
#elif _XMP_FJRDMA
  if(_XMP_world_size > _XMP_ONESIDED_MAX_PROCS) return;
  else _XMP_fjrdma_finalize();
#elif _XMP_UTOFU
  _XMP_utofu_finalize();
#elif _XMP_MPI3_ONESIDED
  _XMP_mpi_onesided_finalize();
#endif
 
#ifdef _XMP_TCA
  _XMP_tca_finalize();
#endif
}

Here is the call graph for this function:

_XMP_initialize_onesided_functions()

void _XMP_initialize_onesided_functions

(

)

{
#ifdef _XMP_FJRDMA
  if(_XMP_world_size > _XMP_ONESIDED_MAX_PROCS){
    if(_XMP_world_rank == 0)
      fprintf(stderr, "Warning : Onesided operations cannot be not used in %d processes (up to %d processes)\n", 
              _XMP_world_size, _XMP_ONESIDED_MAX_PROCS);
 
    return;
  }
#endif
 
#ifdef _XMP_GASNET
  size_t _xmp_heap_size, _xmp_stride_size;
  _xmp_heap_size   = _get_size("XMP_ONESIDED_HEAP_SIZE");
  _xmp_stride_size = _get_size("XMP_ONESIDED_STRIDE_SIZE");
  _xmp_heap_size  += _xmp_stride_size;
  _XMP_gasnet_initialize(_xmp_heap_size, _xmp_stride_size);
  _XMP_gasnet_intrinsic_initialize();
#elif _XMP_FJRDMA
  _XMP_fjrdma_initialize();
#elif _XMP_UTOFU
  _XMP_utofu_initialize();
#elif _XMP_MPI3_ONESIDED
  size_t _xmp_heap_size;
  _xmp_heap_size   = _get_size("XMP_ONESIDED_HEAP_SIZE");
  _XMP_mpi_onesided_initialize(_xmp_heap_size);
#endif
 
#ifdef _XMP_TCA
  _XMP_tca_initialize();
#endif
 
#if defined(_XMP_GASNET) || defined(_XMP_FJRDMA) || defined(_XMP_TCA) || defined(_XMP_MPI3_ONESIDED) || defined(_XMP_UTOFU)
  _XMP_build_sync_images_table();
  _XMP_build_coarray_queue();
  _XMP_post_wait_initialize();
#endif
 
  /* Temporary  */
  if(getenv("XMP_PUT_NB") != NULL){
    _XMP_flag_put_nb = true;  // defalt false
    if(_XMP_world_rank == 0)
      printf("*** _XMP_coarray_contiguous_put() is Non-Blocking ***\n");
  }
 
  if(getenv("XMP_GET_NB") != NULL){
    _XMP_flag_get_nb = true;  // defalt false
    if(_XMP_world_rank == 0)
      printf("*** _XMP_coarray_contiguous_get() is Non-Blocking ***\n");
  }
 
#if defined(_XMP_FJRDMA)
  if(getenv("XMP_PUT_NB_RR") != NULL){
    _XMP_flag_put_nb    = true;  // defalt false
    _XMP_flag_put_nb_rr = true;  // defalt false
    if(_XMP_world_rank == 0)
      printf("*** _XMP_coarray_contiguous_put() is Non-Blocking and Round-Robin ***\n");
  }
 
  if(getenv("XMP_PUT_NB_RR_I") != NULL){
    _XMP_flag_put_nb      = true;  // defalt false
    _XMP_flag_put_nb_rr   = true;  // defalt false
    _XMP_flag_put_nb_rr_i = true;  // defalt false
    if(_XMP_world_rank == 0)
      printf("*** _XMP_coarray_contiguous_put() is Non-Blocking, Round-Robin and Immediately ***\n");
  }
#endif
  /* End Temporary */
}

Here is the call graph for this function:

Variable Documentation

_XMP_flag_get_nb

int _XMP_flag_get_nb = false

_XMP_flag_put_nb

int _XMP_flag_put_nb = false

These variables are temporral.