OMKSvm.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 OMKSvmHEADER
#define OMKSvmHEADER

#include <cassert>
#include <string>
#include <list>

#include <OMKNameToPointerMap.h>
#include "OMKSvmLink.h"

namespace OMK
{
class Scenario ;
class Process ;
class Controller ;
class PvmController ;
class PvmOutgoingMessage ;
class PvmMulticastMessage ;

class OMKPVM_API Svm
{
public:
  
   Svm (NameToPointerMap<Process> * tab, const Date & latence, const Date & timeOut, const int deadReckoningInterval, const bool yieldNeeded) ;


   virtual ~Svm () ;


   virtual void init (const Date & initialSimulationDate );


   virtual void syncDistributedSites() ;


   virtual void connectToDistributedSimulation ( );


   virtual void createDistributedSimulation(const Date & initialSimulationDate) ;


   virtual void broadcast ( PvmMessage::MessageTag, PvmMulticastMessage * message = NULL ) ;
   

   virtual void synchronizeOn ( PvmController & , PvmMessage::MessageTag tag ) ;
   

   virtual void disconnectFromDistributedSimulation( const Date & deconnexionDate );
   
  
   virtual const Name & getSiteName() const ;


   virtual SvmLink * getLinkToProcessNamed(const  Name & processName );


   virtual Process * getProcessDescriptorNamed(const Name & processName );


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

   virtual Process * testIfDisconnectedProcessNamed(const Name & processName );

   virtual void testIfNewProcessAdded() ;

   PvmIncomingMessage * npp ;

   Date dateVar ;
//------------------fin chadi ajout 1/3------------------------




   virtual void processReceivedMessages(PvmController & parsingController, const PvmMessage::MessageTag tag);
   
   
   virtual void waitAndProcessMessages(PvmController & parsingController, const PvmMessage::MessageTag tag);
 
 
   virtual void waitForMessage(PvmController & parsingController, const PvmMessage::MessageTag tag);
 
   
   virtual void waitForMessageFrom(PvmController & parsingController,
                       const Name & processName,
                       const PvmMessage::MessageTag tag );



   virtual void synchroniseReceiveAndProcessMessages(PvmController & parsingController, const PvmMessage::MessageTag tag);
   virtual void relaxedSynchroniseReceiveAndProcessMessages(PvmController & parsingController, const PvmMessage::MessageTag tag);


   virtual Process * waitForAnswerToBlockingRequest (PvmController & parsingController, PvmMessage::MessageTag tag) ;
   
   virtual void sendCurrentBuffersWithTag(const PvmMessage::MessageTag tag);


   virtual void timestampCurrentSendBuffers (const Date & date) ;

   
   virtual const Date & getSynchronisationLatency() ;


//----------------------chadi ajout 2/3 ----------------------------

// gestion de la liste des deconnectes
   virtual void addToDisconnectedTable ( Name& , Process* );    //( NameToPointerMap<Process>::iterator );
   virtual void removeFromDisconnectedTable ( NameToPointerMap<Process>::iterator );
   virtual bool disconnectedProcess(Name&);
   bool _troubleFlag;
   virtual bool getTroubleFlag() ;
   virtual bool disconnectedTableIsEmpty();
   virtual void addNewSiteToSimulation ( const Date & ) ;
   virtual void addNewSiteRequest ( const Date & date) ;
//   void flushDisconnectedSitesOutgoingBuffer() ;
   virtual bool reconnexionEstablished () ;
   virtual bool testIfSiteRecovered (Process * p) = 0;
   virtual void sendPingMessage () ;
   virtual void removeProcessFromActiveTable() ;
   virtual void removeProcessProlog() ;
   int _simStep ;
   // TDTD : pour savoir qui sont les déconnectés
   virtual std::list<Name> getDisconnectedProcessusList () ;
   virtual std::map<Name, int> getDisconnectedProcessusMap () ;
   // fin TDTD
//----------------------fin chadi ajout 2/3 --------------------------

protected:

   // TDTD : pour savoir qui sont les déconnectés
   std::list<Name> _disconnectedProcessusList ;
   std::map<Name, int> _disconnectedProcessusMap ;
   // fin TDTD

   virtual void addNewWorkstation(const Name & m) = 0;
   

   virtual void removeWorkstation(const Name & m) = 0;


   virtual int spawnProcess (Process * p) = 0;


   virtual SvmLink * createSvmLink(const int & d = 0) = 0;


   virtual int getParentSiteId() = 0;
   

   virtual int getSiteId () = 0 ;


   virtual void groupBarrier (std::string groupName, int numberToJoin) = 0 ; 


   virtual void broadcastToGroup (std::string groupName, PvmMessage::MessageTag ) = 0 ;
   

   virtual void initBeforeMessagePacking() = 0 ; 


   virtual int nonblockingReceive (PvmMessage::MessageTag tag) = 0 ; 


   virtual std::pair<PvmMessage::MessageTag, int> waitForAnyRequests (PvmIncomingMessage & receiveBuffer) = 0;


   virtual void joinSvmGroup (std::string & groupName) = 0;


   virtual void serveNameRequestsUntilEnd () ; 


   NameToPointerMap<Process> * _processTable ;

//-------------------chadi ajout 3/3 ---------------------------
   
   std::vector<int> processSiteIds ;
   
   NameToPointerMap<Process> * _disconnectedTable ;
 
   NameToPointerMap<Process> * _activeProcessTable ; 

   NameToPointerMap<Process> * _temporaryTable ; 
 
   NameToPointerMap<Process> aRecevoir ;

   bool firstTime ;
//-----------------fin chadi ajout 3/3 ------------------------------

   
   std::map<int,Process *> _idToProcessTable ;
   
   int _siteId; 
   

   SvmLink * _linkToCentralSite ; 
   

   Name _siteName ; 


   int _numberOfSlaves ;


   const Date _synchronisationLatency ;

   const Date _synchronisationTimeOut ;

   const Date _deadReckoningInterval ;

   const bool _yieldNeeded ;


   static std::string _slaveGroupName;


   static std::string _masterSiteName ;
}; 
}  // namespace OMK

#endif

---