20 #ifndef RTC_PUBLISHERNEW_H 21 #define RTC_PUBLISHERNEW_H 326 virtual ReturnCode write(cdrMemoryStream& data,
357 virtual bool isActive();
426 virtual int svc(
void);
458 ReturnCode pushAll();
463 ReturnCode pushFifo();
468 ReturnCode pushSkip();
473 ReturnCode pushNew();
531 cdrMemoryStream& data);
551 cdrMemoryStream& data);
637 inline void onSend(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 class.
Definition: ConnectorListener.h:1217
InPortConsumer abstract class.
Definition: InPortConsumer.h:76
coil::Guard< coil::Mutex > Guard
Definition: PublisherNew.h:75
Definition: ConnectorListener.h:147
#define DATAPORTSTATUS_ENUM
Importing RTC::DataPortStatus macro.
Definition: DataPortStatus.h:233
void onSend(cdrMemoryStream &data)
Notify an ON_SEND event to listners.
Definition: PublisherNew.h:637
Mutex class.
Definition: Mutex.h:40
void onBufferFull(cdrMemoryStream &data)
Notify an ON_BUFFER_FULL event to listeners.
Definition: PublisherNew.h:577
RT component logger class.
Definition: ConnectorListener.h:146
Definition: PublisherNew.h:431
RTC::ReturnCode_t activate(RTC::RTObject_ptr rtc, RTC::UniqueId ec_id=0)
Definition: ConnectorBase.h:43
coil::Mutex Mutex
Definition: PublisherNew.h:73
void onSenderError()
Notify an ON_SENDER_ERROR event to listeners.
Definition: PublisherNew.h:712
void onBufferWriteOverwrite(cdrMemoryStream &data)
Notify an ON_BUFFER_OVERWRITE event to listeners.
Definition: PublisherNew.h:607
Definition: ConnectorListener.h:140
Enum
DataPortStatus return codes.
Definition: BufferStatus.h:84
Definition: ConnectorListener.h:624
void onReceiverError(cdrMemoryStream &data)
Notify an ON_RECEIVER_ERROR event to listeners.
Definition: PublisherNew.h:697
Definition: ConnectorListener.h:145
Definition: PublisherNew.h:432
coil::Properties Properties
Definition: RTC.h:83
Definition: PublisherNew.h:433
Definition: ConnectorListener.h:142
Definition: ConnectorListener.h:141
Logger class.
Definition: SystemLogger.h:99
Definition: ConnectorListener.h:144
Definition: ConnectorListener.h:143
PeriodicTaskBase class.
Definition: PeriodicTaskBase.h:193
RTC::ReturnCode_t deactivate(RTC::RTObject_ptr rtc, RTC::UniqueId ec_id=0)
Class represents a set of properties.
Definition: Properties.h:101
void onBufferRead(cdrMemoryStream &data)
Notify an ON_BUFFER_READ event to listeners.
Definition: PublisherNew.h:622
Definition: ConnectorListener.h:149
void onBufferWrite(cdrMemoryStream &data)
Notify an ON_BUFFER_WRITE event to listeners.
Definition: PublisherNew.h:562
Policy
Definition: PublisherNew.h:429
Base class of Publisher.
Definition: PublisherBase.h:63
void DLL_EXPORT PublisherNewInit()
void onReceiverTimeout(cdrMemoryStream &data)
Notify an ON_RECEIVER_TIMEOUT event to listeners.
Definition: PublisherNew.h:682
PublisherNew class.
Definition: PublisherNew.h:69
coil::Condition< Mutex > Condition
Definition: PublisherNew.h:74
BufferBase abstract class.
Definition: BufferBase.h:104
#define DLL_EXPORT
Definition: RTC.h:73
void onReceived(cdrMemoryStream &data)
Notify an ON_RECEIVED event to listeners.
Definition: PublisherNew.h:652
Enum
DataPortStatus return codes.
Definition: DataPortStatus.h:143
void onBufferWriteTimeout(cdrMemoryStream &data)
Notify an ON_BUFFER_WRITE_TIMEOUT event to listeners.
Definition: PublisherNew.h:592
Definition: ConnectorListener.h:148
Common Object Interface Layer.
Definition: Affinity.h:28
void onReceiverFull(cdrMemoryStream &data)
Notify an ON_RECEIVER_FULL event to listeners.
Definition: PublisherNew.h:667