---

PsnSvm.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 PsSvmHEADER
#define PsSvmHEADER

#include <set>
#include <string>

#include <Psn.h>
#include <PsList.h>
#include <PsNameToPointerMap.h>
class PsnScenario;
#include "PsnSvmLink.h"
class PsnProcess;
class PsController ;
class PsPvmController ;
class PsnPvmOutgoingMessage ;
class PsnPvmMulticastMessage ;

class PsnSvm
{
public:
  
   PsnSvm (PsNameToPointerMap<PsnProcess> * tab, const PsDate & latence) ;


   virtual ~PsnSvm () ;


   virtual void init (const PsDate & initialSimulationDate );


   virtual void syncDistributedSites() ;


   virtual void connectToDistributedSimulation ( );


   virtual void createDistributedSimulation(const PsDate & initialSimulationDate) ;


   virtual void broadcast ( PsnPvmMessage::MessageTag, PsnPvmMulticastMessage * message = NULL ) ;
   

   virtual void synchronizeOn ( PsPvmController & , PsnPvmMessage::MessageTag tag ) ;
   

   virtual void disconnectFromDistributedSimulation( const PsDate & deconnexionDate );
   
  
   virtual const PsName & getSiteName() const ;


   virtual PsnSvmLink * getLinkToProcessNamed(const  PsName & processName );


   virtual PsnProcess * getProcessDescriptorNamed(const PsName & processName );


   void processReceivedMessages(PsPvmController & parsingController, const PsnPvmMessage::MessageTag tag);
   
   
   void waitAndProcessMessages(PsPvmController & parsingController, const PsnPvmMessage::MessageTag tag);
 
 
   void waitForMessage(PsPvmController & parsingController, const PsnPvmMessage::MessageTag tag);
 
   
   void waitForMessageFrom(PsPvmController & parsingController,
                       const PsName & processName,
                       const PsnPvmMessage::MessageTag tag );



   void synchroniseReceiveAndProcessMessages(PsPvmController & parsingController, const PsnPvmMessage::MessageTag tag);


   PsnProcess * waitForAnswerToBlockingRequest (PsPvmController & parsingController, PsnPvmMessage::MessageTag tag) ;
   
   void sendCurrentBuffersWithTag(const PsnPvmMessage::MessageTag tag);


   void timestampCurrentSendBuffers (const PsDate & date) ;

   
   virtual const PsDate & getSynchronisationLatency() ;

protected:
   virtual void addNewWorkstation(const PsName & m) = 0;
   

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


   virtual int spawnProcess (PsnProcess * p) = 0;


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


   virtual int getParentSiteId() = 0;
   

   virtual int getSiteId () = 0 ;


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


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

   virtual void initBeforeMessagePacking() = 0 ; 


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


   virtual pair<PsnPvmMessage::MessageTag, int> waitForAnyRequests (PsnPvmIncomingMessage & receiveBuffer) = 0;


   virtual void joinSvmGroup (string & groupName) = 0;


   virtual void serveNameRequestsUntilEnd () ; 


   PsNameToPointerMap<PsnProcess> * _processTable ;
   
   map<int,PsnProcess *> _idToProcessTable ;
   
   int _siteId; 
   

   PsnSvmLink * _linkToCentralSite ; 
   

   PsName _siteName ; 


   int _numberOfSlaves ;


   const PsDate _synchronisationLatency ;


   static string _slaveGroupName;


   static string _masterSiteName ;
}; 


#endif

---