OMKPvmMulticastMessage.cxx

Go to the documentation of this file.

#include "OMKPvmMulticastMessage.h"

#include <cassert>
#include <pvm3.h>

#ifdef _DEBUGPVMMESS
#include <iostream>
#endif
using namespace OMK ;

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

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

void PvmMulticastMessage::send(PvmMessage::MessageTag tag) 
{
#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 ) ;
}

---