OMKOutgoingSynchronisationMessage.cpp

Go to the documentation of this file.

#include "OMKOutgoingSynchronisationMessage.h"

#include "OMKPackable.h"
#include "OMKTracer.h"
#include <typeinfo>

#ifdef _DEBUGPVMMESS
#include <iostream>
#endif

using namespace std ;
using namespace OMK ;

OutgoingSynchronisationMessage::OutgoingSynchronisationMessage()
{
}

OutgoingSynchronisationMessage::~OutgoingSynchronisationMessage()
{
}

void OutgoingSynchronisationMessage::reinit() 
{
   // prepare the associated stream for new insertions
   //myos->rdbuf()->seekpos (ios::out, ostrstream::beg) ;
   _myos.seekp (ios::out, ostringstream::beg) ;
}

ostringstream & OutgoingSynchronisationMessage::getOutputStream ( )
{
   _myos.seekp(0, ostringstream::beg);
   return _myos ;
}

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

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


void OutgoingSynchronisationMessage::pack(const Packable & val)
{
#ifdef _DEBUGPVMMESS
   cerr<<"OutgoingSynchronisationMessage:"
       <<this
       <<":pack(const Packable  & ("
       <<typeid (val).name()
       <<") val)";
#endif

   val.pack ( *this ) ;

#ifdef _DEBUGPVMMESS
   cerr<< "end"<<endl;
#endif
}

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

---