OMKEventSignalEmitterUtil.h

Go to the documentation of this file.

#ifndef OMK_INP_EVENTSIGNALEMITTERUTIL_H
#define OMK_INP_EVENTSIGNALEMITTERUTIL_H

#include "OMKInputs.h"
#include "OMKExtensibleSimulatedObject.h"
#include "OMKTransform.h"
#include "OMKBaseType.h"
#include "OMKTransformType.h"
#include "OMKParametersAccessor.inl"
namespace OMK
{
class OMKINPUTS_API EventSignalEmitterUtil  
{
protected: 
        EventSignalEmitterUtil() ;
public: 
  virtual ~EventSignalEmitterUtil() ;
protected:
  virtual bool loadParametersUtil( ExtensibleSimulatedObject* owner, 
                                   const ConfigurationParameterDescriptor * node ) ;
  bool _signal ;
  EventIdentifier _eventId ;
  std::vector< Name > _listeners ;
  virtual void sendUtil( ExtensibleSimulatedObject* owner ) ;
};

//=============================================================================
template< typename T, typename ModelType >
class ValuedEventSignalEmitterUtilT:  
  public EventSignalEmitterUtil
{
protected: 
        ValuedEventSignalEmitterUtilT() 
    : EventSignalEmitterUtil(),
    _current()
  {
  }

public: 
  virtual ~ValuedEventSignalEmitterUtilT() {}
protected:
  virtual bool loadParametersUtil( ExtensibleSimulatedObject* owner, 
                                   const ConfigurationParameterDescriptor * node ) 
  {
    bool ok = true ;
    if( ParametersAccessor::get( node, "AttributeId", _eventId, owner ) )
    {
      IAttribute * attribute = owner->getAttribute( _eventId ) ;
      ok = ok && attribute ;
      if( !attribute ) OMERROR( "Attribute " << _eventId << " cannot be found" ) ;
      if( ok )
      {
        attribute->activateSetByEventOf() ;
        _eventId = EventId::getCurrentValueEventId( _eventId.getCString() ) ;
        _listeners.push_back( owner->getName() ) ;
        _signal = false ;
      }
    }
    else
    {
      ok = ok && EventSignalEmitterUtil::loadParametersUtil( owner, node ) ;
    }
    ok = ok && ParametersAccessor::get( node, "Values", _values, owner ) ;
    _current = _values.begin() ;
    return ok ;
  }
  std::vector< T > _values ;
  typename std::vector< T >::iterator _current ;
  virtual void sendUtil( ExtensibleSimulatedObject* owner ) 
  {
    if( _signal )
    { // Fire the signal
      owner->fireValuedSignal< ModelType >( _eventId, ModelType( *_current ) ) ;
    }
    else
    { // Send the event for each listener
      for( std::vector< Name >::const_iterator i = _listeners.begin() ;
           i != _listeners.end() ;
           i++ )
      {
        OMTRACEID( OMK_DEBUG_OMK_EVENT, "send value \"" << *_current << "\" to \"" << *i << "\" through event \"" << _eventId << "\"" ) ;
        owner->sendValuedEvent< ModelType >( *i, _eventId, ModelType( *_current ) ) ;
      }
    }
    // Next one 
    _current++ ;
    if( _current == _values.end() ) _current = _values.begin() ;
  }
} ;

//=============================================================================
template< typename T, typename ModelType >
class MultiValuedEventSignalEmitterUtilT:  
  public EventSignalEmitterUtil
{
protected: 
        MultiValuedEventSignalEmitterUtilT() 
    : EventSignalEmitterUtil(),
    _default( 0 )
  {
  }

public: 
  virtual ~MultiValuedEventSignalEmitterUtilT() {}
protected:
  virtual bool loadParametersUtil( ExtensibleSimulatedObject* owner, 
                                   const ConfigurationParameterDescriptor * node ) 
  {
    bool ok = true ;
    if( ParametersAccessor::get( node, "AttributeId", _eventId, owner ) )
    {
      IAttribute * attribute = owner->getAttribute( _eventId ) ;
      ok = ok && attribute ;
      if( !attribute ) OMERROR( "Attribute " << _eventId << " cannot be found" ) ;
      if( ok )
      {
        attribute->activateSetByEventOf() ;
        _eventId = EventId::getCurrentValueEventId( _eventId.getCString() ) ;
        _listeners.push_back( owner->getName() ) ;
        _signal = false ;
      }
    }
    else
    {
      ok = ok && EventSignalEmitterUtil::loadParametersUtil( owner, node ) ;
    }
    ok = ok && ParametersAccessor::get( node, "Values", _values, owner ) ;
    ParametersAccessor::get( node, "Default", _default ) ;
    return ok ;
  }
  std::vector< T > _values ;
  int _default ;
  virtual void sendUtil( ExtensibleSimulatedObject* owner, int index ) 
  {
    // if index out of range then it uses the _default
    index = ( index < 0 || (int)_values.size() < index ) ? _default : index ;
    if( _signal )
    { // Fire the signal
      owner->fireValuedSignal< ModelType >( _eventId, ModelType( _values[ index ] ) ) ;
    }
    else
    { // Send the event for each listener
      for( std::vector< Name >::const_iterator i = _listeners.begin() ;
           i != _listeners.end() ;
           i++ )
      {
        OMTRACEID( OMK_DEBUG_OMK_EVENT, "send value[ " << index << " ] \"" << _values[ index ] << "\" to \"" << *i << "\" through event \"" << _eventId << "\"" ) ;
        owner->sendValuedEvent< ModelType >( *i, _eventId, ModelType( _values[ index ] ) ) ;
      }
    }
  }
} ;

} // namespace OMK

#endif // OMK_INP_EVENTSIGNALEMITTERUTIL_H

---