#include <Server.h>

Inheritance diagram for carla::streaming::detail::tcp::Server:

Collaboration diagram for carla::streaming::detail::tcp::Server:

Public Types
using	endpoint = boost::asio::ip::tcp::endpoint

using	protocol_type = endpoint::protocol_type

Public Member Functions
endpoint	GetLocalEndpoint () const

bool	IsSynchronousMode () const

template<typename FunctorT1 , typename FunctorT2 >
void	Listen (FunctorT1 on_session_opened, FunctorT2 on_session_closed)
	Start listening for connections. More...

	Server (boost::asio::io_context &io_context, endpoint ep)

void	SetSynchronousMode (bool is_synchro)

void	SetTimeout (time_duration timeout)
	Set session time-out. More...

Private Member Functions
void	OpenSession (time_duration timeout, ServerSession::callback_function_type on_session_opened, ServerSession::callback_function_type on_session_closed)

Private Member Functions inherited from carla::NonCopyable
	NonCopyable ()=default

	NonCopyable (const NonCopyable &)=delete

	NonCopyable (NonCopyable &&)=delete

NonCopyable &	operator= (const NonCopyable &)=delete

NonCopyable &	operator= (NonCopyable &&)=delete

Private Attributes
boost::asio::ip::tcp::acceptor	_acceptor

boost::asio::io_context &	_io_context

bool	_synchronous

std::atomic< time_duration >	_timeout

Detailed Description

Warning: This server cannot be destructed before its io_context is stopped.

Definition at line 26 of file streaming/detail/tcp/Server.h.

Member Typedef Documentation

◆ endpoint

using carla::streaming::detail::tcp::Server::endpoint = boost::asio::ip::tcp::endpoint

Definition at line 29 of file streaming/detail/tcp/Server.h.

◆ protocol_type

using carla::streaming::detail::tcp::Server::protocol_type = endpoint::protocol_type

Definition at line 30 of file streaming/detail/tcp/Server.h.

Constructor & Destructor Documentation

◆ Server()

carla::streaming::detail::tcp::Server::Server	(	boost::asio::io_context &	io_context,
		endpoint	ep
	)

explicit

Definition at line 20 of file Server.cpp.

Member Function Documentation

◆ GetLocalEndpoint()

endpoint carla::streaming::detail::tcp::Server::GetLocalEndpoint ( ) const

inline

Definition at line 34 of file streaming/detail/tcp/Server.h.

References _acceptor.

Referenced by TEST().

Here is the caller graph for this function:

◆ IsSynchronousMode()

bool carla::streaming::detail::tcp::Server::IsSynchronousMode ( ) const

inline

Definition at line 61 of file streaming/detail/tcp/Server.h.

References _synchronous, and OpenSession().

Referenced by carla::streaming::detail::tcp::ServerSession::Write().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Listen()

template<typename FunctorT1 , typename FunctorT2 >

void carla::streaming::detail::tcp::Server::Listen	(	FunctorT1	on_session_opened,
		FunctorT2	on_session_closed
	)

inline

Start listening for connections.

On each new connection, on_session_opened is called, and on_session_closed when the session is closed.

Definition at line 48 of file streaming/detail/tcp/Server.h.

References _io_context, _timeout, and OpenSession().

Referenced by TEST().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ OpenSession()

void carla::streaming::detail::tcp::Server::OpenSession	(	time_duration	timeout,
		ServerSession::callback_function_type	on_session_opened,
		ServerSession::callback_function_type	on_session_closed
	)