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>

namespace coil
{
  class Properties;
}
namespace RTC
{
  class InPortConsumer;
  class ConnectorListeners;
  class ConnectorInfo;

  class PublisherBase
    : public DataPortStatus
  {
  public:
    DATAPORTSTATUS_ENUM
    virtual ~PublisherBase(void){};

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

    virtual ReturnCode setConsumer(InPortConsumer* consumer) = 0;

    virtual ReturnCode setBuffer(BufferBase<cdrMemoryStream>* buffer) = 0;

    virtual ReturnCode setListener(ConnectorInfo& info,
                                   ConnectorListeners* listeners) = 0;

    virtual ReturnCode write(const cdrMemoryStream& data,
                             unsigned long sec,
                             unsigned long usec) = 0;

    virtual bool isActive() = 0;

    virtual ReturnCode activate() = 0;

    virtual ReturnCode deactivate() = 0;
  
    virtual void release(){}
  };

  typedef coil::GlobalFactory<PublisherBase> PublisherFactory;

#if defined(WIN32) || defined(_WIN32) || defined(__WIN32__) || defined(__NT__)
  EXTERN template class DLL_PLUGIN coil::GlobalFactory<PublisherBase>;
#endif
};
#endif // RTC_PUBLISHERBASE_H