---

PsnBenchScheduler.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
 *
 */
#include "PsnBenchScheduler.h"

#include <fstream>
#include <sys/time.h>
#include <unistd.h>
#include "PsnBenchScheduler.h"
#include "PsnReferenceObjectHandle.h"
#include "PsSimulatedObject.h"

PsnBenchScheduler::PsnBenchScheduler(unsigned int numberOfSteps, 
                                     const int & _sampleIndex, 
                                     unsigned int _numberOfSamples,
                                     ostream & outputFile ) 
   : PsnFrameScheduler ( numberOfSteps ),
     _sampleIndex ( _sampleIndex ),
     _numberOfSamples( _numberOfSamples ),
     _outputFile ( outputFile )
{

}

PsnBenchScheduler::~PsnBenchScheduler() 
{
   assert (_outputFile.good() ) ;
   map<PsnReferenceObjectHandle *, long*>::iterator pTab;
   long moyenne ;
   long nbValeurs ;
   for (pTab= _tabVitesse.begin();
        pTab != _tabVitesse.end(); 
        pTab++)
      {
         //make sure the object still exists 
         assert ( dynamic_cast<const PsSimulatedObject *>( &((*pTab).first->getSimulatedObject() ) ) );
         _outputFile<<"Table des temps pour "<<(*pTab).first->getSimulatedObject().getObjectDescriptor().getName()<<endl;;
         moyenne=0;
         nbValeurs=0;
         for(int i=0;i<_numberOfSamples;i++) {
            long duree=(*pTab).second[i];
            _outputFile<<duree<<endl;
            if (duree>=0) {
#ifdef _SGI
               moyenne = moyenne+(duree/1000);
#else
               moyenne +=duree ;
#endif
               nbValeurs++;
            }
         }
         _outputFile<<"Average running time for "<<(*pTab).first->getSimulatedObject().getName()<<": "<<moyenne/nbValeurs<<" microseconds"<<endl; 
      }
}

void PsnBenchScheduler::addToScheduable(PsnReferenceObjectHandle * ref, unsigned int when ) {
   PsnFrameScheduler::addToScheduable( ref , when ) ;
   if ( _tabVitesse.find (ref) == _tabVitesse.end() ) {
      //to avoid multiple creation in multi-fréquential mode
      _tabVitesse [ ref ] = new long[ _numberOfSamples ];
   }
}



void PsnBenchScheduler::removeFromScheduable(PsnReferenceObjectHandle * ref) {
   PsnFrameScheduler::removeFromScheduable( ref ) ;
   assert ( _tabVitesse.find (ref) != _tabVitesse.end() ) ;

   map<PsnReferenceObjectHandle *, long*>::iterator pTab = _tabVitesse.find (ref) ;

   assert ( dynamic_cast<const PsSimulatedObject *>( &(*pTab).first->getSimulatedObject() ) );

   long moyenne=0;
   long nbValeurs=0;
   for(int i=0;i<_numberOfSamples;i++) {
      long duree=(*pTab).second[i];
      //_outputFile<<duree<<endl;
      if (duree>=0) {
#ifdef _SGI
         moyenne = moyenne+(duree/1000);
#else
         moyenne +=duree ;
#endif
         nbValeurs++;
      }
   }
   _outputFile<<"Average compute time of "<<(*pTab).first->getSimulatedObject().getObjectDescriptor().getName()<<": "<<moyenne/nbValeurs<<" microsecondes (computed using "<<nbValeurs<<" samples)"<<endl;    
   delete [] ( _tabVitesse[ ref ] ) ;
   _tabVitesse.erase( ref ) ; 
}



void PsnBenchScheduler::runStep(unsigned int which) {
#ifdef _SGI
   timespec avant, apres;
#else
   timeval avant, apres ;
#endif
   // Un pas de simulation pour les ObjetSimul de tous les referentiels
   PsnDoubleListElement * pListe ;
   for (pListe = Frames [which]->begin () ;
        pListe != NULL ; 
        pListe = Frames[which]->next (pListe)) {
      //initialisation du compteur de cet objet
#ifdef _SGI
      clock_gettime(CLOCK_SGI_CYCLE, &avant);
#else
      gettimeofday(&avant, NULL);
#endif
      (*pListe).listeElem->compute () ;
#ifdef _COUTPOLATION
      cout<<"Calcul de "<<(*pListe).listeElem->objetSimul ()->getName()<<endl;
#endif
      //lecture du compteur
#ifdef _SGI
      clock_gettime(CLOCK_SGI_CYCLE, &apres);
#else
      gettimeofday(&apres, NULL);
#endif
      //mise à jour de la structure de donnée
      if( _sampleIndex >= 0 ) {
#ifdef _SGI
         _tabVitesse[(*pListe).listeElem][_sampleIndex] = apres.tv_nsec - avant.tv_nsec;
#else
         assert (_tabVitesse.find( (*pListe).listeElem ) != _tabVitesse.end() ) ;
         _tabVitesse[(*pListe).listeElem][_sampleIndex] = apres.tv_usec - avant.tv_usec;
#endif
      }
   }
}

---