PortConnectListener.h

Go to the documentation of this file.

// -*- C++ -*-
#ifndef RTC_PORTCONNECTLISTENER_H
#define RTC_PORTCONNECTLISTENER_H
 
#include <mutex>
#include <rtm/RTC.h>
#include <rtm/idl/RTCSkel.h>
 
#include <vector>
#include <utility>
#include <array>
 
namespace RTC
{
  //============================================================
  enum class PortConnectListenerType : uint8_t
    {
      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 class PortConnectRetListenerType : uint8_t
    {
      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
  {
    using Entry = std::pair<PortConnectListener*, bool>;
  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;
    std::mutex m_mutex;
  };
 
 
  class PortConnectRetListenerHolder
  {
    using Entry = std::pair<PortConnectRetListener*, bool>;
  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;
    std::mutex m_mutex;
  };
 
  class PortConnectListeners
  {
  public:
    PortConnectListeners();
    ~PortConnectListeners();
    bool addListener(PortConnectListenerType type, PortConnectListener* listener, bool autoclean=true);
    bool removeListener(PortConnectListenerType type, PortConnectListener* listener);
    bool addListener(PortConnectRetListenerType type, PortConnectRetListener* listener, bool autoclean=true);
    bool removeListener(PortConnectRetListenerType type, PortConnectRetListener* listener);
    inline bool notify(PortConnectListenerType type, const char* portname, RTC::ConnectorProfile& profile)
    {
        if (static_cast<uint8_t>(type) < portconnect_.size())
        {
            portconnect_[static_cast<uint8_t>(type)].notify(portname, profile);
            return true;
        }
        return false;
    }
    inline bool notify(PortConnectRetListenerType type, const char* portname, RTC::ConnectorProfile& profile,
                ReturnCode_t ret)
    {
        if (static_cast<uint8_t>(type) < portconnret_.size())
        {
            portconnret_[static_cast<uint8_t>(type)].notify(portname, profile, ret);
            return true;
        }
        return false;
    }
 
  private:
    std::array<PortConnectListenerHolder, 
        static_cast<uint8_t>
        (PortConnectListenerType::PORT_CONNECT_LISTENER_NUM)>
        portconnect_;
    std::array<PortConnectRetListenerHolder,
        static_cast<uint8_t>
        (PortConnectRetListenerType::PORT_CONNECT_RET_LISTENER_NUM)>
        portconnret_;
  };
 
 
} // namespace RTC
 
#endif  // RTC_PORTCONNECTLISTENER_H