20#ifndef RTC_INPORTCONNECTOR_H
21#define RTC_INPORTCONNECTOR_H
120 const char*
id()
override;
220 template<
class DataType>
320 template <
typename DataType>
340 "ON_SENDER_EMPTY(InPort,OutPort) "
341 "callback called in direct mode."));
347 RTC_TRACE((
"ON_BUFFER_READ(OutPort), "));
348 RTC_TRACE((
"callback called in direct mode."));
352 RTC_TRACE((
"callback called in direct mode."));
356 RTC_TRACE((
"callback called in direct mode."));
359 RTC_TRACE((
"ON_BUFFER_WRITE(InPort), "));
360 RTC_TRACE((
"callback called in direct mode."));
#define RTC_PARANOID(fmt)
Paranoid level log output macro.
Definition SystemLogger.h:732
#define RTC_TRACE(fmt)
Trace level log output macro.
Definition SystemLogger.h:687
#define RTC_ERROR(fmt)
Error log output macro.
Definition SystemLogger.h:599
DataPortStatus mixin class.
BufferBase abstract class.
Definition BufferBase.h:106
Definition ByteDataStreamBase.h:63
virtual void isLittleEndian(bool little_endian)
Definition ByteDataStreamBase.h:200
virtual bool deserialize(DataType &data)=0
Connector Base class.
Definition ConnectorBase.h:209
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 notifyOut(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.
Definition DirectOutPortBase.h:48
virtual void read(DataType &data)=0
InPortConnector base class.
Definition InPortConnector.h:54
DataPortStatus disconnect() override=0
Disconnect connection.
virtual BufferStatus write(ByteData &cdr)
std::string m_marshaling_type
Definition InPortConnector.h:448
virtual void unsubscribeInterface(const coil::Properties &prop)
bool setOutPort(OutPortBase *directOutPort)
const char * name() override
Getting Connector name.
CdrBufferBase * getBuffer() override
Getting Buffer.
ByteDataStreamBase * m_cdr
Definition InPortConnector.h:457
bool m_littleEndian
Connected Endian .
Definition InPortConnector.h:423
const char * id() override
Getting Connector ID.
Logger rtclog
Logger stream .
Definition InPortConnector.h:391
ConnectorInfo m_profile
ConnectorInfo .
Definition InPortConnector.h:399
bool getDirectData(DataType &data)
Definition InPortConnector.h:321
const ConnectorInfo & profile() override
Getting ConnectorInfo.
ConnectorListenersBase * m_listeners
A reference to a ConnectorListener .
Definition InPortConnector.h:407
PortBase * m_directOutPort
OutProt pointer to the peer in the same process .
Definition InPortConnector.h:439
virtual bool isLittleEndian()
Whether this connector's endian is little.
virtual void setEndian(bool endian_type)
Setting an endian type.
DataPortStatus read(DataType &data)
Definition InPortConnector.h:221
virtual DataPortStatus read(ByteDataStreamBase *data)=0
Destructor.
ConnectorListenersBase * m_outPortListeners
A pointer to a OutPort's ConnectorListener .
Definition InPortConnector.h:431
~InPortConnector() override
Destructor .
InPortConnector(ConnectorInfo &info, ConnectorListenersBase *listeners, CdrBufferBase *buffer)
Constructor.
CdrBufferBase * m_buffer
Connector's buffer .
Definition InPortConnector.h:415
Logger class.
Definition SystemLogger.h:101
Output base class.
Definition OutPortBase.h:229
Port base class.
Definition PortBase.h:132
virtual DirectPortBase * getDirectPort()
::RTC::ByteDataStreamBase * createSerializer(const std::string &marshalingtype)
Definition ByteDataStreamBase.h:363
BufferStatus
DataPortStatus return codes.
Definition BufferStatus.h:57