OMK::PvmMessage Class Reference

Defining a message for a message passing virtual machine. More...

#include <OMKPvmMessage.h>

Inheritance diagram for OMK::PvmMessage:

[legend]Collaboration diagram for OMK::PvmMessage:

[legend]List of all members.

Public Types
enum	MessageTag {   ProcessTable,   EndOfSimulation,   EnterBarrier,   SiteName,   LocalInitSuccessfull,   ExitBarrier,   SynchronisationMessage,   MirrorNeedsInitialValues,   InitialValuesForMirror,   NameServiceGetId,   NameServiceGetString,   NameServiceReturnId,   NameServiceReturnString,   NameServiceVerifyLocalNameServer,   NameServiceVerifyResult,   updateProcessTable,   addNewSite,   pingMessage }
Public Member Functions
	PvmMessage (int bufid)
	constructor
virtual	~PvmMessage ()
	destructor
virtual int	getSize () const
	getSize find out the number of bytes used by the buffer
Protected Attributes
int	_currentBuffer

---

Detailed Description

Defining a message for a message passing virtual machine.

Author:

Siames

Version:

1.0

Definition at line 30 of file OMKPvmMessage.h.

---

Member Enumeration Documentation

enum OMK::PvmMessage::MessageTag

Enumerator:

ProcessTable
EndOfSimulation
EnterBarrier
SiteName
LocalInitSuccessfull
ExitBarrier
SynchronisationMessage
MirrorNeedsInitialValues
InitialValuesForMirror
NameServiceGetId
NameServiceGetString
NameServiceReturnId
NameServiceReturnString
NameServiceVerifyLocalNameServer
NameServiceVerifyResult
updateProcessTable	CHADI.
addNewSite
pingMessage	CHADI.

Definition at line 34 of file OMKPvmMessage.h.

                  {ProcessTable,
                   EndOfSimulation, // signal
                   EnterBarrier,   // signal
                   SiteName,
                   LocalInitSuccessfull, //help debugging value = 4
                   ExitBarrier,       // signal
                   SynchronisationMessage,//help debugging value = 6
                   MirrorNeedsInitialValues,//help debugging value = 7
                   InitialValuesForMirror,
                   NameServiceGetId,
                   NameServiceGetString,
                   NameServiceReturnId,
                   NameServiceReturnString,
                   NameServiceVerifyLocalNameServer,
                   NameServiceVerifyResult,
                   updateProcessTable, //added by Chadi to notify already
                   addNewSite,         //turning processes to consider 
                                       // the new added process
                   pingMessage
  };

---

Constructor & Destructor Documentation

PvmMessage::PvmMessage

(

int

bufid

)

constructor

Definition at line 34 of file OMKPvmMessage.cxx.

                                 :
   _currentBuffer ( bufid )
{

}

PvmMessage::~PvmMessage

(

)

[virtual]

destructor

Definition at line 40 of file OMKPvmMessage.cxx.

{

}

---

Member Function Documentation

int PvmMessage::getSize

(

)

const [virtual]

getSize find out the number of bytes used by the buffer

Definition at line 45 of file OMKPvmMessage.cxx.

References _currentBuffer.

Referenced by OMK::PvmOutgoingMessage::insertTimeStamp(), and OMK::Svm::processReceivedMessages().

{
   int bytes( 0 ) ;
   int info,  msgtag, tid ;
   info = pvm_bufinfo ( _currentBuffer, &bytes, &msgtag, &tid ) ;
#ifdef _DEBUGPVMMESS
   std::cerr <<"PvmMessage::getSize() of message of tag "<<msgtag<<", of sender"<<tid<<". I'm "<<pvm_mytid()<<std::endl;
#endif
   assert ( info == 0 );
   return bytes ;
}

---

Member Data Documentation

int OMK::PvmMessage::_currentBuffer [protected]

Definition at line 69 of file OMKPvmMessage.h.

Referenced by OMK::PvmIncomingMessage::deleteCurrentBuffer(), OMK::PvmIncomingMessage::get(), getSize(), OMK::PvmIncomingMessage::hasMessage(), OMK::PvmIncomingMessage::initialise(), OMK::PvmOutgoingMessage::insertTimeStamp(), OMK::PvmOutgoingMessage::pack(), OMK::PvmOutgoingMessage::PvmOutgoingMessage(), OMK::PvmOutgoingMessage::reinitAndRevertPvmContext(), OMK::PvmUnicastMessage::send(), OMK::PvmMulticastMessage::send(), and OMK::PvmOutgoingMessage::~PvmOutgoingMessage().

---