eprosima::safedds::protocol::rtps::ProcessorDispatcher Class Reference

ProcessorDispatcher implementation. More...

#include <ProcessorDispatcher.hpp>

Public Member Functions
	ProcessorDispatcher (memory::IReferenceList< Reader > &reader_storage, memory::IReferenceList< Writer > &writer_storage) noexcept
	ProcessorDispatcher constructor. More...
	ProcessorDispatcher (memory::IReferenceList< Reader > &reader_storage, memory::IReferenceList< Writer > &writer_storage, ProcessorProperties processor_properties) noexcept
	Overload of processor constructor with configured properties. More...
virtual	~ProcessorDispatcher () noexcept=default
	Virtual destructor. More...
	ProcessorDispatcher (const ProcessorDispatcher &) noexcept=delete
	Copy deleted. More...
	ProcessorDispatcher (ProcessorDispatcher &&) noexcept=delete
	Movement deleted. More...
ProcessorDispatcher &	operator= (const ProcessorDispatcher &) noexcept=delete
	Copy operator deleted. More...
ProcessorDispatcher &	operator= (ProcessorDispatcher &&) noexcept=delete
	Movement operator deleted. More...
ReturnCode	add_reader (Reader &reader) noexcept override
	Add Reader to dispatcher. More...
ReturnCode	add_writer (Writer &writer) noexcept override
	Add Writer to dispatcher. More...
void	process_heartbeat (const ProcessorState &processor_state, const Submessage< Heartbeat > &heartbeat) noexcept override
void	process_data (const ProcessorState &processor_state, const Submessage< Data > &data, const memory::IConstByteArrayView &inline_qos, const memory::IConstByteArrayView &payload) noexcept override
void	process_datafrag (const ProcessorState &processor_state, const Submessage< DataFrag > &data_frag, const memory::IConstByteArrayView &inline_qos, const memory::IConstByteArrayView &payload) noexcept override
void	process_gap (const ProcessorState &processor_state, const Submessage< Gap > &gap) noexcept override
void	process_acknack (const ProcessorState &processor_state, const Submessage< AckNack > &acknack) noexcept override
void	process_nackfrag (const ProcessorState &processor_state, const Submessage< NackFrag > &nackfrag) noexcept override
ReturnCode	process_unknown (ProcessorState &processor_state, const memory::IConstByteArrayView &submessage) noexcept override
ReturnCode	process_message (const memory::IConstByteArrayView &message) noexcept override

Detailed Description

ProcessorDispatcher implementation.

Constructor & Destructor Documentation

ProcessorDispatcher() [1/4]

eprosima::safedds::protocol::rtps::ProcessorDispatcher::ProcessorDispatcher ( memory::IReferenceList< Reader > &  reader_storage, memory::IReferenceList< Writer > &  writer_storage  )

noexcept

ProcessorDispatcher constructor.

Parameters

reader_storage	reference to reader storage. Ownership is not taken.
writer_storage	reference to writer storage. Ownership is not taken.

ProcessorDispatcher() [2/4]

eprosima::safedds::protocol::rtps::ProcessorDispatcher::ProcessorDispatcher ( memory::IReferenceList< Reader > &  reader_storage, memory::IReferenceList< Writer > &  writer_storage, ProcessorProperties  processor_properties  )

noexcept

Overload of processor constructor with configured properties.

Parameters

reader_storage	reference to reader storage. Ownership is not taken.
writer_storage	reference to writer storage. Ownership is not taken.
processor_properties	processor properties.

~ProcessorDispatcher()

virtual eprosima::safedds::protocol::rtps::ProcessorDispatcher::~ProcessorDispatcher ( )

virtualdefaultnoexcept

Virtual destructor.

ProcessorDispatcher() [3/4]

eprosima::safedds::protocol::rtps::ProcessorDispatcher::ProcessorDispatcher ( const ProcessorDispatcher &  )

deletenoexcept

Copy deleted.

ProcessorDispatcher() [4/4]

eprosima::safedds::protocol::rtps::ProcessorDispatcher::ProcessorDispatcher ( ProcessorDispatcher &&  )

deletenoexcept

Movement deleted.

Member Function Documentation

add_reader()

ReturnCode eprosima::safedds::protocol::rtps::ProcessorDispatcher::add_reader ( Reader &  reader )

overridenoexcept

Add Reader to dispatcher.

Parameters

reader

reference to Reader.

Returns

ReturnCode.

add_writer()

ReturnCode eprosima::safedds::protocol::rtps::ProcessorDispatcher::add_writer ( Writer &  writer )

overridenoexcept

Add Writer to dispatcher.

Parameters

writer

reference to Writer.

Returns

ReturnCode.

operator=() [1/2]

ProcessorDispatcher& eprosima::safedds::protocol::rtps::ProcessorDispatcher::operator= ( const ProcessorDispatcher &  )

deletenoexcept

Copy operator deleted.

operator=() [2/2]

ProcessorDispatcher& eprosima::safedds::protocol::rtps::ProcessorDispatcher::operator= ( ProcessorDispatcher &&  )

deletenoexcept

Movement operator deleted.

process_acknack()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_acknack ( const ProcessorState &  processor_state, const Submessage< AckNack > &  acknack  )

overridenoexcept

process_data()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_data ( const ProcessorState &  processor_state, const Submessage< Data > &  data, const memory::IConstByteArrayView &  inline_qos, const memory::IConstByteArrayView &  payload  )

overridenoexcept

process_datafrag()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_datafrag ( const ProcessorState &  processor_state, const Submessage< DataFrag > &  data_frag, const memory::IConstByteArrayView &  inline_qos, const memory::IConstByteArrayView &  payload  )

overridenoexcept

process_gap()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_gap ( const ProcessorState &  processor_state, const Submessage< Gap > &  gap  )

overridenoexcept

process_heartbeat()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_heartbeat ( const ProcessorState &  processor_state, const Submessage< Heartbeat > &  heartbeat  )

overridenoexcept

process_message()

ReturnCode eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_message ( const memory::IConstByteArrayView &  message )

overridenoexcept

process_nackfrag()

void eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_nackfrag ( const ProcessorState &  processor_state, const Submessage< NackFrag > &  nackfrag  )

overridenoexcept

process_unknown()

ReturnCode eprosima::safedds::protocol::rtps::ProcessorDispatcher::process_unknown ( ProcessorState &  processor_state, const memory::IConstByteArrayView &  submessage  )

overridenoexcept

---

The documentation for this class was generated from the following file:

• build/docs/user_manual/v2.0.0/tmp/include/safedds/protocol/rtps/ProcessorDispatcher.hpp