PRT communication request implementation. More...

#include "prt_request.h"

Include dependency graph for prt_request.c:

Functions
prt_request_t *	prt_request_new (prt_packet_t *packet, int count, MPI_Datatype datatype, int peer, int tag)
	request constructor More...

void	prt_request_destroy (prt_request_t *request)
	request destructor Request is only an envelope for a packet. Request destruction does not affect the packet. Need be, packet is destroyed separately (e.g. send completion). More...

void	prt_request_send (prt_request_t *request)
	Post a send request. Detects a possible overflow of the request size. More...

void	prt_request_recv (prt_request_t *request)
	Post a receive request. Detects a possible overflow of the request size. More...

int	prt_request_test (prt_request_t *request)
	Test a request. Trace only completed requests. More...

void	prt_request_cancel (prt_request_t *request)
	Cancel a request. Cancel the request, release the packet, free the request object. More...

Detailed Description

PRT communication request implementation.

Author: Jakub Kurzak

Definition in file prt_request.c.

Function Documentation

void prt_request_cancel ( prt_request_t * request )

Cancel a request. Cancel the request, release the packet, free the request object.

Parameters

request

Definition at line 150 of file prt_request.c.

References prt_request_s::packet, prt_assert, prt_packet_release(), and prt_request_s::request.

 {
     int retval;
     // Cancel the request.
     retval = MPI_Cancel(&request->request);
     prt_assert(retval == MPI_SUCCESS, "error in MPI_Cancel");
 
     // Release the packet.
     prt_packet_release(request->packet);
 
     // Free the request.
     free(request);
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void prt_request_destroy ( prt_request_t * request )

request destructor Request is only an envelope for a packet. Request destruction does not affect the packet. Need be, packet is destroyed separately (e.g. send completion).

Parameters

request

Definition at line 48 of file prt_request.c.

 {
     free(request);
 }

Here is the caller graph for this function:

prt_request_t* prt_request_new	(	prt_packet_t *	packet,
		int	count,
		MPI_Datatype	datatype,
		int	peer,
		int	tag
	)

request constructor

Parameters

packet
count
datatype
peer
tag

Returns: new request

Definition at line 25 of file prt_request.c.

References prt_request_s::count, prt_request_s::datatype, prt_request_s::packet, prt_request_s::peer, prt_assert, and prt_request_s::tag.

 {
     prt_request_t *request = (prt_request_t*)malloc(sizeof(prt_request_t));
     prt_assert(request != NULL, "malloc failed");
     request->packet = packet;
     request->count = count;
     request->datatype = datatype;
     request->peer = peer;
     request->tag = tag;
     return request;
 }

Here is the caller graph for this function:

void prt_request_recv ( prt_request_t * request )

Post a receive request. Detects a possible overflow of the request size.

Parameters

request

Definition at line 92 of file prt_request.c.

References prt_request_s::count, prt_packet_s::data, prt_request_s::datatype, OliveDrab, prt_request_s::packet, prt_request_s::peer, prt_assert, prt_request_s::request, svg_trace_start(), svg_trace_stop(), and prt_request_s::tag.

 {
     int retval;
     int type_size;
     long request_size;
 
     // Compute type size. Check for overflow.
     MPI_Type_size(request->datatype, &type_size);
     request_size = (long)request->count*type_size;
     prt_assert(request_size <= INT_MAX, "request size overflow");
 
     // Post and trace the request. Check the status.
     svg_trace_start(0);
     retval = MPI_Irecv(
         request->packet->data,
         request->count*type_size,
         MPI_BYTE,
         request->peer,
         request->tag,
         MPI_COMM_WORLD,
         &request->request);
     svg_trace_stop(0, -OliveDrab);
     prt_assert(retval == MPI_SUCCESS, "error in MPI_Isend");
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void prt_request_send ( prt_request_t * request )

Post a send request. Detects a possible overflow of the request size.

Parameters

request

Definition at line 60 of file prt_request.c.

References prt_request_s::count, DarkKhaki, prt_packet_s::data, prt_request_s::datatype, prt_request_s::packet, prt_request_s::peer, prt_assert, prt_request_s::request, svg_trace_start(), svg_trace_stop(), and prt_request_s::tag.

 {
     int retval;
     int type_size;
     long request_size;
 
     // Compute type size. Check for overflow.
     MPI_Type_size(request->datatype, &type_size);
     request_size = (long)request->count*type_size;
     prt_assert(request_size <= INT_MAX, "request size overflow");
 
     // Post and trace the request. Check the status.
     svg_trace_start(0);
     retval = MPI_Isend(
         request->packet->data,
         request->count*type_size,
         MPI_BYTE,
         request->peer,
         request->tag,
         MPI_COMM_WORLD,
         &request->request);
     svg_trace_stop(0, -DarkKhaki);
     prt_assert(retval == MPI_SUCCESS, "error in MPI_Isend");
 }

Here is the call graph for this function:

Here is the caller graph for this function:

int prt_request_test ( prt_request_t * request )

Test a request. Trace only completed requests.

Parameters

request

Return values

0	Operation pending.
1	Operation completed.

Definition at line 127 of file prt_request.c.

References prt_assert, prt_request_s::request, RosyBrown, prt_request_s::status, svg_trace_start(), and svg_trace_stop().

 {
     int flag;
     int retval;
 
     // Test the request.
     // Check the status.
     // Trace if completed.
     svg_trace_start(0);
     retval = MPI_Test(&request->request, &flag, &request->status);
     if (flag == 1)
         svg_trace_stop(0, -RosyBrown);
     prt_assert(retval == MPI_SUCCESS, "error in MPI_Test");
     return flag;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

Functions

Detailed Description

Function Documentation