MWPvmRC

class MWPvmRC : public MWRMComm

A Resource Management and Communication class that uses PVM for underlying support of inter-process communication and resource management

Inheritance:

Public Methods
MWPvmRC(): Constructor...
~MWPvmRC(): Destructor...

Public

A. Resource Management Routines

void exit( int exitval ): Shut down
int setup( int argc, char *argv[], int *my_id, int *master_id ): Initialization
int config( int *nhosts, int *narches, MWWorkerID ***workers ): Does a pvm_config, and stuffs the returned hostinfo struct information into a lot of MWWorkerID's
int start_worker( MWWorkerID *w ): Basically do a pvm_spawn
int init_beginning_workers( int *nworkers, MWWorkerID ***workers ): Start up the workers that are given to us at the beginning
int removeWorker( MWWorkerID *w ): Remove a worker
int read_RMstate( FILE *fp ): Read some state
int write_RMstate( FILE *fp ): Write some state

C. Communication Routines

int initsend( int encoding = PvmDataDefault)
int send( int to_whom, int msgtag )
int recv( int from_whom, int msgtag )
int bufinfo( int buf_id, int *len, int *tag, int *from ): Provide info on the message just received
int pack( char *bytes, int nitem, int stride = 1 ): Pack some bytes
int pack( float *f, int nitem, int stride = 1 ): float
int pack( double *d, int nitem, int stride = 1 ): double
int pack( int *i, int nitem, int stride = 1 ): int
int pack( unsigned int *ui, int nitem, int stride = 1 ): unsigned int
int pack( short *sh, int nitem, int stride = 1 ): short
int pack( unsigned short *ush, int nitem, int stride = 1 ): unsigned short
int pack( long *l, int nitem, int stride = 1 ): long
int pack( unsigned long *ul, int nitem, int stride = 1 ): unsigned long
int pack( char *str ): Pack a NULL-terminated string
int unpack( char *bytes, int nitem, int stride = 1 ): Unpack some bytes
int unpack( float *f, int nitem, int stride = 1 ): float
int unpack( double *d, int nitem, int stride = 1 ): double
int unpack( int *i, int nitem, int stride = 1 ): int
int unpack( unsigned int *ui, int nitem, int stride = 1 ): unsigned int
int unpack( short *sh, int nitem, int stride = 1 ): short
int unpack( unsigned short *ush, int nitem, int stride = 1 ): unsigned short
int unpack( long *l, int nitem, int stride = 1 ): long
int unpack( unsigned long *ul, int nitem, int stride = 1 ): unsigned long
int unpack( char *str ): Unpack a NULL-terminated string

Private Fields
int* hostadd_reqs: The number of outstanding requests for a particular arch
int is_master: Am I the master process or not?

Private Methods
int ask_for_host( int howmany, int archnum ): This function says to pvm: "I would like another machine, please"
void conf(): Shows the pvm virtual machine according to pvm
int do_spawn( MWWorkerID *w ): Do the pvm_spawn and associated stuff
int hostaddlogic( int *num_workers ): Figure out wether or not to ask for hosts, and how many
int min( int *array, int len ): Helper for hostaddlogic()
int setup_notifies( int task_tid ): Set up the proper notifies for a task & host tid

Documentation

A Resource Management and Communication class that uses PVM for underlying support of inter-process communication and resource management.
We *could* do cool things here...like keep track of amount of data sent, to whom, etc. We could also MWprintf ( 99, "..." ) everything that gets sent for heaps and heaps of debugging.

A. Resource Management Routines

Here we implement the pure virtual functions found in ur parent class, MWRMComm.

void exit( int exitval )

Shut down. Calls pvm_exit(), then ::exit(exitval).

int setup( int argc, char *argv[], int *my_id, int *master_id )

Initialization. Does pvm_catchout(), pvm_parent(), and pvm_notifies().

int config( int *nhosts, int *narches, MWWorkerID ***workers )

Does a pvm_config, and stuffs the returned hostinfo struct information into a lot of MWWorkerID's. See the parent class for return details.

int start_worker( MWWorkerID *w )

Basically do a pvm_spawn. We also put some information into w upon return.

Returns:: The tid spawned. Negative number on error.

int init_beginning_workers( int *nworkers, MWWorkerID ***workers )

Start up the workers that are given to us at the beginning. See base class comments for more details.

Parameters:: nworkers - The number of workers at start
workers - A pointer to an array of pointers to MWWorkerID classes. This call will new() memory for the MWWorkerIDs. Also, if (*w)[n]->id2 is -1, that means that the spawn failed for worker number n.

int removeWorker( MWWorkerID *w )