OMKPvmLocalObjectHandle.cxx

Go to the documentation of this file.

#include "OMKPvmLocalObjectHandle.h"

#include "OMKController.h"
#include "OMKProcess.h"
#include "OMKSimulatedObject.h"
#include "OMKSvmLink.h"
using namespace OMK ;

PvmLocalObjectHandle::PvmLocalObjectHandle ( SimulatedObject & obj, Controller & ctrl ) : 
   LocalObjectHandle ( obj, ctrl )
{
   
}


                                                                              
PvmLocalObjectHandle::~PvmLocalObjectHandle () 
{

}

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

void PvmLocalObjectHandle::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 PvmLocalObjectHandle::addProcessOfLocal ( const Process * process ) 
{
   _processesOfLocal.push_back( process ) ;
}

---