TCP connection using TLV messages. More...

#include <tstlvConnection.h>

Inheritance diagram for ts::tlv::Connection< SAFETY >:

[legend]

Collaboration diagram for ts::tlv::Connection< SAFETY >:

[legend]

Public Types
using	MutexType = typename ThreadSafetyMutex< SAFETY >::type
	Generic definition of the mutex for this class.

using	SuperClass = ts::TCPConnection
	Reference to superclass.

Public Member Functions
	Connection (const Protocol &protocol, bool auto_error_response=true, size_t max_invalid_msg=0)
	Constructor.

bool	bind (const IPSocketAddress &addr, Report &report=(ts::CerrReport::Instance()))
	Bind to a local address and port.

virtual bool	close (Report &report=(ts::CerrReport::Instance())) override
	Close the socket.

bool	closeWriter (Report &report=(ts::CerrReport::Instance()))
	Close the write direction of the connection.

bool	connect (const IPSocketAddress &addr, Report &report=(ts::CerrReport::Instance()))
	Connect to a remote address and port.

bool	disconnect (Report &report=(ts::CerrReport::Instance()))
	Disconnect from remote partner.

IP	generation () const
	Get the IP generation with which the socket was open.

bool	getAutoErrorResponse () const
	Get invalid incoming messages processing.

bool	getLocalAddress (IPSocketAddress &addr, Report &report=(ts::CerrReport::Instance()))
	Get local socket address.

size_t	getMaxInvalidMessages () const
	Get invalid message threshold.

bool	getPeer (IPSocketAddress &addr, Report &report=(ts::CerrReport::Instance())) const
	Get the connected remote peer.

SysSocketType	getSocket () const
	Get the underlying socket device handle (use with care).

bool	isConnected () const
	Check if the socket is connected.

bool	isOpen () const
	Check if socket is open.

virtual bool	open (IP gen, Report &report=(ts::CerrReport::Instance())) override
	Open the socket.

UString	peerName () const
	Get the connected remote peer as a string.

bool	receive (MessagePtr &msg, const AbortInterface *abort, Logger &logger)
	Receive a TLV message.

bool	receive (MessagePtr &msg, const AbortInterface *abort, Report &report)
	Receive a TLV message.

bool	receive (void buffer, size_t max_size, size_t &ret_size, const AbortInterface abort=nullptr, Report &report=(ts::CerrReport::Instance()))
	Receive data.

bool	receive (void buffer, size_t size, const AbortInterface abort=nullptr, Report &report=(ts::CerrReport::Instance()))
	Receive data until buffer is full.

bool	reusePort (bool reuse_port, Report &report=(ts::CerrReport::Instance()))
	Set the "reuse port" option.

bool	send (const Message &msg, Logger &logger)
	Serialize and send a TLV message.

bool	send (const Message &msg, Report &report)
	Serialize and send a TLV message.

bool	send (const void *data, size_t size, Report &report=(ts::CerrReport::Instance()))
	Send data.

void	setAutoErrorResponse (bool on)
	Set invalid incoming messages processing.

bool	setKeepAlive (bool active, Report &report=(ts::CerrReport::Instance()))
	Set the "keep alive" option.

bool	setLingerTime (int seconds, Report &report=(ts::CerrReport::Instance()))
	Set the linger time option.

void	setMaxInvalidMessages (size_t n)
	Set invalid message threshold.

bool	setNoDelay (bool active, Report &report=(ts::CerrReport::Instance()))
	Set the "no delay" option.

bool	setNoLinger (Report &report=(ts::CerrReport::Instance()))
	Remove the linger time option.

bool	setReceiveBufferSize (size_t size, Report &report=(ts::CerrReport::Instance()))
	Set the receive buffer size.

bool	setReceiveTimeout (cn::milliseconds timeout, Report &report=(ts::CerrReport::Instance()))
	Set the receive timeout.

bool	setSendBufferSize (size_t size, Report &report=(ts::CerrReport::Instance()))
	Set the send buffer size.

bool	setTTL (int ttl, Report &report=(ts::CerrReport::Instance()))
	Set the Time To Live (TTL) option.

