OMK::PvmDuplicatedObjectHandle Class Reference

An object handle for duplicated objects. More...

#include <OMKPvmDuplicatedObjectHandle.h>

Inheritance diagram for OMK::PvmDuplicatedObjectHandle:

[legend]Collaboration diagram for OMK::PvmDuplicatedObjectHandle:

[legend]List of all members.

Public Member Functions
virtual	~PvmDuplicatedObjectHandle ()
	destructor
	PvmDuplicatedObjectHandle (SimulatedObject &, Controller &)
	constructor
virtual void	addProcessOfDuplicate (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 * >	_processesOfDuplicates
	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:

David Margery

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 OMKPvmDuplicatedObjectHandle.h.

---

Constructor & Destructor Documentation

PvmDuplicatedObjectHandle::~PvmDuplicatedObjectHandle

(

)

[virtual]

destructor

Definition at line 18 of file OMKPvmDuplicatedObjectHandle.cxx.

{
}

PvmDuplicatedObjectHandle::PvmDuplicatedObjectHandle	(	SimulatedObject &	,
		Controller &
	)

constructor

Definition at line 13 of file OMKPvmDuplicatedObjectHandle.cxx.

                                                                                                :
   DuplicatedObjectHandle ( obj, ctrl )
{
}

---

Member Function Documentation

void PvmDuplicatedObjectHandle::addProcessOfDuplicate

(

const Process *

process

)

[virtual]

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

Implements OMK::DuplicatedObjectHandle.

Definition at line 74 of file OMKPvmDuplicatedObjectHandle.cxx.

References _processesOfDuplicates.

{
   _processesOfDuplicates.push_back( process ) ;
}

void PvmDuplicatedObjectHandle::unpack

(

IncomingSynchronisationMessage &

)

[virtual]

unpack from a pvm message

Reimplemented from OMK::Flowable.

Definition at line 50 of file OMKPvmDuplicatedObjectHandle.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 PvmDuplicatedObjectHandle::broadcastEvent

(

const Event &

event

)

[protected, virtual]

broadcast event

Implements OMK::DuplicatedObjectHandle.

Definition at line 22 of file OMKPvmDuplicatedObjectHandle.cxx.

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

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

---

Member Data Documentation

std::list<const Process *> OMK::PvmDuplicatedObjectHandle::_processesOfDuplicates [protected]

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

Definition at line 56 of file OMKPvmDuplicatedObjectHandle.h.

Referenced by addProcessOfDuplicate(), and broadcastEvent().

---