PortConnectListener.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_PORTCONNECTLISTENER_H
#define RTC_PORTCONNECTLISTENER_H

#include <vector>
#include <utility>
#include <coil/Mutex.h>
#include <coil/Guard.h>
#include <rtm/RTC.h>
#include <rtm/idl/RTCSkel.h>

namespace RTC
{
  //============================================================
  enum PortConnectListenerType
    {
      ON_NOTIFY_CONNECT,
      ON_NOTIFY_DISCONNECT,
      ON_UNSUBSCRIBE_INTERFACES,
      PORT_CONNECT_LISTENER_NUM
    };

  class PortConnectListener
  {
  public:
    static const char* toString(PortConnectListenerType type);

    virtual ~PortConnectListener();

    virtual void operator()(const char* portname,
                            RTC::ConnectorProfile& profile) = 0;
  };


  //============================================================
  enum PortConnectRetListenerType
    {
      ON_PUBLISH_INTERFACES,
      ON_CONNECT_NEXTPORT,
      ON_SUBSCRIBE_INTERFACES,
      ON_CONNECTED,
      ON_DISCONNECT_NEXT,
      ON_DISCONNECTED,
      PORT_CONNECT_RET_LISTENER_NUM
    };

  class PortConnectRetListener
  {
  public:
    static const char* toString(PortConnectRetListenerType type);

    virtual ~PortConnectRetListener();

    virtual void operator()(const char* portname,
                            RTC::ConnectorProfile& profile,
                            ReturnCode_t ret) = 0;
  };

  //============================================================
  class PortConnectListenerHolder
  {
    typedef std::pair<PortConnectListener*, bool> Entry;
    typedef coil::Guard<coil::Mutex> Guard;
  public:
    PortConnectListenerHolder();
    
    virtual ~PortConnectListenerHolder();
    
    void addListener(PortConnectListener* listener, bool autoclean);
    
    void removeListener(PortConnectListener* listener);

    void notify(const char* portname, RTC::ConnectorProfile& profile);
      
  private:
    std::vector<Entry> m_listeners;
    coil::Mutex m_mutex;
  };


  class PortConnectRetListenerHolder
  {
    typedef std::pair<PortConnectRetListener*, bool> Entry;
    typedef coil::Guard<coil::Mutex> Guard;
  public:
    PortConnectRetListenerHolder();

    virtual ~PortConnectRetListenerHolder();
    
    void addListener(PortConnectRetListener* listener, bool autoclean);
    
    void removeListener(PortConnectRetListener* listener);
    
    void notify(const char* portname, RTC::ConnectorProfile& profile,
                ReturnCode_t ret);
    
  private:
    std::vector<Entry> m_listeners;
    coil::Mutex m_mutex;
  };

  class PortConnectListeners
  {
  public:
    PortConnectListenerHolder 
    portconnect_[PORT_CONNECT_LISTENER_NUM];
    PortConnectRetListenerHolder 
    portconnret_[PORT_CONNECT_RET_LISTENER_NUM];
  };


}; // namespace RTC

#endif // RTC_PORTCONNECTLISTENER_H