xmp_post_wait_mpi.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_mpi.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_mpi_post_wait_initialize ()
	Initialize environment for post/wait directives. More...
void	receive_request (int *node, int *tag)
void	_xmp_mpi_post (const int node, int tag)
	Post operation. More...
void	_xmp_mpi_wait_noargs ()
	Wait operation without node-ref and tag. More...
void	_xmp_mpi_wait_node (const int node)
	Wait operation with node-ref. More...
void	_xmp_mpi_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_mpi_post()

void _xmp_mpi_post	(	const int	node,
		int	tag
	)

Post operation.

Parameters

[in]	node	node number
[in]	tag	tag

{
  if(node == _XMP_world_rank){
    do_post(_XMP_world_rank, tag);
  } else{
    //XACC_DEBUG("post (node=%d, tag=%d)", node, tag);
    MPI_Send(&tag, 1, MPI_INT, node, _XMP_N_MPI_TAG_POSTREQ, MPI_COMM_WORLD);
  }
}

Here is the caller graph for this function:

_xmp_mpi_post_wait_initialize()

void _xmp_mpi_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);
 
  _postreq.table[0].node = 0;
  _postreq.table[_postreq.max_size-1].node=0;
}

Here is the caller graph for this function:

_xmp_mpi_wait()

void _xmp_mpi_wait	(	const int	node,
		const int	tag
	)

Wait operation with node-ref and tag.

Parameters

[in]	node	node number
[in]	tag	tag

{
  XACC_DEBUG("wait (%d,%d)", node,tag);
  if(remove_request(node, tag)){
    XACC_DEBUG("wait end (already recved)");
    return;
  }
 
  while(1){
    int recv_tag;
    int recv_node;
    receive_request(&recv_node, &recv_tag);
    if(recv_node == node && recv_tag == tag){
      XACC_DEBUG("wait end (recved)");
      return;
    }
    do_post(recv_node, recv_tag);
  }
}

Here is the caller graph for this function:

_xmp_mpi_wait_noargs()

void _xmp_mpi_wait_noargs

(

)

Wait operation without node-ref and tag.

{
  if(remove_request_noargs()){
    return;
  }
 
  int tag;
  int node;
  receive_request(&tag, &node);
}

Here is the caller graph for this function:

_xmp_mpi_wait_node()

void _xmp_mpi_wait_node

(

const int

node

)

Wait operation with node-ref.

Parameters

[in]

node

node number

{
  if(remove_request_node(node)){
    return;
  }
 
  while(1){
    int recv_tag;
    int recv_node;
    receive_request(&recv_node, &recv_tag);
    if(recv_node == node){
      return;
    }
    do_post(recv_node, recv_tag);
  }
}

Here is the caller graph for this function:

receive_request()

void receive_request	(	int *	node,
		int *	tag
	)

{
  MPI_Status status;
  XACC_DEBUG("receive_request");
  MPI_Recv(tag, 1, MPI_INT, MPI_ANY_SOURCE, _XMP_N_MPI_TAG_POSTREQ, MPI_COMM_WORLD, &status);
  *node = status.MPI_SOURCE;
  XACC_DEBUG("receivee_request, node=%d, tag=%d", *node, *tag);
}