OutPortPullConnector.h

Go to the documentation of this file.

// -*- 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