xmp_post_wait_tca.c File Reference

#include <stdlib.h>
#include <pthread.h>
#include "xmp_internal.h"
#include <time.h>
#include <sys/time.h>

Include dependency graph for xmp_post_wait_tca.c:

Data Structures
struct	_XMP_postreq_info
struct	_XMP_postreq

Typedefs
typedef struct _XMP_postreq_info	_XMP_postreq_info_t
typedef struct _XMP_postreq	_XMP_postreq_t

Functions
void	_xmp_tca_post_wait_initialize ()
	Initialize environment for post/wait directives. More...
void	_xmp_tca_postreq (const int node, const int tag)
void	_xmp_tca_post (const int node, const int tag)
	Post operation. More...
void	_xmp_tca_wait_noargs ()
	Wait operation without node-ref and tag. More...
void	_xmp_tca_wait_node (const int node)
	Wait operation with node-ref. More...
double	getElapsedTime_ (struct timespec *begin, struct timespec *end)
void	_xmp_tca_wait (const int node, const int tag)
	Wait operation with node-ref and tag. More...

Typedef Documentation

_XMP_postreq_info_t

typedef struct _XMP_postreq_info _XMP_postreq_info_t

_XMP_postreq_t

typedef struct _XMP_postreq _XMP_postreq_t

Function Documentation

_xmp_tca_post()

void _xmp_tca_post	(	const int	node,
		const int	tag
	)

Post operation.

Parameters

[in]	node	node number
[in]	tag	tag

{
  if(node == _XMP_world_rank){
    do_post(_XMP_world_rank, tag);
  } else{
    _XMP_tca_comm_send(node, _XMP_TCA_POSTREQ_TAG, tag);
  }
}

Here is the caller graph for this function:

_xmp_tca_post_wait_initialize()

void _xmp_tca_post_wait_initialize

(

)

Initialize environment for post/wait directives.

{
  _postreq.num      = 0;
  _postreq.max_size = _XMP_POSTREQ_TABLE_INITIAL_SIZE;
  _postreq.table    = malloc(sizeof(_XMP_postreq_info_t) * _postreq.max_size);
  pthread_mutex_init(&_postreq.lock, NULL);
  pthread_cond_init(&_postreq.added, NULL);
 
  _postreq.table[0].node = 0;
  _postreq.table[_postreq.max_size-1].node=0;
}

Here is the caller graph for this function:

_xmp_tca_postreq()

void _xmp_tca_postreq	(	const int	node,
		const int	tag
	)

{
  do_post(node, tag);
}

_xmp_tca_wait()

void _xmp_tca_wait	(	const int	node,
		const int	tag
	)

Wait operation with node-ref and tag.

Parameters

[in]	node	node number
[in]	tag	tag

{
  pthread_mutex_lock(&_postreq.lock);
 
  if(_postreq.num == 0){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
  }
 
  if(remove_request(node, tag)){
    pthread_mutex_unlock(&_postreq.lock);
    return;
  }
 
  while(1){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
    
    if(remove_request(node, tag)){
      pthread_mutex_unlock(&_postreq.lock);
      return;
    }
  }
 
  /*
  pthread_mutex_lock(&__lock);
  while(__reqnum == 0){
    pthread_cond_wait(&__notempty, &__lock);
  }
  --__reqnum;
  pthread_mutex_unlock(&__lock);
  return;
  */
  
  /*
  volatile int *reqnum_p = &__reqnum;
  while(1){
    pthread_mutex_lock(&__lock);
    if(*reqnum_p > 0){
      --*reqnum_p;
      pthread_mutex_unlock(&__lock);
      break;
    }else{
      pthread_mutex_unlock(&__lock);
    }
  }
  return ;
  */
  /* //fprintf(stderr, "_xmp_tca_wait(%d, %d)\n", node, tag); */
  /* clock_gettime(CLOCK_MONOTONIC, &begin_ts_2); */
  /* //fprintf(stderr, "_xmp_tca_wait(%d,%d)\n", node, tag); */
  /* volatile int *num_p = &(_postreq.num); */
  /* while(*num_p < 1){ */
  /*   _mm_pause(); */
  /* } */
  /* while(remove_request(node, tag) == false){ */
  /*   //_mm_pause(); */
  /* } */
  /* clock_gettime(CLOCK_MONOTONIC, &end_ts_2); */
  /* //  if(_XMP_world_rank==1) fprintf(stderr, "wait time=%f\n", getElapsedTime_(&begin_ts_2, &end_ts_2)*1000*1000);   */
  /* //if(_XMP_world_rank==1) fprintf(stderr, "between time=%f, %f\n", getElapsedTime_(&begin_ts_2, &begin_ts)*1000*1000, getElapsedTime_(&end_ts, &end_ts_2)*1000*1000); */
}

Here is the caller graph for this function:

_xmp_tca_wait_noargs()

void _xmp_tca_wait_noargs

(

)

Wait operation without node-ref and tag.

{
  /* while(remove_request_noargs() == false){ */
  /*   continue; */
  /* } */
 
  pthread_mutex_lock(&_postreq.lock);
 
  if(_postreq.num == 0){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
  }
 
  if(remove_request_noargs()){
    pthread_mutex_unlock(&_postreq.lock);
    return;
  }
 
  while(1){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
    
    if(remove_request_noargs()){
      pthread_mutex_unlock(&_postreq.lock);
      return;
    }
  }
}

Here is the caller graph for this function:

_xmp_tca_wait_node()

void _xmp_tca_wait_node

(

const int

node

)

Wait operation with node-ref.

Parameters

[in]

node

node number

{
  /* while(remove_request_node(node) == false){ */
  /*   continue; */
  /* } */
 
  pthread_mutex_lock(&_postreq.lock);
 
  if(_postreq.num == 0){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
  }
 
  if(remove_request_node(node)){
    pthread_mutex_unlock(&_postreq.lock);
    return;
  }
 
  while(1){
    pthread_cond_wait(&_postreq.added, &_postreq.lock);
    
    if(remove_request_node(node)){
      pthread_mutex_unlock(&_postreq.lock);
      return;
    }
  }
}

Here is the caller graph for this function:

getElapsedTime_()

double getElapsedTime_	(	struct timespec *	begin,
		struct timespec *	end
	)

                                                                    {
  return (end->tv_sec - begin->tv_sec) + (end->tv_nsec - begin->tv_nsec) * 1e-9;
}