src/Message/CommPVM.h

Go to the documentation of this file.

// -*- C++ -*-
/***************************************************************************
 *
 * The IPPL Framework
 * 
 *
 * Visit http://people.web.psi.ch/adelmann/ for more details
 *
 ***************************************************************************/

#ifndef COMM_PVM_H
#define COMM_PVM_H

/*
 * CommPVM.h - PVM-specific communications object for use with the
 * Ippl framework.
 * Allows user to establish id's for available nodes, establish connections,
 * and send/receive data.
 */

// include files
#include "Message/Communicate.h"


class CommPVM : public Communicate {

public:
  // constructor and destructor
  // constructor arguments: command-line args, and number of processes
  // to start (if < 0, start the 'default' number, i.e. the number of
  // hosts in a PVM virtual machine, the number of nodes in an O2K, etc)
  CommPVM(int argc = 0, char** argv = NULL, int procs = (-1));
  virtual ~CommPVM(void);

  // return the name of this item
  virtual const char *name() const { return "PVM"; }

protected:

  //
  // implementation-specific routines (which begin with 'my')
  //    these should be provided in a derived class, and contain the
  //    comm-library-specific code
  //

  // send a message ... arguments are the Message itself, the
  // destination node, the 'user' tag, and the 'encoding' tag.
  // Messages should be sent via the underlying mechanism by using the
  // encoding tag (one of the COMM_ tags),
  // and should embed the information about what the user
  // tag is in the data sent between nodes.  Return success.
  virtual bool mysend(Message *, int node, int utag, int etag);

  // receive a message from the given node and user tag.  Return a NEW
  // Message object if a message arrives, or NULL if no message available.
  // node will be set to the node from which the message was sent.
  // tag will be set to the 'user tag' for that message.
  // etag is the 'encoding' tag, and must be one of the COMM_ tags. 
  // Only messages sent via the underlying mechanism with the
  // given etag are checked.  When one is found, the user tag and sending
  // node are extracted from the sent data.
  // If node = COMM_ANY_NODE, checks for messages from any node.
  // If tag = COMM_ANY_TAG, checks for messages with any user tag.
  virtual Message *myreceive(int& node, int& tag, int etag);

  // Synchronize all processors (everybody waits for everybody
  // else to get here before returning to calling function).
  virtual void mybarrier(void);

private:
  char *execName;       // name of executable (without path)
  int *tids;            // task ID's for the tasks used by this application

  // take data from the given Message, and pack it into the current send buf
  void pack_message(Message *, int);

  // take data out of the current receive buf and create a new Message
  Message *unpack_message(int &node, int &tag);

};

#endif // COMM_PVM_H

/***************************************************************************
 * $RCSfile: CommPVM.h,v $   $Author: adelmann $
 * $Revision: 1.1.1.1 $   $Date: 2003/01/23 07:40:28 $
 * IPPL_VERSION_ID: $Id: CommPVM.h,v 1.1.1.1 2003/01/23 07:40:28 adelmann Exp $ 
 ***************************************************************************/

---