OpenRTM-aist 2.0.2
|
OutPortConnector base class. More...
#include <OutPortConnector.h>
Public Member Functions | |
OutPortConnector (ConnectorInfo &info, ConnectorListenersBase *listeners) | |
Constructor . | |
~OutPortConnector () override | |
Destructor . | |
const ConnectorInfo & | profile () override |
Getting Profile. | |
const char * | id () override |
Getting Connector ID. | |
const char * | name () override |
Getting Connector name. | |
DataPortStatus | disconnect () override=0 |
Disconnect connection. | |
CdrBufferBase * | getBuffer () override=0 |
Getting Buffer. | |
virtual DataPortStatus | write (ByteDataStreamBase *data)=0 |
Destructor. | |
virtual void | setEndian (bool endian_type) |
Setting an endian type. | |
virtual bool | isLittleEndian () |
return it whether endian setting. | |
template<class DataType > | |
DataPortStatus | write (DataType &data) |
The conversion template of the data type. | |
virtual BufferStatus | read (ByteData &data) |
bool | setInPort (InPortBase *directInPort) |
virtual void | setPullDirectMode () |
virtual bool | pullDirectMode () |
virtual void | unsubscribeInterface (const coil::Properties &prop) |
![]() | |
virtual | ~ConnectorBase ()=default |
Destructor . | |
virtual void | activate ()=0 |
Connector activation. | |
virtual void | deactivate ()=0 |
Connector deactivation. | |
Protected Attributes | |
Logger | rtclog |
Logger streamf . | |
ConnectorInfo | m_profile |
PortProfile of the Port . | |
bool | m_littleEndian |
Connected Endian . | |
PortBase * | m_directInPort |
InProt pointer to the peer in the same process . | |
ConnectorListenersBase * | m_listeners |
A reference to a ConnectorListener . | |
ConnectorListenersBase * | m_inPortListeners |
A pointer to a InPort's ConnectorListener . | |
bool | m_directMode |
std::string | m_marshaling_type |
ByteDataStreamBase * | m_cdr |
OutPortConnector base class.
The base class to derive subclasses for OutPort's Push/Pull Connectors
RTC::OutPortConnector::OutPortConnector | ( | ConnectorInfo & | info, |
ConnectorListenersBase * | listeners ) |
Constructor .
|
override |
Destructor .
|
overridepure virtual |
Disconnect connection.
This operation disconnect this connection
Implements RTC::ConnectorBase.
Implemented in RTC::OutPortPullConnector, and RTC::OutPortPushConnector.
|
overridepure virtual |
Getting Buffer.
This operation returns this connector's buffer
Implements RTC::ConnectorBase.
Implemented in RTC::OutPortPullConnector, and RTC::OutPortPushConnector.
|
overridevirtual |
|
virtual |
return it whether endian setting.
Referenced by write().
|
overridevirtual |
|
overridevirtual |
|
virtual |
|
virtual |
Reimplemented in RTC::OutPortPullConnector.
|
virtual |
Setting an endian type.
This operation set this connector's endian type
bool RTC::OutPortConnector::setInPort | ( | InPortBase * | directInPort | ) |
|
virtual |
|
virtual |
prop |
Reimplemented in RTC::OutPortPushConnector.
|
pure virtual |
Destructor.
The write function to write data from OutPort to Buffer
Implemented in RTC::OutPortPullConnector, and RTC::OutPortPushConnector.
Referenced by write().
|
inline |
The conversion template of the data type.
This is convert it from Timed* into CdrStream.
References RTC::createSerializer(), RTC::PortBase::getDirectPort(), RTC::ByteDataStreamBase::isLittleEndian(), isLittleEndian(), RTC::DirectInPortBase< DataType >::isNew(), m_cdr, m_directInPort, m_inPortListeners, m_listeners, m_marshaling_type, m_profile, RTC::ConnectorListenersBase::notifyIn(), RTC::ConnectorListenersBase::notifyOut(), RTC::ON_BUFFER_OVERWRITE, RTC::ON_BUFFER_WRITE, RTC::ON_RECEIVED, RTC::ON_RECEIVER_FULL, RTC::PORT_ERROR, RTC::PORT_OK, RTC_ERROR, RTC_PARANOID, RTC_TRACE, RTC::ByteDataStream< DataType >::serialize(), RTC::DirectInPortBase< DataType >::write(), and write().
|
protected |
Referenced by write().
|
protected |
InProt pointer to the peer in the same process .
Referenced by write().
|
protected |
|
protected |
A pointer to a InPort's ConnectorListener .
Referenced by write().
|
protected |
A reference to a ConnectorListener .
Referenced by write().
|
protected |
Connected Endian .
|
protected |
Referenced by write().
|
protected |
PortProfile of the Port .
Referenced by write().