20 #ifndef RTC_PUBLISHERFLUSH_H
21 #define RTC_PUBLISHERFLUSH_H
206 virtual ::RTC::DataPortStatus::Enum
268 virtual ReturnCode
write(
const cdrMemoryStream& data,
364 inline void onSend(
const cdrMemoryStream& data)
367 connectorData_[
ON_SEND].notify(m_profile, data);
382 connectorData_[
ON_RECEIVED].notify(m_profile, data);
435 ReturnCode m_retcode;
447 #endif // RTC_PUBLISHERFLUSH_H
ConnectorListeners クラス
Definition: ConnectorListener.h:813
InPortConsumer 抽象クラス
Definition: InPortConsumer.h:76
Definition: ConnectorListener.h:76
#define DATAPORTSTATUS_ENUM
RTC::DataPortStatus 導入
Definition: DataPortStatus.h:233
void DLL_EXPORT PublisherFlushInit()
void onReceiverError(const cdrMemoryStream &data)
ON_RECEIVER_ERRORのリスナへ通知する。
Definition: PublisherFlush.h:424
Mutex クラス
Definition: Mutex.h:40
RT component logger class.
Definition: ConnectorListener.h:75
ConnectorInfo クラス
Definition: ConnectorBase.h:43
virtual ReturnCode deactivate()
非アクティブ化する
virtual ReturnCode setBuffer(CdrBufferBase *buffer)
バッファのセット
void onReceived(const cdrMemoryStream &data)
ON_RECEIVEDのリスナへ通知する。
Definition: PublisherFlush.h:379
DATAPORTSTATUS_ENUM PublisherFlush()
コンストラクタ
virtual ReturnCode setConsumer(InPortConsumer *consumer)
InPortコンシューマのセット
PublisherFlush クラス
Definition: PublisherFlush.h:58
Definition: ConnectorListener.h:74
coil::Properties Properties
Definition: RTC.h:83
coil::Mutex Mutex
Definition: PublisherFlush.h:62
coil::Condition< Mutex > Condition
Definition: PublisherFlush.h:63
void onSend(const cdrMemoryStream &data)
ON_SENDのリスナへ通知する。
Definition: PublisherFlush.h:364
void onReceiverTimeout(const cdrMemoryStream &data)
ON_RECEIVER_TIMEOUTのリスナへ通知する。
Definition: PublisherFlush.h:409
virtual bool isActive()
アクティブ化確認
Logger クラス
Definition: SystemLogger.h:99
virtual ReturnCode write(const cdrMemoryStream &data, unsigned long sec, unsigned long usec)
データを書き込む
virtual ReturnCode init(coil::Properties &prop)
初期化
プロパティセットを表現するクラス
Definition: Properties.h:101
Definition: ConnectorListener.h:78
Publisher 基底クラス
Definition: PublisherBase.h:63
virtual ~PublisherFlush(void)
デストラクタ
virtual ::RTC::DataPortStatus::Enum setListener(ConnectorInfo &profile, RTC::ConnectorListeners *listeners)
リスナを設定する。
BufferBase 抽象クラス
Definition: BufferBase.h:104
#define DLL_EXPORT
Definition: RTC.h:73
virtual ReturnCode activate()
アクティブ化する
coil::Guard< coil::Mutex > Guard
Definition: PublisherFlush.h:64
Definition: ConnectorListener.h:77
Common Object Interface Layer.
Definition: Allocator.h:27
void onReceiverFull(const cdrMemoryStream &data)
ON_RECEIVER_FULLのリスナへ通知する。
Definition: PublisherFlush.h:394