20#ifndef RTC_PUBLISHERFLUSH_H
21#define RTC_PUBLISHERFLUSH_H
23#include <condition_variable>
263 std::chrono::nanoseconds timeout
264 = std::chrono::nanoseconds(-1))
override;
420 Logger rtclog{
"PublisherFlush"};
421 InPortConsumer* m_consumer{
nullptr};
422 ConnectorInfo m_profile;
423 ConnectorListenersBase* m_listeners{
nullptr};
425 std::mutex m_retmutex;
426 bool m_active{
false};
void PublisherFlushInit()
RT component logger class.
DataPortStatus mixin class.
BufferBase abstract class.
Definition BufferBase.h:106
Definition ByteDataStreamBase.h:63
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)
InPortConsumer abstract class.
Definition InPortConsumer.h:78
Logger class.
Definition SystemLogger.h:101
Base class of Publisher.
Definition PublisherBase.h:66
PublisherFlush class.
Definition PublisherFlush.h:60
~PublisherFlush() override
Destructor.
DataPortStatus deactivate() override
deactivation
DataPortStatus init(coil::Properties &prop) override
initialization
bool isActive() override
If publisher is active state.
DataPortStatus setBuffer(CdrBufferBase *buffer) override
Setting buffer pointer.
void onReceived(ByteData &data)
Notify an ON_RECEIVED event to listeners.
Definition PublisherFlush.h:372
DataPortStatus activate() override
activation
DataPortStatus setConsumer(InPortConsumer *consumer) override
Store InPort consumer.
void onReceiverError(ByteData &data)
Notify an ON_RECEIVER_ERROR event to listeners.
Definition PublisherFlush.h:414
::RTC::DataPortStatus setListener(ConnectorInfo &info, RTC::ConnectorListenersBase *listeners) override
Set the listener.
void onSend(ByteData &data)
Notify an ON_SEND event to listners.
Definition PublisherFlush.h:358
PublisherFlush()
Constructor.
DataPortStatus write(ByteDataStreamBase *data, std::chrono::nanoseconds timeout=std::chrono::nanoseconds(-1)) override
Write data.
void onReceiverTimeout(ByteData &data)
Notify an ON_RECEIVER_TIMEOUT event to listeners.
Definition PublisherFlush.h:400
void onReceiverFull(ByteData &data)
Notify an ON_RECEIVER_FULL event to listeners.
Definition PublisherFlush.h:386
coil::Properties Properties
Definition RTC.h:72
DataPortStatus
DataPortStatus return codes.
Definition DataPortStatus.h:114
Definition DefaultPeriodicTask.h:24