ConnectorListener.cpp

Go to the documentation of this file.

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

namespace RTC
{
  ConnectorDataListener::~ConnectorDataListener(){}

  ConnectorListener::~ConnectorListener(){}

  ConnectorDataListenerHolder::ConnectorDataListenerHolder()
  {
  }
  

  ConnectorDataListenerHolder::~ConnectorDataListenerHolder()
  {
    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 ConnectorDataListenerHolder::
  addListener(ConnectorDataListener* listener, bool autoclean)
  {
    Guard guard(m_mutex);
    m_listeners.push_back(Entry(listener, autoclean));
  }

  
  void ConnectorDataListenerHolder::
  removeListener(ConnectorDataListener* 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 ConnectorDataListenerHolder::notify(const ConnectorInfo& info,
                                           const cdrMemoryStream& cdrdata)
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        m_listeners[i].first->operator()(info, cdrdata);
      }
  }


  ConnectorListenerHolder::ConnectorListenerHolder()
  {
  }
    
  
  ConnectorListenerHolder::~ConnectorListenerHolder()
  {
    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 ConnectorListenerHolder::addListener(ConnectorListener* listener,
                                            bool autoclean)
  {
    Guard guard(m_mutex);
    m_listeners.push_back(Entry(listener, autoclean));
  }
  

  void ConnectorListenerHolder::removeListener(ConnectorListener* 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 ConnectorListenerHolder::notify(const ConnectorInfo& info)
  {
    Guard guard(m_mutex);
    for (int i(0), len(m_listeners.size()); i < len; ++i)
      {
        m_listeners[i].first->operator()(info);
      }
  }
};