net::service::async_udp_service< UDPStreamHandler, Size > Class Template Reference

A ServiceLike Async UDP Service. More...

#include <net/service/async_udp_service.hpp>

Classes
struct	read_context
	A read context. More...

Public Types
template<typename T >
using	socket_address = io::socket::socket_address< T >
	Templated socket address type.
using	async_context = service::async_context
	The async context type.
using	async_scope = async_context::async_scope
	The async scope type.
using	multiplexer_type = async_context::multiplexer_type
	The io multiplexer type.
using	socket_handle = io::socket::socket_handle
	The socket handle type.
using	socket_dialog = io::socket::socket_dialog< multiplexer_type >
	The socket dialog type.
enum	signals
	An enum of all valid async context signals.

Public Member Functions
auto	signal_handler (int signum) noexcept -> void
	handle signals.
auto	start (async_context &ctx) noexcept -> std::error_code
	Start the service on the context.
auto	submit_recv (async_context &ctx, const socket_dialog &socket, std::shared_ptr< read_context > rctx) -> void
	Submits an asynchronous socket recv.

Protected Member Functions
	async_udp_service ()=default
	Default constructor.
template<typename T >
	async_udp_service (socket_address< T > address) noexcept
	Socket address constructor.

Detailed Description

template<typename UDPStreamHandler, std::size_t Size = 64 * 1024UL>
class net::service::async_udp_service< UDPStreamHandler, Size >

A ServiceLike Async UDP Service.

Template Parameters

StreamHandler	The StreamHandler type that derives from async_udp_service.
Size	The socket read buffer size. (Default 64KiB).

Note

The default constructor of async_udp_service is protected so async_udp_service can't be constructed without a stream handler (which would be UB).

async_udp_service is a CRTP base class compliant with the ServiceLike concept. It must be used with an inheriting CRTP specialization that defines what the service should do with bytes it reads off the wire. StreamHandler must define an operator() overload that eventually calls reader to restart the read loop. It also optionally specifies an initialize member that can be used to configure the service socket. See noop_service below for an example of how to specialize async_udp_service.

struct noop_service : public async_udp_service<noop_service>
{
  using Base = async_udp_service<noop_service>;
 
  template <typename T>
  explicit noop_service(socket_address<T> address): Base(address)
  {}
 
  // Optional. initialize() is called by service.start() and is
  // used to set optional socket and file descriptor options before
  // The UDP server starts to read from the socket.
  auto initialize(const socket_handle &socket) -> std::error_code
  {
    return {};
  }
 
  auto operator()(async_context &ctx, const socket_dialog &socket,
                  std::shared_ptr<read_context> rctx,
                  std::span<const std::byte> buf) -> void
  {
    reader(ctx, socket, std::move(rctx));
  }
};

Constructor & Destructor Documentation

async_udp_service()

template<typename UDPStreamHandler , std::size_t Size = 64 * 1024UL>

template<typename T >

net::service::async_udp_service< UDPStreamHandler, Size >::async_udp_service ( socket_address< T >  address )

explicitprotectednoexcept

Socket address constructor.

Template Parameters

T	The socket address type.

Parameters

address

The service address to bind.

Member Function Documentation

signal_handler()

template<typename UDPStreamHandler , std::size_t Size = 64 * 1024UL>

auto net::service::async_udp_service< UDPStreamHandler, Size >::signal_handler ( int  signum ) -> void

noexcept

handle signals.

Parameters

signum

The signal number to handle.

start()

template<typename UDPStreamHandler , std::size_t Size = 64 * 1024UL>

auto net::service::async_udp_service< UDPStreamHandler, Size >::start ( async_context &  ctx ) -> std::error_code

noexcept

Start the service on the context.

Parameters

ctx	The async context to start the service on.

Returns

an error code indicating success.

submit_recv()

template<typename UDPStreamHandler , std::size_t Size = 64 * 1024UL>

auto net::service::async_udp_service< UDPStreamHandler, Size >::submit_recv	(	async_context &	ctx,
		const socket_dialog &	socket,
		std::shared_ptr< read_context >	rctx
	)		-> void

Submits an asynchronous socket recv.

Parameters

ctx	The async context to start the reader on.
socket	the socket to read data from.
rctx	A shared pointer to a mutable read buffer.

---

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

• net/service/async_udp_service.hpp