Virtual Data Processor (VDP) More...

#include "prt.h"

Include dependency graph for prt_vdp.h:

This graph shows which files directly or indirectly include this file:

Data Structures
struct	prt_vdp_s
	Virtual Data Processor (VDP) Is uniquely identified by a tuple. Fires for a predefined number of cycles. Has a fixed number of input and output channels. Has a persistent local store. More...

Typedefs
typedef void(*	prt_vdp_function_t )(int , int, struct prt_channel_s , struct prt_channel_s , void , void *)
	VDP's function pointer Defines the type of the pointer to the VDP's function. More...

typedef struct prt_vdp_s	prt_vdp_t
	Virtual Data Processor (VDP) Is uniquely identified by a tuple. Fires for a predefined number of cycles. Has a fixed number of input and output channels. Has a persistent local store. More...

Functions
prt_vdp_t *	prt_vdp_new (int *tuple, int counter, prt_vdp_function_t function, size_t local_store_size, int num_inputs, int num_outputs, int color)
	VDP constructor. More...

void	prt_vdp_delete (prt_vdp_t *vdp)
	VDP destructor Delete all local output channels. All local input channels are destroyed as output channels of other VDPs. More...

void	prt_vdp_destroy (prt_vdp_t *vdp)

void	prt_vdp_channel_insert (prt_vdp_t vdp, struct prt_channel_s channel, enum prt_channel_direction_e direction, int slot)

int	prt_vdp_ready (prt_vdp_t *vdp)
	Check if a VDP is ready to fire. Only checks established channels. (NULL channels don't prevent firing.) More...

Detailed Description

Virtual Data Processor (VDP)

Author: Jakub Kurzak

Definition in file prt_vdp.h.

Typedef Documentation

typedef void(* prt_vdp_function_t)(int *, int, struct prt_channel_s **, struct prt_channel_s **, void *, void *)

VDP's function pointer Defines the type of the pointer to the VDP's function.

Definition at line 28 of file prt_vdp.h.

typedef struct prt_vdp_s prt_vdp_t

Virtual Data Processor (VDP) Is uniquely identified by a tuple. Fires for a predefined number of cycles. Has a fixed number of input and output channels. Has a persistent local store.

Function Documentation

void prt_vdp_channel_insert	(	prt_vdp_t *	vdp,
		struct prt_channel_s *	channel,
		enum prt_channel_direction_e	direction,
		int	slot
	)

void prt_vdp_delete ( prt_vdp_t * vdp )

VDP destructor Delete all local output channels. All local input channels are destroyed as output channels of other VDPs.

Parameters

vdp

Definition at line 77 of file prt_vdp.c.

References prt_channel_s::dst_node, prt_vdp_s::input, prt_vdp_s::local_store, prt_vsa_s::node_rank, prt_vdp_s::num_inputs, prt_vdp_s::num_outputs, prt_vdp_s::output, prt_assert, prt_channel_delete(), prt_tuple_delete(), prt_vdp_s::thread, prt_vdp_s::tuple, prt_channel_s::vdp, and prt_thread_s::vsa.

 {
     // Check for a NULL VDP.
     prt_assert(vdp != NULL, "NULL VDP");
 
     // Delete the tuple.
     prt_assert(vdp->tuple != NULL, "NULL tuple");
     prt_tuple_delete(vdp->tuple);
 
     int i;
     // Delete local output channels.
     for (i = 0; i < vdp->num_outputs; i++) {
         prt_channel_t *channel = vdp->output[i];
         if (channel != NULL)
             if (channel->dst_node == channel->vdp->thread->vsa->node_rank)
                 prt_channel_delete(channel);
     }
     // Free array of inputs.
     if (vdp->num_inputs > 0)
         free(vdp->input);
 
     // Free array of outputs.
     if (vdp->num_outputs > 0)
         free(vdp->output);
 
     // Free local store.
     if (vdp->local_store != NULL)
         free(vdp->local_store);
 
     // Free the VDP.
     free(vdp);
 }

Here is the call graph for this function:

void prt_vdp_destroy ( prt_vdp_t * vdp )

prt_vdp_t* prt_vdp_new	(	int *	tuple,
		int	counter,
		prt_vdp_function_t	function,
		size_t	local_store_size,
		int	num_inputs,
		int	num_outputs,
		int	color
	)

VDP constructor.

Parameters

tuple	VDP's unique identificator
counter	number of times to fire the VDP
function	function implementing VDP's actions
local_store_size	size of VDP's persistent local store in bytes
num_inputs	number of input channels
num_outputs	number of output channels

Returns: new VDP

Definition at line 26 of file prt_vdp.c.

References prt_vdp_s::color, prt_vdp_s::counter, prt_vdp_s::function, prt_vdp_s::input, prt_vdp_s::local_store, prt_vdp_s::num_inputs, prt_vdp_s::num_outputs, prt_vdp_s::output, prt_assert, prt_vdp_s::thread, and prt_vdp_s::tuple.

 {
     // Allocate the VDP.
     prt_vdp_t *vdp = (prt_vdp_t*)malloc(sizeof(prt_vdp_t));
     prt_assert(vdp != NULL, "malloc failed");
 
     // Check parameters.
     prt_assert(tuple != NULL, "NULL tuple");
     prt_assert(function != NULL, "NULL function");
     prt_assert(counter > 0, "counter less or equal zero");
 
     // Initialize the VDP.
     vdp->thread = NULL;
     vdp->tuple = tuple;
     vdp->counter = counter;
     vdp->function = function;
     vdp->color = color;
 
     // Initialize input channels.
     vdp->num_inputs = num_inputs;
     if (vdp->num_inputs > 0) {
         vdp->input = (prt_channel_t**)calloc(vdp->num_inputs, sizeof(prt_channel_t*));
         prt_assert(vdp->input != NULL, "malloc failed");
     }
     // Initialize output channels.
     vdp->num_outputs = num_outputs;
     if (vdp->num_outputs > 0) {
         vdp->output = (prt_channel_t**)calloc(vdp->num_outputs, sizeof(prt_channel_t*));
         prt_assert(vdp->output != NULL, "malloc failed");
     }
     // Allocate local store.
     if (local_store_size > 0) {
         vdp->local_store = (void*)malloc(local_store_size);
         prt_assert(vdp->local_store != NULL, "malloc failed");
     }
     // Return the VDP.
     return vdp;
 }

int prt_vdp_ready ( prt_vdp_t * vdp )

Check if a VDP is ready to fire. Only checks established channels. (NULL channels don't prevent firing.)

Parameters

vdp

Return values

0	not ready
1	ready

Definition at line 170 of file prt_vdp.c.

References prt_vdp_s::input, prt_vdp_s::num_inputs, prt_assert, and prt_channel_empty().

 {
     // Check for a NULL VDP.
     prt_assert(vdp != NULL, "NULL VDP");
 
     int i;
     // FOR each input channel.
     for (i = 0; i < vdp->num_inputs; i++)
         // IF the channel was established.
         if (vdp->input[i] != NULL)
             // IF the list of packets is empty.
             if (prt_channel_empty(vdp->input[i]))
                 // Return "not ready".
                 return 0;
 
     // Return "ready".
     return 1;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

Data Structures

Typedefs

Functions

Detailed Description

Typedef Documentation

Function Documentation