Class astutedds::rtps::TCPTransport

ClassList > astutedds > rtps > TCPTransport

Manages TCP connections for RTPS. More...

• #include <tcp_transport.hpp>

Classes

Type	Name
struct	Config TCP transport configuration.
struct	Stats Get transport statistics.

Public Functions

Type	Name
	TCPTransport ()
	TCPTransport (const Config & config)
	TCPTransport (const TCPTransport &) = delete
std::vector< std::shared_ptr< TCPConnection > >	get_connections () const Get all active connections.
Locator_t	get_local_locator () const Get local locator for this transport.
std::shared_ptr< TCPConnection >	get_or_connect (const Locator_t & locator) Get or create connection to locator.
Stats	get_stats () const
bool	init () Initialize transport.
bool	is_running () const Check if transport is running.
TCPTransport &	operator= (const TCPTransport &) = delete
bool	send (const Locator_t & locator, const std::vector< uint8_t > & data) Send data to locator.
void	set_receive_callback (TCPReceiveCallback callback) Set callback for received data.
void	shutdown () Shutdown transport.
	~TCPTransport ()

Detailed Description

Provides connection pooling, reconnection logic, and event-driven I/O.

Public Functions Documentation

function TCPTransport [1/3]

astutedds::rtps::TCPTransport::TCPTransport () 

---

function TCPTransport [2/3]

explicit astutedds::rtps::TCPTransport::TCPTransport (
    const Config & config
) 

---

function TCPTransport [3/3]

astutedds::rtps::TCPTransport::TCPTransport (
    const TCPTransport &
) = delete

---

function get_connections

Get all active connections.

std::vector< std::shared_ptr< TCPConnection > > astutedds::rtps::TCPTransport::get_connections () const

---

function get_local_locator

Get local locator for this transport.

Locator_t astutedds::rtps::TCPTransport::get_local_locator () const

---

function get_or_connect

Get or create connection to locator.

std::shared_ptr< TCPConnection > astutedds::rtps::TCPTransport::get_or_connect (
    const Locator_t & locator
) 

Parameters:

• locator TCP locator

Returns:

Connection pointer or nullptr

---

function get_stats

Stats astutedds::rtps::TCPTransport::get_stats () const

---

function init

Initialize transport.

bool astutedds::rtps::TCPTransport::init () 

Returns:

true if successful

---

function is_running

Check if transport is running.

inline bool astutedds::rtps::TCPTransport::is_running () const

---

function operator=

TCPTransport & astutedds::rtps::TCPTransport::operator= (
    const TCPTransport &
) = delete

---

function send

Send data to locator.

bool astutedds::rtps::TCPTransport::send (
    const Locator_t & locator,
    const std::vector< uint8_t > & data
) 

Parameters:

• locator Destination locator
• data Data to send

Returns:

true if sent or queued

---

function set_receive_callback

Set callback for received data.

void astutedds::rtps::TCPTransport::set_receive_callback (
    TCPReceiveCallback callback
) 

---

function shutdown

Shutdown transport.

void astutedds::rtps::TCPTransport::shutdown () 

---

function ~TCPTransport

astutedds::rtps::TCPTransport::~TCPTransport () 

---

---

The documentation for this class was generated from the following file include/astutedds/rtps/tcp_transport.hpp