PublisherBase.h

Go to the documentation of this file.

// -*- C++ -*-
 
#ifndef RTC_PUBLISHERBASE_H
#define RTC_PUBLISHERBASE_H
 
#include <coil/Properties.h>
#include <coil/Factory.h>
#include <rtm/RTC.h>
#include <rtm/CdrBufferBase.h>
#include <rtm/DataPortStatus.h>
#include <rtm/ByteDataStreamBase.h>
 
 
namespace coil
{
  class Properties;
} // namespace coil
namespace RTC
{
  class InPortConsumer;
  class ConnectorListenersBase;
  class ConnectorInfo;

  class PublisherBase
  {
  public:
    virtual ~PublisherBase() = default;

    virtual DataPortStatus init(coil::Properties& prop) = 0;

    virtual DataPortStatus setConsumer(InPortConsumer* consumer) = 0;

    virtual DataPortStatus setBuffer(BufferBase<ByteData>* buffer) = 0;

    virtual DataPortStatus setListener(ConnectorInfo& info,
                                   ConnectorListenersBase* listeners) = 0;

    virtual DataPortStatus write(ByteDataStreamBase* data,
                             std::chrono::nanoseconds timeout) = 0;

    virtual bool isActive() = 0;

    virtual DataPortStatus activate() = 0;

    virtual DataPortStatus deactivate() = 0;

    virtual void release(){}
  };
 
  using PublisherFactory = coil::GlobalFactory<PublisherBase>;
} // namespace RTC
 
#if defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__)
EXTERN template class DLL_PLUGIN coil::GlobalFactory<RTC::PublisherBase>;
#elif defined(__GNUC__)
EXTERN template class coil::GlobalFactory<RTC::PublisherBase>;
#endif
 
#endif  // RTC_PUBLISHERBASE_H