prt_channel.h

Go to the documentation of this file.

#ifndef PRT_CHANNEL_H
#define PRT_CHANNEL_H

#include "prt.h"

#ifdef __cplusplus
extern "C" {
#endif

struct prt_vdp_s;
struct prt_packet_s;

typedef struct prt_channel_s {
    struct prt_vdp_s *vdp;          // back pointer to the parent VDP
    int count;                      // number of elements in a packet
    MPI_Datatype datatype;          // datatype of elements in a packet
    int *src_tuple;                 // tuple of the source VDP
    int src_slot;                   // slot in the source VDP
    int *dst_tuple;                 // tuple of the destination VDP
    int dst_slot;                   // slot in the destination VDP
    int dst_node;                   // destination node
    icl_deque_t *packets;           // list of data packets
    int tag;                        // tag for process-to-process communication
} prt_channel_t;

typedef enum prt_channel_direction_e {
    PrtInputChannel, PrtOutputChannel
} prt_channel_direction_t;

prt_channel_t* prt_channel_new(
    int count, MPI_Datatype datatype,
    int *src_tuple, int src_slot,
    int *dst_tuple, int dst_slot);
void prt_channel_delete(prt_channel_t *channel);
void prt_channel_push(prt_channel_t *channel, struct prt_packet_s *packet);
struct prt_packet_s *prt_channel_pop(prt_channel_t *channel);
int prt_channel_empty(prt_channel_t *channel);
int prt_channel_compare(void *channel1, void *channel2);

#ifdef __cplusplus
}
#endif

#endif /* PRT_CHANNEL_H */