Protected Member Functions
bool	convert (IPAddress &addr, Report &report) const
	Convert an IP address to make it compatible with the socket IP generation.

bool	createSocket (IP gen, int type, int protocol, Report &report)
	Create the socket.

virtual void	declareOpened (SysSocketType sock, Report &report) override
	Set an open socket descriptor from a subclass.

virtual void	handleClosed (Report &report=(ts::CerrReport::Instance())) override
	This virtual method can be overriden by subclasses to be notified of close.

virtual void	handleConnected (Report &) override
	This virtual method can be overriden by subclasses to be notified of connection.

virtual void	handleDisconnected (Report &report=(ts::CerrReport::Instance()))
	This virtual method can be overriden by subclasses to be notified of disconnection.

virtual void	handleOpened (Report &report)
	This virtual method can be overriden by subclasses to be notified of open.

Protected Attributes
std::recursive_mutex	_mutex {}
	Mutex protecting this object.

Detailed Description

template<ThreadSafety SAFETY>
class ts::tlv::Connection< SAFETY >

TCP connection using TLV messages.

Template Parameters

SAFETY The required type of thread-safety.

Constructor & Destructor Documentation

◆ Connection()

template<ts::ThreadSafety SAFETY>

ts::tlv::Connection< SAFETY >::Connection	(	const Protocol &	protocol,
		bool	auto_error_response = `true`,
		size_t	max_invalid_msg = `0`
	)

explicit

Constructor.

Parameters

[in]	protocol	The incoming messages are interpreted according to this protocol. The reference is kept in this object.
[in]	auto_error_response	When an invalid message is received, the corresponding error message is automatically sent back to the sender when auto_error_response is true.
[in]	max_invalid_msg	When non-zero, the connection is automatically disconnected when the number of consecutive invalid messages has reached this value.

Member Function Documentation

◆ send() [1/3]

template<ts::ThreadSafety SAFETY>

bool ts::tlv::Connection< SAFETY >::send	(	const Message &	msg,
		Report &	report
	)

Serialize and send a TLV message.

Parameters

[in]	msg	The message to send.
[in,out]	report	Where to report errors.

Returns: True on success, false on error.

◆ send() [2/3]

template<ts::ThreadSafety SAFETY>

bool ts::tlv::Connection< SAFETY >::send	(	const Message &	msg,
		Logger &	logger
	)

Serialize and send a TLV message.

Parameters

[in]	msg	The message to send.
[in,out]	logger	Where to report errors and messages.

Returns: True on success, false on error.

◆ receive() [1/4]

template<ts::ThreadSafety SAFETY>

bool ts::tlv::Connection< SAFETY >::receive	(	MessagePtr &	msg,
		const AbortInterface *	abort,
		Report &	report
	)

Receive a TLV message.

Wait for the message, deserialize it and validate it. Process invalid messages and loop until a valid message is received.

Parameters

[out]	msg	A safe pointer to the received message.
[in]	abort	If non-zero, invoked when I/O is interrupted (in case of user-interrupt, return, otherwise retry).
[in,out]	report	Where to report errors.

Returns: True on success, false on error.

◆ receive() [2/4]

template<ts::ThreadSafety SAFETY>

bool ts::tlv::Connection< SAFETY >::receive	(	MessagePtr &	msg,
		const AbortInterface *	abort,
		Logger &	logger
	)

Receive a TLV message.

Wait for the message, deserialize it and validate it. Process invalid messages and loop until a valid message is received.

Parameters

[out]	msg	A safe pointer to the received message.
[in]	abort	If non-zero, invoked when I/O is interrupted (in case of user-interrupt, return, otherwise retry).
[in,out]	logger	Where to report errors and messages.

Returns: True on success, false on error.

◆ getAutoErrorResponse()

template<ThreadSafety SAFETY>

bool ts::tlv::Connection< SAFETY >::getAutoErrorResponse ( ) const

inline

Get invalid incoming messages processing.

Returns: True if, when an invalid message is received, the corresponding error message is automatically sent back to the sender.

◆ setAutoErrorResponse()

template<ThreadSafety SAFETY>

