---

PsnPvmIncomingMessage.cxx

Go to the documentation of this file.

#include "PsnPvmIncomingMessage.h"

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

#include "PsController.h"
#include "PsPvmException.h"
int PsnPvmIncomingMessage::pvmActiveBuffer = 0 ;



PsnPvmIncomingMessage::PsnPvmIncomingMessage() :
   PsIncomingSynchronisationMessage (),
   PsnPvmMessage (0)
{

}


  
PsnPvmIncomingMessage::PsnPvmIncomingMessage(int bufId) :
   PsIncomingSynchronisationMessage (),
   PsnPvmMessage (bufId)
{
  pvmActiveBuffer = bufId ;
}



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


//--------------------------------------------------------------------
PsnPvmIncomingMessage::~PsnPvmIncomingMessage ()
{
}

const PsDate & PsnPvmIncomingMessage::getMessageDate()
{
   return _messageTimestamp ;
}

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


//--------------------------------------------------------------------
void PsnPvmIncomingMessage::checkForGetErrors( int info)
{
  if (info < 0 )
    {
      cerr<<"PsnPvmIncomingMessage::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;         
      if ( PsController::warningLevel >= PsController::ExceptionOnWarnings ) 
         {            
            throw PsPvmException ( info ) ; 
         }
    }
}



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


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


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




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





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



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




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




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




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



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



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


void PsnPvmIncomingMessage::get (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<<"PsnPvmIncomingMessage::get (string & "<<str<<" )"<<endl;
#endif
  delete [] Cstr ;

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


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




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





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



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




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




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




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



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

---