OMK::PvmLocalObjectHandle Class Reference

An object handle for duplicated objects. More...

#include <OMKPvmLocalObjectHandle.h>

Inheritance diagram for OMK::PvmLocalObjectHandle:

[legend]Collaboration diagram for OMK::PvmLocalObjectHandle:

[legend]List of all members.

Public Member Functions
virtual	~PvmLocalObjectHandle ()
	destructor
	PvmLocalObjectHandle (SimulatedObject &, Controller &)
	constructor
virtual void	addProcessOfLocal (const Process *process)
	add a process to the data structure storing the location of copies
virtual void	unpack (IncomingSynchronisationMessage &)
	unpack from a pvm message
Protected Member Functions
virtual void	broadcastEvent (const Event &event)
	broadcast event
Protected Attributes
std::list< const Process * >	_processesOfLocal
	The data structure used to store the processes to broadcast information to.

---

Detailed Description

An object handle for duplicated objects.

This object handle is a reference object handle for object who have more than one reference object ( duplicated objects and the controller). This implementation id concerned with the propagation of events to the other reference objects.

Author:

ChadiEl Zammar

Version:

1.0 (warning, not implementing dynamic discovery of sites the object is duplicated on. All sites are supposed)

Definition at line 34 of file OMKPvmLocalObjectHandle.h.

---

Constructor & Destructor Documentation

PvmLocalObjectHandle::~PvmLocalObjectHandle

(

)

[virtual]

destructor

Definition at line 17 of file OMKPvmLocalObjectHandle.cxx.

{

}

PvmLocalObjectHandle::PvmLocalObjectHandle	(	SimulatedObject &	,
		Controller &
	)

constructor

Definition at line 9 of file OMKPvmLocalObjectHandle.cxx.

                                                                                      : 
   LocalObjectHandle ( obj, ctrl )
{
   
}

---

Member Function Documentation

void PvmLocalObjectHandle::addProcessOfLocal

(

const Process *

process

)

[virtual]

add a process to the data structure storing the location of copies

Implements OMK::LocalObjectHandle.

Definition at line 68 of file OMKPvmLocalObjectHandle.cxx.

References _processesOfLocal.

{
   _processesOfLocal.push_back( process ) ;
}

void PvmLocalObjectHandle::unpack

(

IncomingSynchronisationMessage &

)

[virtual]

unpack from a pvm message

Reimplemented from OMK::Flowable.

Definition at line 45 of file OMKPvmLocalObjectHandle.cxx.

References OMK::EventCreator::createEvent(), OMK::EventReceived, OMK::ReferenceObjectHandle::receiveEvent(), and OMK::Event::unpack().

{
   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::broadcastEvent

(

const Event &

event

)

[protected, virtual]

broadcast event

Implements OMK::LocalObjectHandle.

Definition at line 22 of file OMKPvmLocalObjectHandle.cxx.

References _processesOfLocal, OMK::Event::clone(), OMK::EventReceived, OMK::SimulatedObject::getName(), OMK::ObjectHandle::getSimulatedObject(), and OMK::ReferenceObjectHandle::receiveEvent().

{
  // 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() ) ;
}

---

Member Data Documentation

std::list<const Process *> OMK::PvmLocalObjectHandle::_processesOfLocal [protected]

The data structure used to store the processes to broadcast information to.

Definition at line 54 of file OMKPvmLocalObjectHandle.h.

Referenced by addProcessOfLocal(), and broadcastEvent().

---