18#ifndef RTC_OUTPORTDSPROVIDER_H
19#define RTC_OUTPORTDSPROVIDER_H
21#include <rtm/idl/DataPortSkel.h>
57 public virtual ::POA_RTC::DataPullService,
58 public virtual PortableServer::RefCountServantBase
118 void init(coil::Properties& prop)
override;
237 ::RTC::PortStatus
pull(::RTC::OctetSeq_out data)
override;
261 inline void onBufferRead(
ByteData& data)
287 inline void onBufferEmpty()
299 inline void onBufferReadTimeout()
311 inline void onSenderEmpty()
323 inline void onSenderTimeout()
335 inline void onSenderError()
342 ::RTC::DataPullService_var m_objref;
343 ConnectorListenersBase* m_listeners;
344 ConnectorInfo m_profile;
345 OutPortConnector* m_connector{
nullptr};
CORBA sequence utility template functions.
void OutPortDSProviderInit(void)
Module initialization.
BufferBase abstract class.
Definition BufferBase.h:106
ConnectorInfo class.
Definition ConnectorBase.h:50
Definition ConnectorListener.h:1354
virtual::RTC::ConnectorListenerStatus::Enum notifyOut(ConnectorDataListenerType type, ConnectorInfo &info, ByteData &data)=0
Notify listeners. (Typed data version)
virtual::RTC::ConnectorListenerStatus::Enum notify(ConnectorListenerType type, ConnectorInfo &info)=0
Virtual Callback method.
OutPortConnector base class.
Definition OutPortConnector.h:58
OutPortDSProvider class.
Definition OutPortDSProvider.h:59
~OutPortDSProvider() override
Destructor.
void init(coil::Properties &prop) override
Initializing configuration.
::RTC::PortStatus pull(::RTC::OctetSeq_out data) override
[CORBA interface] Get data from the buffer
void setBuffer(CdrBufferBase *buffer) override
Setting outside buffer's pointer.
void setListener(ConnectorInfo &info, ConnectorListenersBase *listeners) override
Set the listener.
void setConnector(OutPortConnector *connector) override
set Connector
OutPortDSProvider()
Constructor.
OutPortProvider.
Definition OutPortProvider.h:190
BufferBase< ByteData > CdrBufferBase
Definition CdrBufferBase.h:31
BufferStatus
DataPortStatus return codes.
Definition BufferStatus.h:57