void ts::tlv::Connection< SAFETY >::setAutoErrorResponse ( bool on )

inline

Set invalid incoming messages processing.

Parameters

[in] on When an invalid message is received, the corresponding error message is automatically sent back to the sender when on is true.

◆ getMaxInvalidMessages()

template<ThreadSafety SAFETY>

size_t ts::tlv::Connection< SAFETY >::getMaxInvalidMessages ( ) const

inline

Get invalid message threshold.

Returns: When non-zero, the connection is automatically disconnected when the number of consecutive invalid messages has reached this value.

◆ setMaxInvalidMessages()

template<ThreadSafety SAFETY>

void ts::tlv::Connection< SAFETY >::setMaxInvalidMessages ( size_t n )

inline

Set invalid message threshold.

Parameters

[in] n When non-zero, the connection is automatically disconnected when the number of consecutive invalid messages has reached this value.

◆ handleConnected()

template<ts::ThreadSafety SAFETY>

void ts::tlv::Connection< SAFETY >::handleConnected ( Report & report )

overrideprotectedvirtual

This virtual method can be overriden by subclasses to be notified of connection.

All subclasses should explicitly invoke their superclass' handlers.

Parameters

[in,out] report Where to report error.

Reimplemented from ts::TCPConnection.

◆ connect()

