20#ifndef RTC_OUTPORTPULLCONNECTOR_H
21#define RTC_OUTPORTPULLCONNECTOR_H
28 class OutPortProvider;
287 bool m_sync_readwrite;
289 struct WorkerThreadCtrl
291 WorkerThreadCtrl() {}
293 std::condition_variable cond_;
294 bool completed_{
false};
296 WorkerThreadCtrl m_writecompleted_worker;
297 WorkerThreadCtrl m_readcompleted_worker;
298 WorkerThreadCtrl m_readready_worker;
DataPortStatus mixin class.
BufferBase abstract class.
Definition BufferBase.h:106
Definition ByteDataStreamBase.h:63
ConnectorInfo class.
Definition ConnectorBase.h:50
Definition ConnectorListener.h:1354
OutPortConnector base class.
Definition OutPortConnector.h:58
OutPortProvider.
Definition OutPortProvider.h:190
OutPortPullConnector class.
Definition OutPortPullConnector.h:83
BufferStatus read(ByteData &data) override
void onDisconnect()
Invoke callback when connection is destroied .
void onConnect()
Invoke callback when connection is established .
OutPortProvider * m_provider
the pointer to the OutPortProvider
Definition OutPortPullConnector.h:267
~OutPortPullConnector() override
Destructor.
static CdrBufferBase * createBuffer(ConnectorInfo &info)
create buffer
OutPortPullConnector(ConnectorInfo info, OutPortProvider *provider, ConnectorListenersBase *listeners, CdrBufferBase *buffer=nullptr)
Constructor.
void activate() override
Connector activation.
Definition OutPortPullConnector.h:214
CdrBufferBase * m_buffer
the pointer to the buffer
Definition OutPortPullConnector.h:285
CdrBufferBase * getBuffer() override
Getting Buffer.
ConnectorListenersBase * m_listeners
A reference to a ConnectorListener .
Definition OutPortPullConnector.h:276
void deactivate() override
Connector deactivation.
Definition OutPortPullConnector.h:230
DataPortStatus disconnect() override
disconnect
DataPortStatus write(ByteDataStreamBase *data) override
Writing data.
BufferStatus
DataPortStatus return codes.
Definition BufferStatus.h:57