OMK::PvmUnicastMessage Class Reference

refine the Pvm outgoing message with a send to only one destination site. More...

#include <OMKPvmUnicastMessage.h>

Inheritance diagram for OMK::PvmUnicastMessage:

[legend]Collaboration diagram for OMK::PvmUnicastMessage:

[legend]List of all members.

Public Member Functions
virtual	~PvmUnicastMessage ()
	destructor
	PvmUnicastMessage (int distantSiteId)
	constructor specifying the distant site ID to which message is sent
virtual void	send (PvmMessage::MessageTag tag)
	send all previously packed data to destination and reinitiliases the send buffer
virtual void	setDistantSiteId (int distantSiteId)
	change the distant site id
Protected Attributes
int	_distantSiteId

---

Detailed Description

refine the Pvm outgoing message with a send to only one destination site.

Author:

David Margery

Version:

1.0

Definition at line 13 of file OMKPvmUnicastMessage.h.

---

Constructor & Destructor Documentation

PvmUnicastMessage::~PvmUnicastMessage

(

)

[virtual]

destructor

Definition at line 15 of file OMKPvmUnicastMessage.cxx.

{
}

PvmUnicastMessage::PvmUnicastMessage

(

int

distantSiteId

)

constructor specifying the distant site ID to which message is sent

Definition at line 10 of file OMKPvmUnicastMessage.cxx.

                                                       :
  _distantSiteId ( distantSiteId )
{
}

---

Member Function Documentation

void PvmUnicastMessage::send

(

PvmMessage::MessageTag

tag

)

[virtual]

send all previously packed data to destination and reinitiliases the send buffer

Implements OMK::PvmOutgoingMessage.

Definition at line 24 of file OMKPvmUnicastMessage.cxx.

References OMK::PvmMessage::_currentBuffer, _distantSiteId, OMK::PvmOutgoingMessage::_timeStamped, OMK::PvmOutgoingMessage::checkForChangedBuffer(), OMK::PvmOutgoingMessage::checkForSendErrors(), and OMK::PvmOutgoingMessage::reinitAndRevertPvmContext().

Referenced by OMK::Svm::addNewSiteRequest(), OMK::Svm::addNewSiteToSimulation(), OMK::Svm::disconnectFromDistributedSimulation(), OMK::PvmMirrorObjectHandle::registerToReferenceObject(), OMK::PvmController::sendInitialValuesToMirror(), and OMK::PvmSvmLink::sendOutgoingBuffer().

{
  assert ( _timeStamped ) ;

  assert ( _currentBuffer != 0 ) ;

  assert ( _distantSiteId != 0 ) ;

#ifdef _DEBUGPVMMESS
  std::cerr<<"PvmUnicastMessage:"<<this<<":send ("<<tag<<") to "<< _distantSiteId << " buffer "<<_currentBuffer<<std::endl;
#endif

  int oldbuf = pvm_setsbuf ( _currentBuffer ) ;

  checkForChangedBuffer ( oldbuf, __LINE__, __FILE__ ) ;

  int info = pvm_send ( _distantSiteId, tag ) ;

  checkForSendErrors ( info ) ;

  reinitAndRevertPvmContext ( oldbuf ) ;
}

void PvmUnicastMessage::setDistantSiteId

(

int

distantSiteId

)

[virtual]

change the distant site id

Definition at line 19 of file OMKPvmUnicastMessage.cxx.

References _distantSiteId.

Referenced by OMK::PvmSvmLink::unpack().

{
  _distantSiteId = distantSiteId ;
}

---

Member Data Documentation

int OMK::PvmUnicastMessage::_distantSiteId [protected]

Definition at line 28 of file OMKPvmUnicastMessage.h.

Referenced by send(), and setDistantSiteId().

---