OMKPvmDuplicatedObjectHandle.cxx

Go to the documentation of this file.

#include "OMKPvmDuplicatedObjectHandle.h"

#include "OMKController.h"
#include "OMKProcess.h"
#include "OMKSimulatedObject.h"
#include "OMKSvmLink.h"

#ifdef _DEBUGPVMMESS
#include <iostream>
#endif
using namespace OMK ;

PvmDuplicatedObjectHandle::PvmDuplicatedObjectHandle ( SimulatedObject & obj, Controller & ctrl ) :
   DuplicatedObjectHandle ( obj, ctrl )
{
}

PvmDuplicatedObjectHandle::~PvmDuplicatedObjectHandle ()
{
}

void PvmDuplicatedObjectHandle::broadcastEvent ( const Event & event )
{
  //send the event to all copies of oneself
  for (std::list<const Process *>::const_iterator i = _processesOfDuplicates.begin() ;
       i != _processesOfDuplicates.end () ;
       ++i) 
    {
      if (getSimulatedObject().getController().getObjectDescriptor().getProcess() != (*i)->getProcessName() )
        {
#ifdef _DEBUGPVMMESS
          std::cerr<<"PvmDuplicatedObjectHandle::broadcastEvent"<<std::endl;
#endif
          if ( ! (*i)->getSvmLink ()->getOutgoingBuffer().isTimeStamped() )
            {
              (*i)->getSvmLink ()->getOutgoingBuffer().
                insertTimeStamp ( getSimulatedObject().getController().getSimulatedDate() ) ;
             }
          (*i)->getSvmLink ()->getOutgoingBuffer()<< getSimulatedObject().getName ()
                                                  << EventReceived
                                                  << event  ;
        }
     }
  //receive the event oneself
  ReferenceObjectHandle::receiveEvent ( event.clone() ) ;
}



void PvmDuplicatedObjectHandle::unpack (IncomingSynchronisationMessage & in) 
{
   RequestType typeMess ;
   int messageType ;

   in >> messageType ;
   typeMess = static_cast <RequestType> (messageType) ;

   if ( typeMess == EventReceived )
      {
         Event * event ;
         Name classToCreate ;
         EventIdentifier eventId;
         Date eventDate;
         Name sender, receiver ;
         in >> classToCreate >> eventId>> eventDate>>sender>>receiver ;
         event = EventCreator::createEvent (classToCreate, eventId, eventDate, sender, receiver ) ;
         event->unpack ( in ) ;
         ReferenceObjectHandle::receiveEvent ( event ) ;
      }
}



void PvmDuplicatedObjectHandle::addProcessOfDuplicate ( const Process * process ) 
{
   _processesOfDuplicates.push_back( process ) ;
}

---