---

PsnOutputOffsetTable.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
 *
 */
#if defined (_MOME) && !defined (_OLDALLOCATORS)
#include <PsnOutputOffsetTable.h>
#include <PsnSharedMemoryManager.h>
#include <PsnLock.h>
#include <PsNomSym.h>
#include <PsNomSymServer.h>
#include <unistd.h>

PsnOutputOffsetTable::PsnOutputOffsetTable() {
   PsnLock toto;
   _myLockNumber=toto.getLock();
   _locked=false;
}

void PsnOutputOffsetTable::lock() {
#ifdef _DEBUGLOCK
   cerr<<"PsnOutputOffsetTable::lock("<<(int)_myLockNumber<<")";
   cerr.flush() ;
   //if (MomeNumberOfProcessors > 2 ) sleep(1);
#endif
   MomeMutexLock(_myLockNumber);
   assert(!_locked);
   _locked=true;
   _lockedBy=MomeMe;
#ifdef _DEBUGLOCK
   cerr<<" obtenu"<<endl;
#endif
}

void PsnOutputOffsetTable::unlock() {
#ifdef _DEBUGLOCK
   cerr<<"PsnOutputOffsetTable::lock("<<(int)_myLockNumber<<")";
   cerr.flush();
#endif
   assert(_lockedBy==MomeMe);
   _locked=false;
   MomeMutexUnLock(_myLockNumber);
#ifdef _DEBUGLOCK
   cerr<<" relache"<<endl;
#endif
}

void * PsnOutputOffsetTable::operator new(size_t size) {
   PsnControleurMome::STLSharedMemoryManager->lockIfNeeded();
   void * resul(PsnControleurMome::STLSharedMemoryManager->mmalloc(size));
   PsnControleurMome::STLSharedMemoryManager->unlockIfNeeded();
   return resul;
}

void PsnOutputOffsetTable::operator delete(void * ptr,size_t size) {
   PsnControleurMome::STLSharedMemoryManager->lockIfNeeded();
#ifdef _DEBUGMFREE
   cerr<<"PsnOutputOffsetTable::operator delete : appel de mfree ";
#endif
   PsnControleurMome::STLSharedMemoryManager->mfree(ptr,size);
#ifdef _DEBUGMFREE
   cerr<<"done"<<endl;
#endif
   PsnControleurMome::STLSharedMemoryManager->unlockIfNeeded();
}

void PsnOutputOffsetTable::declareOutput(const PsNomSym & object, const PsNomSym & name, unsigned long offset) {
   // cerr<<"PsnOutputOffsetTable::declareOutput"<<endl;
   assert(_locked);
   iterator i=find(object._identifiant);
   if (i==end()) {
      pair <iterator,bool> res = insert(value_type(object._identifiant,internalHash_map()));
      i=res.first;
   }
   (*i).second.insert(internalHash_map::value_type(name._identifiant,offset));
#ifdef _DEBUGOUTPUTOFFSETTABLE
//     PsNomSym::serveurDeNom->lock();
//     for (i=begin();i!=end();i++)
//        {
//       cerr<<PsNomSym::serveurDeNom->Chaine((*i).first)<<" : "<<endl;
//       for (internalHash_mapIterator j=(*i).second.begin();
//            j!=(*i).second.end();j++) {
//          cerr<<"     "<<PsNomSym::serveurDeNom->Chaine((*j).first)<<" : "<<(*j).second<<endl;
//       }
//        }
//     PsNomSym::serveurDeNom->unlock();
   //cerr<<"PsnOutputOffsetTable::declareOutput fin"<<endl;
#endif
}
 
void PsnOutputOffsetTable::invalidateOutput(const PsNomSym & object, const PsNomSym & name) {
   assert(_locked);
   iterator i=find(object._identifiant);
   if (i != end()) {
      (*i).second.erase(name._identifiant);
      if ((*i).second.empty()) erase(object._identifiant) ;
   }
   else {
      cerr<<"Les sorties (dont "
          <<name
          <<" ) de l'objet de simulation "
          <<object
          <<" ne sont pas dans la table"
          <<" dans la méthode ";
      //PsnControleur::error("PsnOutputOffsetTable::invalidateOutput");
   }
}

pair<bool,unsigned int> PsnOutputOffsetTable::getOutputOffset(const PsNomSym & object, const PsNomSym & name) {
   //cerr<<"PsnOutputOffsetTable::getOutputOffset"<<endl;
   pair<bool, unsigned int> resul;
   iterator i=find(object._identifiant);
   if (i!=end()) {
      internalHash_mapIterator j = (*i).second.find(name._identifiant); 
      if (j!=(*i).second.end()) {
         resul.first = true ;
         resul.second = (*j).second ;
      }
      else {
         resul.first = false ;
      }
   }
   else {
      resul.first = false ;
   }
#ifdef _DEBUGOUTPUTOFFSETTABLE
   cerr<<object<<","<<name<<" : "<<resul.second<<endl;
#endif
   //cerr<<"PsnOutputOffsetTable::getOutputOffset fin"<<endl;
   return resul;
}
#endif

---