ConfigurationListener.cpp

Go to the documentation of this file.

// -*- C++ -*-
#include <rtm/ConfigurationListener.h>

namespace RTC
{

  //============================================================
  ConfigurationParamListener::~ConfigurationParamListener(){}

  ConfigurationSetNameListener::~ConfigurationSetNameListener(){}

  ConfigurationSetListener::~ConfigurationSetListener(){}


  //============================================================
  ConfigurationParamListenerHolder::ConfigurationParamListenerHolder()
  {
  }
  
  
  ConfigurationParamListenerHolder::~ConfigurationParamListenerHolder()
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        if (m_listeners[i].second)
          {
            delete m_listeners[i].first;
          }
      }
  }

  
  void ConfigurationParamListenerHolder::
  addListener(ConfigurationParamListener* listener,
              bool autoclean)
  {
    Guard guard(m_mutex);
    m_listeners.push_back(Entry(listener, autoclean));
  }
  
  
  void ConfigurationParamListenerHolder::
  removeListener(ConfigurationParamListener* listener)
  {
    Guard guard(m_mutex);
    std::vector<Entry>::iterator it(m_listeners.begin());
    
    for (; it != m_listeners.end(); ++it)
      {
        if ((*it).first == listener)
          {
            if ((*it).second)
              {
                delete (*it).first;
              }
            m_listeners.erase(it);
            return;
          }
      }
    
  }
  
  
  void ConfigurationParamListenerHolder::notify(const char* config_set_name,
                                                const char* config_param_name)
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        m_listeners[i].first->operator()(config_set_name, config_param_name);
      }
  }


  //============================================================
  ConfigurationSetListenerHolder::ConfigurationSetListenerHolder()
  {
  }
    
  
  ConfigurationSetListenerHolder::~ConfigurationSetListenerHolder()
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        if (m_listeners[i].second)
          {
            delete m_listeners[i].first;
          }
      }
  }
  
  
  void ConfigurationSetListenerHolder::
  addListener(ConfigurationSetListener* listener,
              bool autoclean)
  {
    Guard guard(m_mutex);
    m_listeners.push_back(Entry(listener, autoclean));
  }
  
  
  void ConfigurationSetListenerHolder::
  removeListener(ConfigurationSetListener* listener)
  {
    Guard guard(m_mutex);
    std::vector<Entry>::iterator it(m_listeners.begin());
    
    for (; it != m_listeners.end(); ++it)
      {
        if ((*it).first == listener)
          {
            if ((*it).second)
              {
                delete (*it).first;
              }
            m_listeners.erase(it);
            return;
          }
      }
    
  }
  
  
  void ConfigurationSetListenerHolder::
  notify(const coil::Properties& config_set)
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        m_listeners[i].first->operator()(config_set);
      }
  }

  //============================================================
  ConfigurationSetNameListenerHolder::ConfigurationSetNameListenerHolder()
  {
  }
  

  ConfigurationSetNameListenerHolder::~ConfigurationSetNameListenerHolder()
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        if (m_listeners[i].second)
          {
            delete m_listeners[i].first;
          }
      }
  }

  
  void ConfigurationSetNameListenerHolder::
  addListener(ConfigurationSetNameListener* listener, bool autoclean)
  {
    Guard guard(m_mutex);
    m_listeners.push_back(Entry(listener, autoclean));
  }

  
  void ConfigurationSetNameListenerHolder::
  removeListener(ConfigurationSetNameListener* listener)
  {
    Guard guard(m_mutex);
    std::vector<Entry>::iterator it(m_listeners.begin());
    for (; it != m_listeners.end(); ++it)
      {
        if ((*it).first == listener)
          {
            if ((*it).second)
              {
                delete (*it).first;
              }
            m_listeners.erase(it);
            return;
          }
      }
    
  }

    
  void ConfigurationSetNameListenerHolder::notify(const char* config_set_name)
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        m_listeners[i].first->operator()(config_set_name);
      }
  }

};