OutPortPullConnector.h

[詳解]

// -*- C++ -*-
 
#ifndef RTC_OUTPORTPULLCONNECTOR_H
#define RTC_OUTPORTPULLCONNECTOR_H
 
#include <rtm/OutPortConnector.h>
#include <rtm/ConnectorListener.h>
 
namespace RTC
{
  class OutPortProvider;

  class OutPortPullConnector
    : public OutPortConnector
  {
  public:

    OutPortPullConnector(ConnectorInfo info,
                         OutPortProvider* provider,
                         ConnectorListenersBase* listeners,
                         CdrBufferBase* buffer = nullptr);

    ~OutPortPullConnector() override;

    DataPortStatus write(ByteDataStreamBase* data) override;
 
    BufferStatus read(ByteData &data) override;

    DataPortStatus disconnect() override;

    CdrBufferBase* getBuffer() override;

    void activate() override {}  // do nothing

    void deactivate() override {}  // do nothing

    static CdrBufferBase* createBuffer(ConnectorInfo& info);

    void onConnect();

    void onDisconnect();
 
  protected:
    OutPortProvider* m_provider;

    ConnectorListenersBase* m_listeners;

    CdrBufferBase* m_buffer;
  private:
      bool m_sync_readwrite;
 
      struct WorkerThreadCtrl
      {
          WorkerThreadCtrl() {}
          std::mutex mutex_;
          std::condition_variable cond_;
          bool completed_{false};
      };
      WorkerThreadCtrl m_writecompleted_worker;
      WorkerThreadCtrl m_readcompleted_worker;
      WorkerThreadCtrl m_readready_worker;
 
  };
} // namespace RTC
 
#endif  // RTC_PULL_CONNECTOR_H