PVM_CODEC

Description

This object is designed for message buffering, adding message handling features (including retrieving messages with specified attributes) other process IDs management etc.

Warnings

Changes since the last version :

• There is a different behaviour of constructor and startProcess. And the "procType" argument of constructor became obligatory.
• getSenderType () -> getProcessType ()
• getPids (...) has one more parameter, for retrieving pids of specific tasks use getParentPids (...), getChildPids (...) and getApplicationPids (...).
• int maxBuf -> int *maxBufMsgAmounts. Now there can be different "maxBuf" to every registered task. And there are new functions to modify "maxBufs" like (setMaxBufBufByPid (...), ...).
• buffer... -> send... (for example : bufferTypes (...) -> sendTypes (...)) so the sending functions have the same declaration as in PVM_COVER but they perform buffering.

Methods

Public:
============= Constructors and Destructors ============
PVM_CODEC (int procType);
~PVM_CODEC ();

============= General functions =============
int startProcess (char *fileName, char **argv, int taskAmount);
int startProcess (char *fileName, char **argv, char *hostName, int taskAmount, int *procPids);
int getProcessType ();

============= Coating functions =============
BOOL getPids (int **pids, int **procTypes, int *pidAmount);
BOOL getParentPids (int **pids, int *pidAmount);
BOOL getChildPids (int **pids, int *pidAmount);
BOOL getApplicationPids (int **pids, int *pidAmount);
int getMaxBufByPid (int procPid);
void setMaxBufByPid (int procPid, int maxAmount);
void setMaxBufByType (int procType, int maxAmount);
void setMaxBufToAll (int maxAmount);
int getRecMsgAmount (int priority);

============= Receiving =============
BOOL retrieveMsgs ();
BOOL getSpecificMsg (int senderPid, int senderType, int priorityLow, int priorityHigh, int msgTag, int msgSpecTag, BYTE **msg);
BOOL peekSpecificMsg (int senderPid, int senderType, int priorityLow, int priorityHigh, int msgTag, int msgSpecTag, BYTE **msg);
BOOL getNextRecMsg (int priority, BYTE **msg);
BOOL peekNextRecMsg (int priority, BYTE **msg);
void wasteNextRecMsg (int priority);
void wasteRecMsgs (int priority);
void wasteAllMsgs ();
void* getMsgDataPtr (void *msg);
MSG_COMMON* getMsgInfoPtr (void *msg);
int getMsgTag (void *msg);
int getMsgPriority (void *msg);
int getMsgSenderType (void *msg);
int getMsgSpecTag (void *msg);
int getMsgLen (void *msg);
int getMsgSenderPid (void *msg);
int getMsgContentType (void *msg);
int getMsgDataAmount (void *msg);
BOOL isRecMsg (int priority);

============= Sending =============
BOOL sendTypes (int destProc, int senderType, int priority, int msgTag, int specMsgTag, BYTE type, void *types, int typeAmount);
BOOL multicastTypes (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, BYTE type, void *types, int typeAmount);
BOOL sendBytes (int destProc, int senderType, int priority, int msgTag, int specMsgTag, BYTE *lpBytes, int byteAmount);
BOOL multicastBytes (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, BYTE *lpBytes, int byteAmount);
BOOL sendTypeMap (int destProc, int senderType, int priority, int msgTag, int specMsgTag, void *lpMap, int mapLen);
BOOL multicastTypeMap (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, void *lpMap, int mapLen);
void flushPid (int pid);
void flushAll ();

Protected:
int getPidIndex (int pid);

Private:
void checkMyMsgs ();

PVM_CODEC (int procType);

~PVM_CODEC ();

int startProcess (char *fileName, char **argv, int taskAmount);

int startProcess (char *fileName, char **argv, char *hostName, int taskAmount, int *procPids);

int getProcessType ();

BOOL getPids (int **pids, int **procTypes, int *pidAmount);

BOOL getParentPids (int **pids, int *pidAmount);
BOOL getChildPids (int **pids, int *pidAmount);
BOOL getApplicationPids (int **pids, int *pidAmount);

int getMaxBufByPid (int procPid);

void setMaxBufByPid (int procPid, int maxAmount);
void setMaxBufByType (int procType, int maxAmount);
void setMaxBufToAll (int maxAmount);

int getRecMsgAmount (int priority);

BOOL retrieveMsgs ();

BOOL getSpecificMsg (int senderPid, int senderType, int priorityLow, int priorityHigh, int msgTag, int msgSpecTag, BYTE **msg);
BOOL peekSpecificMsg (int senderPid, int senderType, int priorityLow, int priorityHigh, int msgTag, int msgSpecTag, BYTE **msg);

BOOL getNextRecMsg (int priority, BYTE **msg);
BOOL peekNextRecMsg (int priority, BYTE **msg);

void wasteNextRecMsg (int priority);
void wasteRecMsgs (int priority);
void wasteAllMsgs ();

void* getMsgDataPtr (void *msg);

Arguments:

Returns:

MSG_COMMON* getMsgInfoPtr (void *msg);

Arguments:

Returns:

int getMsgTag (void *msg);
int getMsgPriority (void *msg);
int getMsgSenderType (void *msg);
int getMsgSpecTag (void *msg);
int getMsgLen (void *msg);
int getMsgSenderPid (void *msg);
int getMsgContentType (void *msg);
int getMsgDataAmount (void *msg);

Arguments:

Returns:

BOOL isRecMsg (int priority);

BOOL sendTypes (int destProc, int senderType, int priority, int msgTag, int specMsgTag, BYTE type, void *types, int typeAmount);
BOOL multicastTypes (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, BYTE type, void *types, int typeAmount);
BOOL sendBytes (int destProc, int senderType, int priority, int msgTag, int specMsgTag, BYTE *lpBytes, int byteAmount);
BOOL multicastBytes (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, BYTE *lpBytes, int byteAmount);
BOOL sendTypeMap (int destProc, int senderType, int priority, int msgTag, int specMsgTag, void *lpMap, int mapLen);
BOOL multicastTypeMap (int *destProc, int destProcAmount, int senderType, int priority, int msgTag, int specMsgTag, void *lpMap, int mapLen);

void flushPid (int pid);

void flushAll ();

int getPidIndex (int pid);

void checkMyMsgs ();

Atributes

Public:
BYTE * recBuffers[PRIORITY_PAMOUNT];
int recBufLens[PRIORITY_PAMOUNT], recMsgAmounts[PRIORITY_PAMOUNT];
int processType;
int *procPids, *procTypes, procAmount;
Protected:
Private:
BYTE **sendBuffers;
int *sendBufLens, *sendMsgAmounts, *maxBufMsgAmounts;

BYTE *recBuffers[PRIORITY_PAMOUNT];

int recBufLens[PRIORITY_PAMOUNT], recMsgAmounts[PRIORITY_PAMOUNT];

int processType;

int *procPids, *procTypes, procAmount;

BYTE ** sendBuffers;

int *sendBufLens, *sendMsgAmounts, *maxBufMsgAmounts;