---

PsnMomeWriterFifo.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 PsnMomeWriterFifoHEADER
#define PsnMomeWriterFifoHEADER

#include "PsnMomeFifo.h"

template <typename Type>
class PsnMomeWriterFifo : public PsnMomeFifo<Type>
{
public:
   PsnMomeWriterFifo(const int, PsnRelaxedMemoryManager * myMemory);
   PsnMomeWriterFifo(void * fifoAddress , const unsigned int size);
   virtual ~PsnMomeWriterFifo() ;
   virtual void set (const Type & val, const PsDate & date) ;
   virtual unsigned int getNumberOfPresentValues( int maxCherche = -1 ) const ;
   virtual void setInPlace ( const Type & val, const PsDate & date) ;

   virtual Type & getNextPlaceHolder() ;
   virtual void clear() ;
   virtual void printDebuggingInformation() const ;
protected:
   virtual unsigned int findFirstValid() const ;

   virtual const PsDate & getOldestDateAfter(const int indice) const ;

};


template <typename Type> 
PsnMomeWriterFifo<Type>::PsnMomeWriterFifo(const int size, PsnRelaxedMemoryManager * myMemory) : 
   PsnMomeFifo<Type> (size,myMemory) {

}



template <typename Type> 
PsnMomeWriterFifo<Type>::PsnMomeWriterFifo(void * fifoAddress , const unsigned int size) : 
   PsnMomeFifo<Type> (fifoAddress,size) {
   
}



template <typename Type>
PsnMomeWriterFifo<Type>::~PsnMomeWriterFifo() {

}



template <typename Type> 
void PsnMomeWriterFifo<Type>::set(const Type & val, const PsDate & date) {
#ifdef _DEBUGATTRIBUTSMOME
   cerr<<"PsnMomeWriterFifo<"<<typeid(Type).name()<<">::"<<this<<"::set("<<val<<", "<<date<<")"<<endl;
#endif
   PsDate & oldDateAtWrittenIndex ((*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].dateValeur) ;
//     cerr<<"Written at adress : "<<&(*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()]
//         <<" which is page : "<<PsnSharedMemoryManager::whichSharedMemoryManager(_tab)->globalAddressToLocal(&(*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()])/4096+4096
//         <<endl;
   (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].valeur = val ;
   //assert (oldDateAtWrittenIndex != date) ;
   if ( oldDateAtWrittenIndex != date ) {//avoid rechanging 
      (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].dateValeur = date ;
      _dateOfOldestValidValue = getOldestDateAfter (PsnRelaxedMemoryManager::getWritableQueueIndex()) ;
      _lastValidIndex = PsnRelaxedMemoryManager::getWritableQueueIndex() ;
      (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].datePlusVieilleValeurValide = _dateOfOldestValidValue ;

   }
#ifdef _DEBUGATTRIBUTSMOME
   cerr<<"PsnMomeWriterFifo<"<<typeid(Type).name()<<">::"<<this<<"::set done"<<endl;
#endif
}


template <typename Type> 
void PsnMomeWriterFifo<Type>::setInPlace(const Type & newValue, const PsDate & date) {


   PsDate & oldDateAtWrittenIndex ((*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].dateValeur) ;

   assert (&((*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].valeur) == &newValue ) ;

   if ( oldDateAtWrittenIndex != date ) //avoid rechanging 
      {
         (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].dateValeur = date ;
         _dateOfOldestValidValue = getOldestDateAfter (PsnRelaxedMemoryManager::getWritableQueueIndex()) ;
         _lastValidIndex = PsnRelaxedMemoryManager::getWritableQueueIndex() ;
         (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].datePlusVieilleValeurValide = _dateOfOldestValidValue ;
         
      }
}

template <typename Type>
Type & PsnMomeWriterFifo<Type>::getNextPlaceHolder() 
{
   return (*_tab)[PsnRelaxedMemoryManager::getWritableQueueIndex()].valeur ;
}


template <typename Type> 
unsigned int PsnMomeWriterFifo<Type>::getNumberOfPresentValues( int maxCherche ) const {
#ifdef _DEBUGATTRIBUTSMOME
   cerr<<"PsnMomeWriterFifo<"<<typeid(Type).name()<<">::"<<this<<"::getNumberOfPresentValues("<<maxCherche<<")"<<endl;
#endif
   unsigned int nbATrouver ;
   if (maxCherche == -1) {
      nbATrouver = _fifoSize ;
   }
   else {
      nbATrouver = maxCherche ; 
   }
   int lookAt = findFirstValid () ;

   unsigned int nbValidFound = 0 ;
   unsigned int nbLookedAt = 0 ;

   while ( ( nbValidFound < nbATrouver ) && 
           ( nbLookedAt < _fifoSize ) ) {
         if ( (*_tab)[lookAt].dateValeur >= _dateOfOldestValidValue ) nbValidFound++ ;
         nbLookedAt++ ;
         if (lookAt != 0 ) {
            lookAt--;
         }
         else {
            lookAt = _fifoSize -1 ;
         }      
   } 
   return nbValidFound ;
}



template <typename Type> 
const PsDate & PsnMomeWriterFifo<Type>::getOldestDateAfter (int i) const {
   //if the assertion isn't valid, the loop might never end
   assert ((*_tab)[i].dateValeur >= _dateOfOldestValidValue ) ;

   int lookAt = ( i + 1 ) % _fifoSize ;
   int nbValidFound = 0 ;
   
   if ((*_tab)[lookAt].dateValeur >= _dateOfOldestValidValue ) nbValidFound++ ;

   while (nbValidFound != 1) {
      lookAt = ( lookAt + 1 ) % _fifoSize ;
      if ((*_tab)[lookAt].dateValeur >= _dateOfOldestValidValue ) nbValidFound++ ;
   }

   return (*_tab) [lookAt].dateValeur ;
}



template <typename Type>
unsigned int PsnMomeWriterFifo<Type>::findFirstValid() const {
#ifdef _DEBUGATTRIBUTSMOME
   cerr<<"PsnMomeWriterFifo<"<<typeid(Type).name()<<">::"<<this<<"::findFirstValid ()"<<endl;
#endif
   return _lastValidIndex ;
}



template <typename Type>
void PsnMomeWriterFifo<Type>::clear() {
   _dateOfOldestValidValue = (*_tab)[_lastValidIndex].dateValeur ;
   (*_tab)[_lastValidIndex].dateValeur -- ;
}



template <typename Type>
void PsnMomeWriterFifo<Type>::printDebuggingInformation() const {
   cerr<<" PsnMomeWriterFifo<"<<typeid(Type).name()<<">::"<<this<<"::printDebuggingInformation () "<<endl;
   PsnMomeFifo<Type>::printDebuggingInformation() ;
}

#endif

---