---

PsnBroadcastManager.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 <PsnBroadcastManager.h>
#include <PsnSharedMemoryManager.h>
#include <PsName.h>
#include <PsnNew.h>
#include <PsnLock.h>
#include <PsnUniqueCreator.h>
#include <PsDistributedController.h>
#include <unistd.h>

const int PsnBroadcastManager::nbTablesDansBuffer=3;

PsnBroadcastManager::PsnBroadcastManager(PsnUniqueCreator & aCreator) : 
   _allProcessesId("_allProcesses"),
   _mirrorToReferentialId("_MirrorId")
{
   PsnLock toto;
   _myLockNumber=toto.getLock();
#ifdef _DEBUGLOCK
   cerr<<"PsnBroadcastManager::PsnBroadcastManager : le processeur "
       <<MomeMe
       <<" a obtenu le numero de verrou "<<(int)_myLockNumber<<endl;
#endif
   for (int i=0; i<nbTablesDansBuffer ; i++) {
      broadcastedEventsTable[i]=aCreator.newbroadcastManagerTable(i);
      assert ( PsnSharedMemoryManager::whichSharedMemoryManager(broadcastedEventsTable[i]) != NULL ) ;
   }
   _memoryManagerOfmyData=PsnSharedMemoryManager::whichSharedMemoryManager(broadcastedEventsTable[0]);
   cerr<<broadcastedEventsTable<<endl;
   assert ( _memoryManagerOfmyData != NULL ) ;
   assert ( PsnSharedMemoryManager::whichSharedMemoryManager( this ) == NULL );
   _locked=false;
   _currentWritableTable=0;
   _currentReadableTable=1;
   _currentDeletableTable=2;
   //lancer le thread de destruction des événements et des messages
}

PsnBroadcastManager::~PsnBroadcastManager() {

}

void PsnBroadcastManager::sendEvent(const PsName & receiverProcess, unsigned int offsetOfEvent) {
   //install in this scope our memoryManager as the default memory manager
   HeapStackTop toto(_memoryManagerOfmyData);
   //Send the event to the appropriate controler
   lock();
   broadcastedEventsTable[_currentWritableTable]->insert(broadcastedEventsTable[_currentWritableTable]->begin(),_myPairType(receiverProcess,offsetOfEvent));
   unlock();
} 

void PsnBroadcastManager::broadcastEvent(unsigned int offsetOfEvent) {
   //install in this scope our memoryManager as the default memory manager
   HeapStackTop toto(_memoryManagerOfmyData);
   //Send the event to the appropriate controler
   lock();
   broadcastedEventsTable[_currentWritableTable]->insert(broadcastedEventsTable[_currentWritableTable]->begin(),_myPairType(_allProcessesId,offsetOfEvent));
   unlock();
} 


void PsnBroadcastManager::addToEventList(PsList<PsEvent *> * anEventList, const PsName & aProcess) {
   _myTypeOfTable::iterator i;
   for(i=broadcastedEventsTable[_currentReadableTable]->begin();
       i!=broadcastedEventsTable[_currentReadableTable]->end();
       i++) 
      {
         if ((*i).first==aProcess
             ||(*i).first==_allProcessesId) 
            {
               PsEvent::insertInList(anEventList,
                                     ((PsEvent *)_memoryManagerOfmyData->localAddressToGlobal((*i).second)));
            }
      }
}

void PsnBroadcastManager::dispatchEventsOfList(PsDistributedController & theLocalControler) {
#ifdef _DEBUGEVT
   cerr<<"PsnBroadcastManager::dispatchEventsOfList for "<<theLocalControler.getObjectDescriptor()->Processus()<<endl;
#endif
   _myTypeOfTable::iterator i;
   const PsName & aProcess(theLocalControler.getObjectDescriptor().getProcess());

#ifdef _DEBUGEVT
   cerr<<"PsnBroadcastManager::dispatchEventsOfList : broadcastedEventsTable["<<_currentReadableTable<<"] : "<<broadcastedEventsTable[_currentReadableTable]->size()<<" event(s) present(s)"<<endl;
#endif

   for(i=broadcastedEventsTable[_currentReadableTable]->begin();
       i!=broadcastedEventsTable[_currentReadableTable]->end();
       i++) 
      {
#ifdef _DEBUGEVT
         cerr<<(*i).first<<endl;
         cerr<<(*i).second<<endl;
         cerr<<_memoryManagerOfmyData<<endl;
         cerr<<_memoryManagerOfmyData->localAddressToGlobal((*i).second)<<endl;
         cerr<<(PsEvent *)_memoryManagerOfmyData->localAddressToGlobal((*i).second)<<endl;
         cerr<<*(PsEvent *)_memoryManagerOfmyData->localAddressToGlobal((*i).second)<<endl;
#endif
         if ((*i).first==aProcess
             ||(*i).first==_allProcessesId) 
            {
               theLocalControler.dispatchEvent((PsEvent *)_memoryManagerOfmyData->localAddressToGlobal((*i).second));
            }
      }      
#ifdef _DEBUGEVT
   cerr<<"PsnBroadcastManager::dispatchEventsOfList fin"<<endl;
#endif
}


void PsnBroadcastManager::sync() {
   int temp;
   //the _current*Table variables are kept coherant accros the cluster because of the barrier at each simulation step
#ifdef _DEBUGEVT
   cerr<<"PsnBroadcastManager::sync()"<<endl;
#endif
   temp=_currentReadableTable;
   _currentReadableTable=_currentWritableTable;
   _currentWritableTable=_currentDeletableTable;
   _currentDeletableTable=temp;
   //La currentReadeableTable a du être lu : il faut donc la détruire
   if (MomeMe==0) {
      _myTypeOfTable::iterator i,needsDelete;
      i=broadcastedEventsTable[_currentDeletableTable]->begin();
        while( i!=broadcastedEventsTable[_currentDeletableTable]->end() )
         {
            needsDelete=i;
            i++;
            broadcastedEventsTable[_currentDeletableTable]->erase( needsDelete );
         }
   }
   //cerr<<"PsnBroadcastManager::sync() fin"<<endl;
}
void PsnBroadcastManager::lock() {
#ifdef _DEBUGLOCK
   cerr<<"PsnBroadcastManager::lock("<<(int)_myLockNumber<<","<<&_accessToLock<<")";
   cerr.flush() ;
   sleep (1) ;
#endif
   _accessToLock.protect () ;
   assert(!_locked);
   MomeMutexLock(_myLockNumber);
   _locked=true;
#ifdef _DEBUGLOCK
   cerr<<" obtenu"<<endl;
#endif
}
;

void PsnBroadcastManager::unlock() {
#ifdef _DEBUGLOCK
   cerr<<"PsnBroadcastManager::lock("<<(int)_myLockNumber<<","<<&_accessToLock<<")";
   cerr.flush() ;
   //sleep (1) ;
#endif
   assert(_locked);
   _locked=false;
   MomeMutexUnLock(_myLockNumber);
#ifdef _DEBUGLOCK
   cerr<<" relache"<<endl;
#endif
   _accessToLock.unprotect () ;
}

const PsName & PsnBroadcastManager::getMirrorToReferentialId() {
   return _mirrorToReferentialId;
}

const PsName & PsnBroadcastManager::getAllProcessesId() {
   return _allProcessesId;
}

#endif

---