OMKSignalDispatcher.cpp

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 "OMKSignalDispatcher.h"

#include "OMKController.h"
#include "OMKEvent.h"
#include <OMKNameServer.h>

using namespace std ;
using namespace OMK ;


SignalDispatcher::SignalDispatcher(Controller & ctrl ) :
   _controler (ctrl) 
{

}

SignalDispatcher::~SignalDispatcher() {
   for (_TableType::iterator i = _tableOfRegistredObjects.begin() ;
        i !=  _tableOfRegistredObjects.end() ;
        i++ )
      {
         delete (*i).second ;
      }
}

void SignalDispatcher::sendEventsForSignal ( Event & event,
                                               const EventIdentifier & sigId )
{
   //cerr<<"SignalDispatcher:"<<this<<":sendEventsForSignal "<<sigId<<endl;
#ifdef _OMK_MUTEX_
   _mutexForRegistredObjectsTable.protect() ;
#endif
   _TableType::iterator i = _tableOfRegistredObjects.find ( sigId ) ;
   if (i != _tableOfRegistredObjects.end() )
      {
         _VectorType::iterator listIterator = (*i).second->begin();
         while ( listIterator != (*i).second->end() )
            {
               event.receiver = listIterator->first ;
               event.eventId = listIterator->second ;
               SimulatedObject * receiver = _controler.getPointerToSimulatedObjectNamed(event.receiver) ;
               if ( receiver != NULL ) 
                  {
                     receiver->getObjectHandle()->receiveEvent(event) ;
                     listIterator ++ ;
                  }
               else 
                  {
                     // we suppose the objet no longer exists
                     cerr<<"WARNING : OMKReferenceObjectHandle::sendSignalAsEvent "
                         <<receiver
                         << "no longer seems to exists : deleted from data structure "<<endl;
                     listIterator = (*i).second->erase ( listIterator ) ; 
                  }
            }
      }
#ifdef _OMK_MUTEX_
   _mutexForRegistredObjectsTable.unprotect() ;
#endif
}

bool SignalDispatcher::registerForSignal ( const EventIdentifier & sigId, 
                                              const Name & registrant, 
                                              const EventIdentifier & eventId ) 
{
//   cerr << "SignalDispatcher: " << this << " :registerForSignal on "<< sigId <<" send "<< eventId <<" to " << registrant << endl ;
#ifdef _OMK_MUTEX_
  _mutexForRegistredObjectsTable.protect() ;
#endif
  _TableType::iterator i = _tableOfRegistredObjects.find ( sigId ) ;
  if (i == _tableOfRegistredObjects.end() )
    {
      _tableOfRegistredObjects[sigId] = new _VectorType( 1, pair<Name, EventIdentifier>( registrant, eventId ) );
    }
  else 
    {
      _VectorType::iterator j = (*i).second->begin() ;
      while ( j != (*i).second->end() )
        {
          if ( ( *j ).first == registrant )
            {
              j = (*i).second->erase( j ) ;
            }
          else
            {
              ++j ;
            }
        }
      ( *i ).second->push_back( pair <Name, EventIdentifier> 
                                ( registrant, eventId ) );
    }
  
#ifdef _OMK_MUTEX_
  _mutexForRegistredObjectsTable.unprotect() ;
#endif
  return true ;
}


bool SignalDispatcher::cancelRegistrationForSignal ( const EventIdentifier & sigId, 
                                                        const Name & registrant ) 
{
#ifdef _OMK_MUTEX_
   _mutexForRegistredObjectsTable.protect() ;
#endif
   _TableType::iterator i = _tableOfRegistredObjects.find ( sigId ) ;
   if (i != _tableOfRegistredObjects.end() )
      {
         _VectorType::iterator listIterator = (*i).second->begin();
         while ( listIterator != (*i).second->end() )
            {
               if (listIterator->first == registrant ) 
                  {
                     listIterator = (*i).second->erase( listIterator ) ;
                  }
               else
                  {
                     listIterator++ ;
                  }
            }
      }
#ifdef _OMK_MUTEX_
   _mutexForRegistredObjectsTable.unprotect() ;   
#endif
   return true ;
}

---