OMKPvmIncomingMessage.cxx

Go to the documentation of this file.

#include "OMKPvmIncomingMessage.h"

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

#include "OMKController.h"
#include "OMKPvmException.h"
#include "OMKBasicTypes.h"

using namespace std ;
using namespace OMK ;

int PvmIncomingMessage::pvmActiveBuffer = 0 ;

PvmIncomingMessage::PvmIncomingMessage() :
   IncomingSynchronisationMessage (),
   PvmMessage (0)
{

}


  
PvmIncomingMessage::PvmIncomingMessage(int bufId) :
   IncomingSynchronisationMessage (),
   PvmMessage (bufId)
{
  pvmActiveBuffer = bufId ;
}



void PvmIncomingMessage::initialise ( int bufId )
{
  _currentBuffer = bufId ;
  pvmActiveBuffer = bufId ;
  if (_myis != 0 )
    {
      delete _myis ;
      _myis = 0 ;
    }
  if (_currentBuffer != 0) _messageTimestamp.unpack(*this) ;
}

void PvmIncomingMessage::deleteCurrentBuffer()
{
  pvm_freebuf(_currentBuffer);
}


//--------------------------------------------------------------------
PvmIncomingMessage::~PvmIncomingMessage ()
{

}

const Date & PvmIncomingMessage::getMessageDate()
{
   return _messageTimestamp ;
}

bool PvmIncomingMessage::hasMessage () const 
{
   return _currentBuffer != 0 ;
}


//--------------------------------------------------------------------
void PvmIncomingMessage::checkForGetErrors( int info)
{
  if (info < 0 )
    {
      cerr<<"PvmIncomingMessage::checkForGetErrors ERROR ";
      assert ( false ) ;
      switch ( info ) 
        {
        case PvmNoData:
          cerr<<"Reading beyond the end of the receive buffer. Most likely cause is trying to get more items than were originally packed into the buffer. This can also happen if a new reception without buffer saving happened in the course of geting all the data of a previous message";
          break;
        case PvmNoBuf:
          cerr<<"There is no active receive buffer to get.";
          break;
        case PvmBadMsg:
           cerr<<"The received message can to be decoded. Most likely because the hosts are heterogeneous and the users specified an incompatible encoding.";
          break;
        default:
          cerr<<"unexpected error: ";
        }
      cerr<<endl;         
        OMASSERT( false ) ;
    }
}



void PvmIncomingMessage::get (bool & val)
{
   assert ( pvmActiveBuffer == _currentBuffer ) ;
   char realVal ;
   int info = pvm_upkbyte ( &realVal, 1, 1 ) ;
   val = realVal ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (char & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
   checkForGetErrors ( info ) ;
}


void PvmIncomingMessage::get (char & val)
{
   assert ( pvmActiveBuffer == _currentBuffer ) ;
   int info = pvm_upkbyte ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (char & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
   checkForGetErrors ( info ) ;
}


void PvmIncomingMessage::get (long & val)
{
   assert ( pvmActiveBuffer == _currentBuffer ) ;
   int info = pvm_upklong ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (long & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
   checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (unsigned long & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkulong ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned long & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}





void PvmIncomingMessage::get (int & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkint ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (int & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}



void PvmIncomingMessage::get (unsigned int & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkuint ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned int & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (float & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkfloat ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (float & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (double & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkdouble ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (double & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (short & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkshort ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (short & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}



void PvmIncomingMessage::get (unsigned short & val)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkushort ( &val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned short & "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}



void PvmIncomingMessage::get (char * ch)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkstr ( ch ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (char * "<<ch<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}


void PvmIncomingMessage::get (std::string & str)
{
  assert ( pvmActiveBuffer == _currentBuffer );

  unsigned int stringSize ;
  int info = pvm_upkuint ( &stringSize, 1, 1 ) ;
  checkForGetErrors ( info ) ;

  char * Cstr = new char [stringSize] ;

  info = pvm_upkstr ( Cstr ) ;
  checkForGetErrors ( info ) ;
  assert (Cstr[stringSize-1] == '\0' ) ;

  str = Cstr ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (std::string & "<<str<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  delete [] Cstr ;

}
void PvmIncomingMessage::get (char * val, int cnt)
{
   assert ( pvmActiveBuffer == _currentBuffer ) ;
   int info = pvm_upkbyte ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (char * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
   checkForGetErrors ( info ) ;
}


void PvmIncomingMessage::get (long * val, int cnt)
{
   assert ( pvmActiveBuffer == _currentBuffer ) ;
   int info = pvm_upklong ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (long * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
   checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (unsigned long * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkulong ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned long * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}





void PvmIncomingMessage::get (int * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkint ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (int * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}



void PvmIncomingMessage::get (unsigned int * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkuint ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned int * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (float * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkfloat ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (float * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (double * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkdouble ( val, 1, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (double * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}




void PvmIncomingMessage::get (short * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkshort ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (short * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}



void PvmIncomingMessage::get (unsigned short * val, int cnt)
{
  assert ( pvmActiveBuffer == _currentBuffer );
  int info = pvm_upkushort ( val, cnt, 1 ) ;
#ifdef _DEBUGPVMMESS
  cerr<<"PvmIncomingMessage::get (unsigned short * "<<val<<" )"<< " Buffer " << _currentBuffer << endl;
#endif
  checkForGetErrors ( info ) ;
}

---