---

PsIncomingSynchronisationMessage.cxx

Go to the documentation of this file.

#include "PsIncomingSynchronisationMessage.h"

#include "PsPackable.h"
#include "assert.h"
#include <typeinfo>

PsIncomingSynchronisationMessage::PsIncomingSynchronisationMessage() :
   _myis ( 0 )
{
}


PsIncomingSynchronisationMessage::~PsIncomingSynchronisationMessage()
{
   if ( _myis != NULL ) delete _myis ;
}



#ifdef _USESSTREAM
istringstream & PsIncomingSynchronisationMessage::getInputStream () 
#else
istrstream & PsIncomingSynchronisationMessage::getInputStream () 
#endif
{
   assert ( _myis != NULL ) ;
   return *_myis ;
}



void PsIncomingSynchronisationMessage::unpackInputStream ( ) 
{
   if ( _myis != NULL ) delete _myis ;

#ifdef _USESSTREAM
   string inputStream ;
   get ( inputStream ) ;
  _myis = new istringstream ( inputStream ) ;
#else

  int messageLength ;

  get ( messageLength ) ;

  char * message = new char [messageLength] ;

  get ( message ) ;

  assert (message [messageLength -1] == 0 ) ;
  
  _myis = new istrstream (message, messageLength) ;
#endif
}



PsIncomingSynchronisationMessage & PsIncomingSynchronisationMessage::operator >> (char * val) 
{
   get ( val ) ; 
   return *this ;
}


void PsIncomingSynchronisationMessage::get (PsPackable & val) 
{
   val.unpack(*this) ;
}

---