---

PsnPvmDuplicatedObjectHandle.cxx

Go to the documentation of this file.

#include "PsnPvmDuplicatedObjectHandle.h"

#include "PsnProcess.h"
#include "PsSimulatedObject.h"
#include "PsnSvmLink.h"

PsnPvmDuplicatedObjectHandle::PsnPvmDuplicatedObjectHandle ( PsSimulatedObject & obj, PsController & ctrl ) : 
   PsnDuplicatedObjectHandle ( obj, ctrl )
{
   
}


                                                                              
PsnPvmDuplicatedObjectHandle::~PsnPvmDuplicatedObjectHandle () 
{

}



void PsnPvmDuplicatedObjectHandle::broadcastEvent ( const PsEvent & event )
{
   PsnPvmOutgoingMessage * outgoingMessage ;
   //send the event to all copies of oneself
   for (list<const PsnProcess *>::const_iterator i = _processesOfDuplicates.begin() ;
        i != _processesOfDuplicates.end () ;
        ++i) 
      {
         if (getSimulatedObject().getController().getObjectDescriptor().getProcess() != (*i)->getProcessName() )
            {
               //cerr<<"sending "<<event<<" to "<<getSimulatedObject().getName ()<<" of process "<<(*i)->getProcessName()<<endl;
#ifdef _DEBUGPVMMESS
               cerr<<"PsnPvmDuplicatedObjectHandle::broadcastEvent"<<endl;
#endif
               (*i)->getSvmLink ()->getOutgoingBuffer()<< getSimulatedObject().getName ()  
                                                       << EventReceived   
                                                       << event  ;
            }
      }
   //receive the event oneself
   PsnReferenceObjectHandle::receiveEvent ( event.clone() ) ;
}



void PsnPvmDuplicatedObjectHandle::unpack (PsIncomingSynchronisationMessage & in) 
{
   PsnRequestType typeMess ;
   int messageType ;

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

   if ( typeMess == EventReceived )
      {
         PsEvent * event ;
         PsName classToCreate ;
         PsEventIdentifier eventId;
         PsDate eventDate;
         PsName sender, receiver ;
         in >> classToCreate >> eventId>> eventDate>>sender>>receiver ;
         event = PsEventCreator::createEvent (classToCreate, eventId, eventDate, sender, receiver ) ;
         event->unpack ( in ) ;
         PsnReferenceObjectHandle::receiveEvent ( event ) ;
      }
}



void PsnPvmDuplicatedObjectHandle::addProcessOfDuplicate ( const PsnProcess * process ) 
{
   _processesOfDuplicates.push_back( process ) ;
}

---