20 #ifndef RTC_PUBLISHERPERIODIC_H
21 #define RTC_PUBLISHERPERIODIC_H
326 virtual ReturnCode
write(
const cdrMemoryStream& data,
425 virtual int svc(
void);
530 const cdrMemoryStream& data);
551 const cdrMemoryStream& data);
622 inline void onSend(
const cdrMemoryStream& data)
625 connectorData_[
ON_SEND].notify(m_profile, data);
640 connectorData_[
ON_RECEIVED].notify(m_profile, data);
731 if (m_buffer->
empty() && !m_readback)
742 InPortConsumer* m_consumer;
744 ConnectorInfo m_profile;
746 ConnectorListeners* m_listeners;
747 ReturnCode m_retcode;
762 #endif // RTC_PUBLISHERPERIODIC_H
Definition: ConnectorListener.h:402
ConnectorListeners class.
Definition: ConnectorListener.h:813
InPortConsumer abstract class.
Definition: InPortConsumer.h:76
void onBufferWriteTimeout(const cdrMemoryStream &data)
Notify an ON_BUFFER_WRITE_TIMEOUT event to listeners.
Definition: PublisherPeriodic.h:592
BufferBase< cdrMemoryStream > CdrBufferBase
Definition: CdrBufferBase.h:30
Definition: ConnectorListener.h:76
#define DATAPORTSTATUS_ENUM
Importing RTC::DataPortStatus macro.
Definition: DataPortStatus.h:233
ReturnCode invokeListener(DataPortStatus::Enum status, const cdrMemoryStream &data)
Call listeners according to the DataPortStatus.
virtual ReturnCode write(const cdrMemoryStream &data, unsigned long sec, unsigned long usec)
Write data.
Mutex class.
Definition: Mutex.h:40
RT component logger class.
Definition: ConnectorListener.h:75
Definition: ConnectorBase.h:43
void onReceiverTimeout(const cdrMemoryStream &data)
Notify an ON_RECEIVER_TIMEOUT event to listeners.
Definition: PublisherPeriodic.h:667
void onReceiverError(const cdrMemoryStream &data)
Notify an ON_RECEIVER_ERROR event to listeners.
Definition: PublisherPeriodic.h:682
void onSenderError()
Notify an ON_SENDER_ERROR event to listeners.
Definition: PublisherPeriodic.h:721
Definition: ConnectorListener.h:69
void onBufferWrite(const cdrMemoryStream &data)
Notify an ON_BUFFER_WRITE event to listeners.
Definition: PublisherPeriodic.h:562
Definition: PublisherPeriodic.h:433
virtual ReturnCode deactivate()
deactivation
Enum
DataPortStatus return codes.
Definition: BufferStatus.h:84
Definition: PublisherPeriodic.h:430
void onBufferRead(const cdrMemoryStream &data)
Notify an ON_BUFFER_READ event to listeners.
Definition: PublisherPeriodic.h:607
void setPushPolicy(const coil::Properties &prop)
Setting PushPolicy.
Definition: ConnectorListener.h:404
virtual ~PublisherPeriodic(void)
Destructor.
Definition: ConnectorListener.h:74
void onReceiverFull(const cdrMemoryStream &data)
Notify an ON_RECEIVER_FULL event to listeners.
Definition: PublisherPeriodic.h:652
#define RTC_DEBUG(fmt)
Debug level log output macro.
Definition: SystemLogger.h:488
ReturnCode convertReturn(BufferStatus::Enum status, const cdrMemoryStream &data)
Convertion from BufferStatus to DataPortStatus.
coil::Properties Properties
Definition: RTC.h:83
ReturnCode pushNew()
push "new" policy
void onSenderEmpty()
Notify an ON_SENDER_EMPTY event to listeners.
Definition: PublisherPeriodic.h:708
ReturnCode pushAll()
push "all" policy
virtual ReturnCode setConsumer(InPortConsumer *consumer)
Store InPort consumer.
Definition: PublisherPeriodic.h:432
Definition: ConnectorListener.h:71
PublisherPeriodic class.
Definition: PublisherPeriodic.h:64
coil::Guard< coil::Mutex > Guard
Definition: PublisherPeriodic.h:70
Definition: ConnectorListener.h:70
virtual ReturnCode setListener(ConnectorInfo &info, ConnectorListeners *listeners)
Set the listener.
Definition: ConnectorListener.h:73
PeriodicTaskBase class.
Definition: PeriodicTaskBase.h:193
void onReceived(const cdrMemoryStream &data)
Notify an ON_RECEIVED event to listeners.
Definition: PublisherPeriodic.h:637
void onBufferFull(const cdrMemoryStream &data)
Notify an ON_BUFFER_FULL event to listeners.
Definition: PublisherPeriodic.h:577
Definition: PublisherPeriodic.h:431
Class represents a set of properties.
Definition: Properties.h:101
DATAPORTSTATUS_ENUM PublisherPeriodic(void)
Constructor.
Definition: ConnectorListener.h:78
void DLL_EXPORT PublisherPeriodicInit()
ReturnCode pushSkip()
push "skip" policy
Definition: ConnectorListener.h:400
Policy
Definition: PublisherPeriodic.h:428
Base class of Publisher.
Definition: PublisherBase.h:63
bool createTask(const coil::Properties &prop)
Setting Task.
ReturnCode pushFifo()
push "fifo" policy
virtual int svc(void)
Thread execution function.
virtual ReturnCode activate()
activation
coil::Mutex Mutex
Definition: PublisherPeriodic.h:68
void onBufferEmpty()
Notify an ON_BUFFER_EMPTY event to listeners.
Definition: PublisherPeriodic.h:695
virtual ReturnCode init(coil::Properties &prop)
Initialization.
virtual bool isActive()
If publisher is active state.
BufferBase abstract class.
Definition: BufferBase.h:104
#define DLL_EXPORT
Definition: RTC.h:73
virtual ReturnCode setBuffer(CdrBufferBase *buffer)
Setting buffer pointer.
Enum
DataPortStatus return codes.
Definition: DataPortStatus.h:143
virtual bool empty(void) const =0
Check on whether the buffer is empty.
coil::Condition< Mutex > Condition
Definition: PublisherPeriodic.h:69
void onSend(const cdrMemoryStream &data)
Notify an ON_SEND event to listners.
Definition: PublisherPeriodic.h:622
Definition: ConnectorListener.h:77
Common Object Interface Layer.
Definition: Allocator.h:27