20 #ifndef RTC_PUBLISHERNEW_H
21 #define RTC_PUBLISHERNEW_H
326 virtual ReturnCode
write(
const cdrMemoryStream& data,
426 virtual int svc(
void);
531 const cdrMemoryStream& data);
551 const cdrMemoryStream& data);
637 inline void onSend(
const cdrMemoryStream& data)
640 connectorData_[
ON_SEND].notify(m_profile, data);
655 connectorData_[
ON_RECEIVED].notify(m_profile, data);
726 ReturnCode m_retcode;
740 #endif // RTC_PUBLISHERNEW_H
ConnectorListeners クラス
Definition: ConnectorListener.h:813
InPortConsumer 抽象クラス
Definition: InPortConsumer.h:76
coil::Guard< coil::Mutex > Guard
Definition: PublisherNew.h:75
Definition: ConnectorListener.h:76
#define DATAPORTSTATUS_ENUM
RTC::DataPortStatus 導入
Definition: DataPortStatus.h:233
virtual ReturnCode write(const cdrMemoryStream &data, unsigned long sec, unsigned long usec)
データを書き込む
virtual ReturnCode setListener(ConnectorInfo &info, ConnectorListeners *listeners)
リスナを設定する。
DATAPORTSTATUS_ENUM PublisherNew()
コンストラクタ
Mutex クラス
Definition: Mutex.h:40
RT component logger class.
Definition: ConnectorListener.h:75
Definition: PublisherNew.h:431
ConnectorInfo クラス
Definition: ConnectorBase.h:43
coil::Mutex Mutex
Definition: PublisherNew.h:73
void onBufferWrite(const cdrMemoryStream &data)
ON_BUFFER_WRITEのリスナへ通知する。
Definition: PublisherNew.h:562
virtual ReturnCode activate()
アクティブ化する
ReturnCode invokeListener(DataPortStatus::Enum status, const cdrMemoryStream &data)
DataPortStatusに従ってリスナへ通知する関数を呼び出す。
virtual int svc(void)
スレッド実行関数
virtual ReturnCode init(coil::Properties &prop)
初期化
void onSenderError()
ON_SENDER_ERRORのリスナへ通知する。
Definition: PublisherNew.h:712
void onBufferFull(const cdrMemoryStream &data)
ON_BUFFER_FULLリスナへイベントを通知する。
Definition: PublisherNew.h:577
Definition: ConnectorListener.h:69
Enum
BufferStatus リターンコード
Definition: BufferStatus.h:84
void onBufferWriteOverwrite(const cdrMemoryStream &data)
ON_BUFFER_OVERWRITEのリスナへ通知する。
Definition: PublisherNew.h:607
Definition: ConnectorListener.h:404
void onBufferWriteTimeout(const cdrMemoryStream &data)
ON_BUFFER_WRITE_TIMEOUTのリスナへ通知する。
Definition: PublisherNew.h:592
Definition: ConnectorListener.h:74
void setPushPolicy(const coil::Properties &prop)
PushPolicy の設定
Definition: PublisherNew.h:432
virtual bool isActive()
アクティブ化確認
coil::Properties Properties
Definition: RTC.h:83
void onBufferRead(const cdrMemoryStream &data)
ON_BUFFER_READのリスナへ通知する。
Definition: PublisherNew.h:622
void onReceiverError(const cdrMemoryStream &data)
ON_RECEIVER_ERRORのリスナへ通知する。
Definition: PublisherNew.h:697
Definition: PublisherNew.h:433
ReturnCode pushAll()
push "all" policy
bool createTask(const coil::Properties &prop)
Task の設定
Definition: ConnectorListener.h:71
void onReceiverTimeout(const cdrMemoryStream &data)
ON_RECEIVER_TIMEOUTのリスナへ通知する。
Definition: PublisherNew.h:682
ReturnCode pushFifo()
push "fifo" policy
ReturnCode convertReturn(BufferStatus::Enum status, const cdrMemoryStream &data)
BufferStatus から DataPortStatus への変換
virtual ReturnCode setBuffer(CdrBufferBase *buffer)
バッファのセット
virtual ReturnCode deactivate()
非アクティブ化する
Definition: ConnectorListener.h:70
Logger クラス
Definition: SystemLogger.h:99
Definition: ConnectorListener.h:73
Definition: ConnectorListener.h:72
PeriodicTaskBase クラス
Definition: PeriodicTaskBase.h:193
Definition: PublisherNew.h:434
プロパティセットを表現するクラス
Definition: Properties.h:101
Definition: ConnectorListener.h:78
Policy
Definition: PublisherNew.h:429
Publisher 基底クラス
Definition: PublisherBase.h:63
void DLL_EXPORT PublisherNewInit()
PublisherNew クラス
Definition: PublisherNew.h:69
void onReceiverFull(const cdrMemoryStream &data)
ON_RECEIVER_FULLのリスナへ通知する。
Definition: PublisherNew.h:667
ReturnCode pushNew()
push "new" policy
coil::Condition< Mutex > Condition
Definition: PublisherNew.h:74
BufferBase 抽象クラス
Definition: BufferBase.h:104
void onReceived(const cdrMemoryStream &data)
ON_RECEIVEDのリスナへ通知する。
Definition: PublisherNew.h:652
#define DLL_EXPORT
Definition: RTC.h:73
void onSend(const cdrMemoryStream &data)
ON_SENDのリスナへ通知する。
Definition: PublisherNew.h:637
Enum
Definition: DataPortStatus.h:143
ReturnCode pushSkip()
push "skip" policy
virtual ReturnCode setConsumer(InPortConsumer *consumer)
InPortコンシューマのセット
virtual ~PublisherNew(void)
デストラクタ
Definition: ConnectorListener.h:77
Common Object Interface Layer.
Definition: Allocator.h:27