---

PsOutgoingSynchronisationMessage.cxx

Go to the documentation of this file.

#include "PsOutgoingSynchronisationMessage.h"

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

PsOutgoingSynchronisationMessage::PsOutgoingSynchronisationMessage()
{
}


PsOutgoingSynchronisationMessage::~PsOutgoingSynchronisationMessage()
{
}


void PsOutgoingSynchronisationMessage::reinit() 
{
   // prepare the associated stream for new insertions
   //myos->rdbuf()->seekpos (ios::out, ostrstream::beg) ;
#ifdef _USESSTREAM
   _myos.seekp (ios::out, ostringstream::beg) ;
#else
   _myos.seekp(0,ostrstream::beg) ;
#endif  
}


#ifdef _USESSTREAM
ostringstream & PsOutgoingSynchronisationMessage::getOutputStream ( )
{
   _myos.seekp(0, ostringstream::beg);
   return _myos ;
}
#else
ostrstream & PsOutgoingSynchronisationMessage::getOutputStream ( )
{
   _myos.seekp(0, ostrstream::beg);
   return _myos ;
}
#endif

void PsOutgoingSynchronisationMessage::packOutputStream ( ) 
{
#ifdef _DEBUGPVMMESS
  cerr<<"PsOutgoingSynchronisationMessage:"<<(void *)this<<":packOutputMessage () "<<endl;
#endif
  
#ifdef _USESSTREAM

  pack ( _myos.str() ) ;
  
  _myos.seekp(0, ostringstream::beg) ;

#else
  _myos.freeze( 1 ) ;
  
  int messageSize = _myos.pcount () ;
  char * messageToPack = _myos.str() ;

  assert ( messageToPack[messageSize - 1] == 0 ) ;
  
  // int ind = myos->tellp();
  // mess[ind] = '\0' ;

  pack ( messageSize ) ;
  pack ( messageToPack ) ;

  _myos.freeze( 0 ) ;

  // prepare the associated stream for new insertions
  //myos->rdbuf()->seekpos (ios::out, ostrstream::beg) ;
  _myos.seekp(0, ostrstream::beg) ;
#endif
}


void PsOutgoingSynchronisationMessage::pack(const PsPackable & val)
{
#ifdef _DEBUGPVMMESS
   cerr<<"PsOutgoingSynchronisationMessage:"
       <<this
       <<":pack(const PsPackable  & ("
       <<typeid (val).name()
       <<") val)";
#endif
   val.pack ( *this ) ;
#ifdef _DEBUGPVMMESS
   cerr<< "end"<<endl;
#endif
}


PsOutgoingSynchronisationMessage & PsOutgoingSynchronisationMessage::operator << (char * val) 
{
   pack ( val ) ;
   return *this ;
}

---