---

PsPvmGlobalController.cxx

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
 *
 */
#ifdef _PVM
#include <sys/time.h>
#include <PsPvmGlobalController.h>
#include <PsnPvmSvm.h>
#include <unistd.h>

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

PsPvmGlobalController::PsPvmGlobalController (PsObjectDescriptor & scenario,
                                              const PsDate & initialDate,
                                              PsNameToPointerMap<PsnProcess> * tab,
                                              const PsString & fConfig,
                                              const PsDate & latence)
  : PsController (scenario, initialDate) {
   // demarrage de la machine virtuelle Siames
   //************************
   // mise en oeuvre PVM
   //************************
   laSVM =  new PsnPvmSvm (tab, latence) ;
   // initialisation de la machine virtuelle
   cout << "Initialisation du reseau........................" << endl;
   // en attendant que les PsStrings fonctionnent effectivement ...
//     char buff [256] ;
//     ostrstream os (buff, 256) ;
//     os << fConfig.getCString () << " " << latence << '\0' ;
   PsString fConfigue (fConfig) ;
   PsString espace(" ");
   //7 fev 1999 : utilisation des PsStrings qui marchent (si on sait s'en servir)
   fConfigue=fConfigue+espace+latence+espace;
   //7/02/1999 : ajout du repertoire de travail dans les options du PVM_LOCAL
   fConfigue=fConfigue+getenv("PWD")+"/";
   cout << "fConfigue = " << fConfigue << endl ;
   laSVM->init (fConfigue, initialDate) ;
   // On recupere le pid de ce pss
   // pidCG = getpid () ;
   // On commence
}

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

PsPvmGlobalController::~PsPvmGlobalController () {
   laSVM->stop () ;
   delete laSVM ;
}



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

void PsPvmGlobalController::run () {
   PsFrequency freqGlobale ;
   //PsnPvmIncomingMessage * message ;

   struct timeval wallTimeAtStart ;
   struct timeval wallTimeAtEnd ;
   struct timeval wallTimeSimulationLength ;

#ifdef INFO
   cout << endl << "Synchronisation globale........................." << endl ;
#endif
   freqGlobale = laSVM->synchroGlobale () ;
#ifdef INFO
   cout << endl << "Execution du controleur global.................." << endl ;
#endif
   laSVM->surveillerSynchroCL () ;
   //cerr << "PsPvmGlobalController::run : synchro reception avant boucle init" << endl ;
   laSVM->envoyerTopCL () ;
   //cerr << "PsPvmGlobalController::run : synchro emission avant boucle init" << endl ;
   laSVM->surveillerSynchroCL () ;
   //cerr << "PsPvmGlobalController::run : synchro reception apres boucle init" << endl ;
   laSVM->envoyerTopCL () ;
   //cerr << "PsPvmGlobalController::run : synchro emission apres boucle init" << endl ;
   cerr<<"Tous les processus sont initialisés et partis"<<endl;
   // On recupere le temps du debut de la simulation
   gettimeofday (&wallTimeAtStart, NULL) ;
         // On met a jour la fin de la simulation
   laSVM->surveillerSynchroCL () ;

   gettimeofday (&wallTimeAtEnd, NULL) ;
   // On calcule la wallTimeSimulationLength de temps depuis le debut
   if (wallTimeAtEnd.tv_usec >= wallTimeAtStart.tv_usec) {
      wallTimeSimulationLength.tv_sec = wallTimeAtEnd.tv_sec - wallTimeAtStart.tv_sec;
      wallTimeSimulationLength.tv_usec = wallTimeAtEnd.tv_usec - wallTimeAtStart.tv_usec;
   } else {
      wallTimeSimulationLength.tv_sec = wallTimeAtEnd.tv_sec - wallTimeAtStart.tv_sec - 1;
      // Une seconde correspond a 1000000 microseconde eh oui ;-D
      wallTimeSimulationLength.tv_usec = 1000000 - wallTimeAtStart.tv_usec + wallTimeAtEnd.tv_usec;
   }
   // On affiche la derive par rapport au temps
   cerr << "-------------------------------------" << endl
        << "Duree effective : " << wallTimeSimulationLength.tv_sec
        << " s " << wallTimeSimulationLength.tv_usec << endl ;
#ifdef INFO
   cout << endl << "Fin du controleur global........................" << endl ;
#endif
}

#endif

---