20#ifndef RTC_INPORTPUSHCONNECTOR_H
21#define RTC_INPORTPUSHCONNECTOR_H
314 bool m_sync_readwrite;
316 struct WorkerThreadCtrl
318 WorkerThreadCtrl() {}
320 std::condition_variable cond_;
321 bool completed_{
false};
323 WorkerThreadCtrl m_writecompleted_worker;
324 WorkerThreadCtrl m_readcompleted_worker;
325 WorkerThreadCtrl m_readready_worker;
InPortConnector base 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 notifyIn(ConnectorDataListenerType type, ConnectorInfo &info, ByteData &data)=0
Notify listeners. (Typed data version)
virtual::RTC::ConnectorListenerStatus::Enum notify(ConnectorListenerType type, ConnectorInfo &info)=0
Virtual Callback method.
InPortConnector base class.
Definition InPortConnector.h:54
ConnectorInfo m_profile
ConnectorInfo .
Definition InPortConnector.h:399
InPortProvider.
Definition InPortProvider.h:191
InPortPushConnector class.
Definition InPortPushConnector.h:82
~InPortPushConnector() override
Destructor.
InPortPushConnector(ConnectorInfo info, InPortProvider *provider, ConnectorListenersBase *listeners, CdrBufferBase *buffer=nullptr)
DataPortStatus disconnect() override
disconnect
void onBufferReadTimeout(ByteData &)
Definition InPortPushConnector.h:287
void onDisconnect()
Invoke callback when connection is destroied .
void deactivate() override
Connector deactivation.
Definition InPortPushConnector.h:232
BufferStatus write(ByteData &cdr) override
void onBufferEmpty(ByteData &)
Definition InPortPushConnector.h:282
void activate() override
Connector activation.
Definition InPortPushConnector.h:216
void onConnect()
Invoke callback when connection is established .
DataPortStatus read(ByteDataStreamBase *data) override
Reading data.
void onBufferRead(ByteData &data)
Definition InPortPushConnector.h:276
virtual CdrBufferBase * createBuffer(ConnectorInfo &info)
create buffer
BufferStatus
DataPortStatus return codes.
Definition BufferStatus.h:57