---

PsnPvmMulticastMessage.cxx

Go to the documentation of this file.

#include "PsnPvmMulticastMessage.h"

#include "stdio.h"
#include "pvm3.h"

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



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



void PsnPvmMulticastMessage::send(PsnPvmMessage::MessageTag tag) 
{
#ifdef _DEBUGPVMMESS
   cerr<<"PsnPvmMulticastMessage:"<<(void *)this<<": send("<<tag<<")"<<endl; 
#endif
  int oldbuf = pvm_setsbuf ( _currentBuffer ) ;

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

  checkForSendErrors ( info ) ;

  reinitAndRevertPvmContext ( oldbuf ) ;
}

---