bool ts::TCPConnection::connect	(	const IPSocketAddress &	addr,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Connect to a remote address and port.

Use this method when acting as TCP client. Do not use on server side: the TCPConnection object is passed to TCPServer::accept() which establishes the connection.

Parameters

[in]	addr	IP address and port of the server to connect.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ isConnected()

bool ts::TCPConnection::isConnected ( ) const

inlineinherited

Check if the socket is connected.

Returns: True if the socket was successfully connected to the peer.

◆ getPeer()

bool ts::TCPConnection::getPeer	(	IPSocketAddress &	addr,
		Report &	report = `(ts::CerrReport::Instance())`
	)		const

inherited

Get the connected remote peer.

Parameters

[out]	addr	IP address and port of the remote socket.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ peerName()

UString ts::TCPConnection::peerName ( ) const

inherited

Get the connected remote peer as a string.

Returns: A string representation of the IP address and port of the remote socket.

◆ closeWriter()

bool ts::TCPConnection::closeWriter ( Report & report = (ts::CerrReport::Instance()) )

inherited

Close the write direction of the connection.

The application shall call this routine after sending the last message but may still want to receive messages, waiting for the peer to voluntary disconnect.

Parameters

[in,out] report Where to report error.

Returns: True on success, false on error.

◆ disconnect()

bool ts::TCPConnection::disconnect ( Report & report = (ts::CerrReport::Instance()) )

inherited

Disconnect from remote partner.

Parameters

[in,out] report Where to report error.

Returns: True on success, false on error.

◆ send() [3/3]

bool ts::TCPConnection::send	(	const void *	data,
		size_t	size,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Send data.

Parameters

[in]	data	Address of the data to send.
[in]	size	Size in bytes of the data to send.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ receive() [3/4]

bool ts::TCPConnection::receive	(	void *	buffer,
		size_t	max_size,
		size_t &	ret_size,
		const AbortInterface *	abort = `nullptr`,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Receive data.

This version of receive() returns when "some" data are received into the user buffer. The actual received data may be shorter than the user buffer size.

The version is typically useful when the application cannot predict how much data will be received and must respond even if the user buffer is not full.

Parameters

[out]	buffer	Address of the buffer for the received data.
[in]	max_size	Size in bytes of the reception buffer.
[out]	ret_size	Size in bytes of the received data. Will never be larger than max_size.
[in]	abort	If non-zero, invoked when I/O is interrupted (in case of user-interrupt, return, otherwise retry).
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ receive() [4/4]

bool ts::TCPConnection::receive	(	void *	buffer,
		size_t	size,
		const AbortInterface *	abort = `nullptr`,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Receive data until buffer is full.

This version of receive() returns only when sufficient data are received to completely fill the user buffer. The size of the actual received data is identical to the user buffer size.

The version is typically useful when the application knows that a certain amount of data is expected and must wait for them.

Parameters

[out]	buffer	Address of the buffer for the received data.
[in]	size	Size in bytes of the buffer.
[in]	abort	If non-zero, invoked when I/O is interrupted (in case of user-interrupt, return, otherwise retry).
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ handleDisconnected()

virtual void ts::TCPConnection::handleDisconnected ( Report & report = (ts::CerrReport::Instance()) )

protectedvirtualinherited

This virtual method can be overriden by subclasses to be notified of disconnection.

All subclasses should explicitly invoke their superclass' handlers.

Parameters

[in,out] report Where to report error.

◆ handleClosed()

virtual void ts::TCPConnection::handleClosed ( Report & report = (ts::CerrReport::Instance()) )

overrideprotectedvirtualinherited

This virtual method can be overriden by subclasses to be notified of close.

All subclasses should explicitly invoke their superclass' handlers.

Parameters

[in,out] report Where to report error.

Reimplemented from ts::TCPSocket.

◆ setTTL()

bool ts::TCPSocket::setTTL	(	int	ttl,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the Time To Live (TTL) option.

Parameters

[in]	ttl	The TTL value, ie. the maximum number of "hops" between routers before an IP packet is dropped.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ setNoLinger()

bool ts::TCPSocket::setNoLinger ( Report & report = (ts::CerrReport::Instance()) )

inherited

Remove the linger time option.

Parameters

[in,out] report Where to report error.

Returns: True on success, false on error.

◆ setLingerTime()

bool ts::TCPSocket::setLingerTime	(	int	seconds,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the linger time option.

Parameters

[in]	seconds	Number of seconds to wait after shuting down the socket.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ setKeepAlive()

bool ts::TCPSocket::setKeepAlive	(	bool	active,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the "keep alive" option.

Parameters

[in]	active	If true, the socket periodically sends "keep alive" packets when the connection is idle.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ setNoDelay()

bool ts::TCPSocket::setNoDelay	(	bool	active,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the "no delay" option.

Parameters

[in]	active	If true, the socket immediately sends outgoing packets. By default, a TCP socket waits a small amount of time after a send() operation to get a chance to group outgoing data from successive send() operations into one single packet.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ bind()

bool ts::TCPSocket::bind	(	const IPSocketAddress &	addr,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Bind to a local address and port.

The IP address part of the socket address must one of:

IPAddress::AnyAddress4. Any local interface may be used to connect to a server (client side) or to receive incoming client connections (server side).
The IP address of an interface of the local system. Outgoing connections (client side) will be only allowed through this interface. Incoming client connections (server side) will be accepted only when they arrive through the selected interface.

The port number part of the socket address must be one of:

IPSocketAddress::AnyPort. The socket is bound to an arbitrary unused local TCP port. This is the usual configuration for a TCP client.
A specific port number. This is the usual configuration for a TCP server. If this TCP port is already bound by another local TCP socket, the bind operation fails, unless the "reuse port" option has already been set.

Parameters

[in]	addr	Local socket address to bind to.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ open()

virtual bool ts::TCPSocket::open	(	IP	gen,
		Report &	report = `(ts::CerrReport::Instance())`
	)

overridevirtualinherited

Open the socket.

Parameters

[in]	gen	IP generation, IPv4 or IPv6. If set to IP::Any, open an IPv6 socket with option IPV6_V6ONLY cleared. As a server, this socket can accept IPv4 and IPv6 connections. If gen is IP::v6, the socket is created with option IPV6_V6ONLY set.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

Implements ts::Socket.

◆ close()

virtual bool ts::TCPSocket::close ( Report & report = (ts::CerrReport::Instance()) )

overridevirtualinherited

Close the socket.

Parameters

[in,out] report Where to report error.

Returns: True on success, false on error.

Reimplemented from ts::Socket.

Reimplemented in ts::TCPServer.

◆ handleOpened()

virtual void ts::TCPSocket::handleOpened ( Report & report )

protectedvirtualinherited

This virtual method can be overriden by subclasses to be notified of open.

All subclasses should explicitly invoke their superclass' handlers.

Parameters

[in,out] report Where to report error.

◆ declareOpened()

virtual void ts::TCPSocket::declareOpened	(	SysSocketType	sock,
		Report &	report
	)

overrideprotectedvirtualinherited

Set an open socket descriptor from a subclass.

This method is used by a server to declare that a client socket has just become opened.

Parameters

[in]	sock	New socket descriptor.
[in,out]	report	Where to report error.

Reimplemented from ts::Socket.

◆ isOpen()

bool ts::Socket::isOpen ( ) const

inlineinherited

Check if socket is open.

Returns: True if socket is open.

◆ generation()

IP ts::Socket::generation ( ) const

inlineinherited

Get the IP generation with which the socket was open.

Returns: IP generation. Return IP::Any if the socket can access IPv4 and IPv6 addresses.

◆ setSendBufferSize()

bool ts::Socket::setSendBufferSize	(	size_t	size,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the send buffer size.

Parameters

[in]	size	Send buffer size in bytes.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ setReceiveBufferSize()

bool ts::Socket::setReceiveBufferSize	(	size_t	size,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the receive buffer size.

Parameters

[in]	size	Receive buffer size in bytes.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ setReceiveTimeout()

bool ts::Socket::setReceiveTimeout	(	cn::milliseconds	timeout,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the receive timeout.

Parameters

[in]	timeout	Receive timeout in milliseconds. If negative, receive timeout is not used.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ reusePort()

bool ts::Socket::reusePort	(	bool	reuse_port,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Set the "reuse port" option.

Parameters

[in]	reuse_port	If true, the socket is allowed to reuse a local UDP port which is already bound.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ getLocalAddress()

bool ts::Socket::getLocalAddress	(	IPSocketAddress &	addr,
		Report &	report = `(ts::CerrReport::Instance())`
	)

inherited

Get local socket address.

Parameters

[out]	addr	Local socket address of the connection.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

◆ getSocket()

SysSocketType ts::Socket::getSocket ( ) const

inlineinherited

Get the underlying socket device handle (use with care).

This method is reserved for low-level operations and should not be used by normal applications.

Returns: The underlying socket system device handle or file descriptor. Return SYS_SOCKET_INVALID if the socket is not open.

◆ createSocket()

bool ts::Socket::createSocket	(	IP	gen,
		int	type,
		int	protocol,
		Report &	report
	)

protectedinherited

Create the socket.

Parameters

[in]	gen	IP generation.
[in]	type	Socket type: SOCK_STREAM, SOCK_DGRAM
[in]	protocol	Socket protocol: IPPROTO_TCP, IPPROTO_UDP
[in,out]	report	Where to report error.

Returns: True on success, false on error.

See also: open(ge, Report&)

◆ convert()

bool ts::Socket::convert	(	IPAddress &	addr,
		Report &	report
	)		const

protectedinherited

Convert an IP address to make it compatible with the socket IP generation.

Parameters

	addr	[in,out] The address to convert.
[in,out]	report	Where to report error.

Returns: True on success, false on error.

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

tstlvConnection.h

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Connection()

Member Function Documentation

◆ send() [1/3]

◆ send() [2/3]

◆ receive() [1/4]

◆ receive() [2/4]

◆ getAutoErrorResponse()

◆ setAutoErrorResponse()

◆ getMaxInvalidMessages()

◆ setMaxInvalidMessages()

◆ handleConnected()

◆ connect()

◆ isConnected()

◆ getPeer()

◆ peerName()

◆ closeWriter()

◆ disconnect()

◆ send() [3/3]

◆ receive() [3/4]

◆ receive() [4/4]

◆ handleDisconnected()

◆ handleClosed()

◆ setTTL()

◆ setNoLinger()

◆ setLingerTime()

◆ setKeepAlive()

◆ setNoDelay()

◆ bind()

◆ open()

◆ close()

◆ handleOpened()

◆ declareOpened()

◆ isOpen()

◆ generation()

◆ setSendBufferSize()

◆ setReceiveBufferSize()

◆ setReceiveTimeout()

◆ reusePort()

◆ getLocalAddress()

◆ getSocket()

◆ createSocket()

◆ convert()