---

PsDistributedController.h

Go to the documentation of this file.

/*
 * This file is part of openMask © INRIA, CNRS, Universite de Rennes 1 1993-2002, thereinafter the Software
 * 
 * The Software has been developped within the Siames Project. 
 * INRIA, the University of Rennes 1 and CNRS jointly hold intellectual property rights
 * 
 * The Software has been registered with the Agence pour la Protection des
 * Programmes (APP) under registration number IDDN.FR.001.510008.00.S.P.2001.000.41200
 *
 * This file may be distributed under the terms of the Q Public License
 * version 1.0 as defined by Trolltech AS of Norway and appearing in the file
 * LICENSE.QPL included in the packaging of this file.
 *
 * Licensees holding valid specific licenses issued by INRIA, CNRS or Université de Rennes 1 
 * for the software may use this file in accordance with that specific license 
 *
 */
#ifndef PsDistributedControllerHEADER
#define PsDistributedControllerHEADER


#include <PsController.h>

#include "PsnDuplicatedObjectHandle.h"

class PsDuplicatedObject ;
class PsnMirrorObjectHandle ;
class PsnSimulationTree ;

class PsDistributedController : public PsController 
{
public:
   PsDistributedController(PsObjectDescriptor & initialObjects, const PsDate & initialDate);

   virtual ~PsDistributedController();

   virtual PsSimulatedObject * getPointerToSimulatedObjectNamed (const PsName & objectName );
   
   virtual void dispatchEvent(PsEvent * event);



   virtual bool processEvent ( PsEvent * event ) ;
 
   virtual void purgeMemoryFromOldEvents ( const PsDate & dateOfOldestKept );


   virtual void broadcastEventsForSignal ( PsEvent & event, const PsEventIdentifier & sigId ) ;


   virtual bool receiveRegistrationForSignal(const PsEventIdentifier & sigId, 
                                  const PsName & registrant, 
                                  const PsEventIdentifier & eventId);


   virtual bool receiveCancellationForSignal ( const PsEventIdentifier & sigId , 
                                              const PsName & registrant ) ;

protected:
   virtual PsnMirrorObjectHandle * newPsnMirrorObjectHandle (PsSimulatedObject & obj) = 0 ;


   virtual PsnDuplicatedObjectHandle * newPsnDuplicatedObjectHandle (PsSimulatedObject & obj) = 0 ;


   virtual void deleteObjectHandle ( PsnObjectHandle * objectHandle ) ;

   virtual void createControlledObjects (const PsObjectDescriptor * subTree) ;

   virtual void createObject(const PsObjectDescriptor & newObjectDescription, const PsName & fathersName) ;

   virtual void processNewObjectDeclaration ( PsObjectDescriptor & declaration, const PsDate & declarationDate ) ;

   virtual PsnMirrorObjectHandle * createMirrorObject ( PsObjectDescriptor * objectDescription );


   virtual PsnDuplicatedObjectHandle * createDuplicatedObject( PsObjectDescriptor * objectDescription );

   typedef hash_map<PsName,PsnMirrorObjectHandle *,PsName::hashFunctionObject > MirrorObjectsContainerType ;

   MirrorObjectsContainerType _mirrorObjectsMap ;

   PsNameToPointerMap<PsnDuplicatedObjectHandle> _duplicatedObjectsMap;


   virtual void processStartEventOf(PsnReferenceObjectHandle * objectHandle) ;

   PsNameToPointerMap<PsnReferenceObjectHandle> tableDesNonInitialises ;

   PsNameToPointerMap<PsnReferenceObjectHandle> tableDesInitialises ;

   PsName _processName ;

   list<pair<PsEventIdentifier, pair <PsEvent *, PsDate> > > _broadcastedSignals ;

protected:
   class RegistrationData : public PsType 
   {
   public:
      RegistrationData() {} ;

      RegistrationData (const PsEventIdentifier & sig,
                        const PsName & registrant, 
                        const PsEventIdentifier & eventId) ;

      virtual ~RegistrationData() ;

      virtual void unpack (PsIncomingSynchronisationMessage &) ;
      
      virtual void pack (PsOutgoingSynchronisationMessage &) const ;

      virtual void extract(istream & in) ;

      virtual void insertInStream (ostream & out) const ;

      virtual PsPolatorNT * createPolator() ;

      PsEventIdentifier _sig ;
      PsName _registrant ;
      PsEventIdentifier _eventId ;
   }; 



   class CancellationData : public PsType
   {
   public:
      CancellationData(){};

      CancellationData  ( const PsEventIdentifier & sigId , const PsName & registrant ) ;

      virtual ~CancellationData() ;

      virtual void unpack (PsIncomingSynchronisationMessage &) ;
      
      virtual void pack (PsOutgoingSynchronisationMessage &) const ;

      virtual void extract(istream & in) ;

      virtual void insertInStream (ostream & out) const ;

      virtual PsPolatorNT * createPolator() ;

      PsEventIdentifier _sigId ;

      PsName _registrant ;
   };
};

#endif

---