OMK::PvmMulticastMessage Class Reference

class refining the pvm outgoing message for a send with any number of recipients More...

#include <OMKPvmMulticastMessage.h>

Inheritance diagram for OMK::PvmMulticastMessage:

[legend]Collaboration diagram for OMK::PvmMulticastMessage:

[legend]List of all members.

Public Member Functions
virtual	~PvmMulticastMessage ()
	destructor
	PvmMulticastMessage (const std::vector< int > &)
	constructor specifying the distant site IDs to which message will be sent
virtual void	send (PvmMessage::MessageTag tag)
	send all previously packed data to all destinations and reinitiliases the send buffer
Protected Attributes
int	_numberOfRecepients
	the number of recepients
int *	_recepients
	array of recepients ids

---

Detailed Description

class refining the pvm outgoing message for a send with any number of recipients

Author:

D. Margery

Version:

1.0

Definition at line 15 of file OMKPvmMulticastMessage.h.

---

Constructor & Destructor Documentation

PvmMulticastMessage::~PvmMulticastMessage

(

)

[virtual]

destructor

Definition at line 22 of file OMKPvmMulticastMessage.cxx.

References _recepients.

{
  assert (_recepients != NULL ) ;
  delete [] _recepients ;
}

PvmMulticastMessage::PvmMulticastMessage

(

const std::vector< int > &

)

constructor specifying the distant site IDs to which message will be sent

Definition at line 11 of file OMKPvmMulticastMessage.cxx.

References _numberOfRecepients, and _recepients.

                                                                            :
  _numberOfRecepients ( recepients.size () ),
  _recepients ( 0 ) 
{
  _recepients = new int [ _numberOfRecepients ] ;
  for ( int i = 0 ; i < _numberOfRecepients ; ++i )
    {
      _recepients [i] = recepients [i] ;
    }
}

---

Member Function Documentation

void PvmMulticastMessage::send

(

PvmMessage::MessageTag

tag

)

[virtual]

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

Implements OMK::PvmOutgoingMessage.

Definition at line 28 of file OMKPvmMulticastMessage.cxx.

References OMK::PvmMessage::_currentBuffer, _numberOfRecepients, _recepients, OMK::PvmOutgoingMessage::checkForSendErrors(), and OMK::PvmOutgoingMessage::reinitAndRevertPvmContext().

Referenced by OMK::Svm::addNewSiteToSimulation(), OMK::Svm::createDistributedSimulation(), and OMK::Svm::disconnectFromDistributedSimulation().

{
#ifdef _DEBUGPVMMESS
   std::cerr<<"PvmMulticastMessage:"<<(void *)this<<": send("<<tag<<") to "<<_numberOfRecepients<<" recipients"<<std::endl; 
#endif
  int oldbuf = pvm_setsbuf ( _currentBuffer ) ;

  int info = pvm_mcast ( _recepients, _numberOfRecepients, tag ) ;

  checkForSendErrors ( info ) ;

  reinitAndRevertPvmContext ( oldbuf ) ;
}

---

Member Data Documentation

int OMK::PvmMulticastMessage::_numberOfRecepients [protected]

the number of recepients

Definition at line 29 of file OMKPvmMulticastMessage.h.

Referenced by PvmMulticastMessage(), and send().

int* OMK::PvmMulticastMessage::_recepients [protected]

array of recepients ids

Definition at line 32 of file OMKPvmMulticastMessage.h.

Referenced by PvmMulticastMessage(), send(), and ~PvmMulticastMessage().

---