OMKPvmController.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 OMKPvmControllerHEADER
#define OMKPvmControllerHEADER

//---------------------------------------------------------------------

#include <OMKDistributedController.h>
#include <OMKSvmLink.h>

//---------------------------------------------------------------------
namespace OMK
{
class Svm ;
class MirrorObjectHandle ;

//---------------------------------------------------------------------
//---------------------------------------------------------------------

class OMKPVM_API PvmController : public DistributedController 
{
public :
   
   PvmController (ObjectDescriptor & arbre,
                    const Date & initialSimulationDate,
                    int argc,
                    char * argv []) ;

   virtual ~PvmController () ;


   virtual void run () ;


   virtual void advanceSimulatedDate ();


   virtual void computeNextSimulationStep();
   
   
   virtual void finish() ;


   virtual const Name & getProcessName () const ;
   

   virtual Svm * getDistributedVirtualMachine () ;
   

   virtual void makeSynchronisationMessage (NameToPointerMap<ReferenceObjectHandle> & referenceObjects) ;

   
   virtual void parseSynchronisationMessage (PvmIncomingMessage * message) ;
   

   virtual void waitForAnswerToBlockingRequest (PvmMessage::MessageTag tag) ;


   virtual void sendInitialValuesToMirror (PvmIncomingMessage & message) ;

   virtual void init () ;


   /******************chadi ajout***********************/
   //   virtual void parseUpdateProcessTableMessage (PvmIncomingMessage * message) ;
   
   std::vector<Name> _publicIsolatedMirrorObjectsVector ;
   virtual std::vector<Name> getIsolatedMirrorList();
   std::vector<Name> _publicNonIsolatedMirrorObjectsVector ;
   virtual std::vector<Name> getNonIsolatedMirrorList();
   virtual bool testIfTroubleOccured() ;
   virtual void createNewSite ( const Date & ) ;
  // TDTD pour gérer les noms des déconnectés...
  virtual std::list<Name> getDisconnectedProcessusList () ;
  virtual std::map<Name, int> getDisconnectedProcessusMap () ;
   //*********************fin ************************

   
protected :

   virtual Date getPurgeDate () ;


   virtual MirrorObjectHandle * createMirrorObject (ObjectDescriptor * objectDescription ) ;
   

   virtual DuplicatedObjectHandle * newOMKDuplicatedObjectHandle (SimulatedObject & object);


//------------------chadi ajout 1/1 ------------------

 virtual LocalObjectHandle * newOMKLocalObjectHandle (SimulatedObject & object);

//-------------------fin 1/1 -------------------------   






   virtual MirrorObjectHandle * newOMKMirrorObjectHandle (SimulatedObject & obj);


   virtual ReferenceObjectHandle * newOMKReferenceObjectHandle(SimulatedObject & object, 
                                                                  Controller & controller,
                                                                  SignalDispatcher * signalDispatcher);


   virtual int getOutputHistorySize(void) ;
   

   Svm * _distributedVirtualMachine ;


   virtual ObjectHandle * removeObjectFromDataStructures(const Name & nom);


   bool _finishing ;

   void (PvmController::* receiveAndProcessMessages) (void) ;
   void synchronizedReceiveAndProcessMessages (void) ;
   void relaxedReceiveAndProcessMessages (void) ;

} ; // PvmController

//---------------------------------------------------------------------
} // namespace OMK
#endif

---