Convenience alias of Server with per-message encryption enabled. More...

#include <server.h>

Inheritance diagram for vlink::SecurityServer< ReqT, RespT >:

Collaboration diagram for vlink::SecurityServer< ReqT, RespT >:

Public Types
using	UniquePtr = std::unique_ptr< SecurityServer< ReqT, RespT > >
	Owning unique-pointer alias. More...

using	SharedPtr = std::shared_ptr< SecurityServer< ReqT, RespT > >
	Owning shared-pointer alias. More...

Public Types inherited from vlink::Server< ReqT, Traits::EmptyType, SecurityType::kWithSecurity >
using	UniquePtr = std::unique_ptr< Server< ReqT, Traits::EmptyType, SecT > >
	Owning unique-pointer alias. More...

using	SharedPtr = std::shared_ptr< Server< ReqT, Traits::EmptyType, SecT > >
	Owning shared-pointer alias. More...

using	ReqCallback = Function< void(const ReqT &)>
	Fire-and-forget handler signature. More...

using	ReqRespCallback = Function< void(const ReqT &, Traits::EmptyType &)>
	Synchronous fill-response handler. More...

using	ReqAsyncRespCallback = Function< void(uint64_t, const ReqT &)>
	Handler signature for deferred asynchronous replies. More...

Public Types inherited from vlink::Node< ImplT, SecT >
using	StatusCallback = NodeImpl::StatusCallback
	Handler signature for status-change notifications. More...

Public Member Functions
template<typename ConfT , typename SecurityConfigT = Security::Config, typename = std::enable_if_t<std::is_base_of_v<Conf, ConfT>>>
	SecurityServer (const ConfT &conf, SecurityConfigT &&sec_cfg={}, InitType type=InitType::kWithInit)
	Constructs a `SecurityServer` from a typed configuration object. More...

template<typename SecurityConfigT = Security::Config>
	SecurityServer (const std::string &url_str, SecurityConfigT &&sec_cfg={}, InitType type=InitType::kWithInit)
	Constructs a `SecurityServer` from a URL string and installs the security configuration. More...

Public Member Functions inherited from vlink::Server< ReqT, Traits::EmptyType, SecurityType::kWithSecurity >
	Server (const ConfT &conf, InitType type=InitType::kWithInit)
	Constructs a server from a typed transport configuration object. More...

	Server (const std::string &url_str, InitType type=InitType::kWithInit)
	Constructs a server from a URL string. More...

bool	listen (ReqCallback &&callback)
	Installs a fire-and-forget request handler. More...

bool	listen (ReqRespCallback &&callback)
	Installs a synchronous request/response handler. More...

bool	listen_for_reply (ReqAsyncRespCallback &&callback)
	Installs a handler that defers the reply via `reply()`. More...

bool	reply (uint64_t req_id, const Traits::EmptyType &resp)
	Emits the asynchronous response for a previously received request. More...

bool	reply_bytes (uint64_t req_id, const Bytes &resp_data, bool is_sync,[[maybe_unused]] Bytes *resp_data_ptr)

Public Member Functions inherited from vlink::Node< ImplT, SecT >
virtual bool	init ()
	Initialises the node and its transport back-end. More...

virtual bool	deinit ()
	Tears the node down and releases all transport resources. More...

virtual void	interrupt ()
	Aborts any blocking wait on this node. More...

bool	has_inited () const
	Reports whether `init()` has been successfully called. More...

bool	is_support_loan () const
	Reports whether the transport supports zero-copy loaned buffers. More...

Bytes	loan (int64_t size)
	Allocates a loaned buffer from the transport memory pool. More...

bool	return_loan (const Bytes &bytes)
	Returns a previously loaned buffer to the transport pool. More...

virtual void	set_manual_unloan (bool manual_unloan)
	Toggles manual-unloan mode for zero-copy receives. More...

virtual bool	is_manual_unloan () const
	Reports whether manual-unloan mode is currently active. More...

bool	suspend ()
	Suspends message delivery on this node. More...

bool	resume ()
	Resumes message delivery after a prior `suspend()`. More...

bool	is_suspend () const
	Reports whether the node is currently suspended. More...

bool	attach (class MessageLoop *message_loop)
	Attaches the node to a `MessageLoop` for callback dispatch. More...

bool	detach ()
	Detaches the node from its current `MessageLoop`. More...

class MessageLoop *	get_message_loop () const
	Returns the `MessageLoop` this node is currently attached to. More...

const AbstractNode *	get_abstract_node () const
	Returns the abstract-graph handle for runtime topology inspection. More...

Status::BasePtr	get_status (Status::Type type) const
	Retrieves the current status object for the requested category. More...

void	register_status_handler (StatusCallback &&callback)
	Registers a handler invoked whenever the node's status changes. More...

void	set_property (const std::string &prop, const std::string &value)
	Sets a transport-specific string-keyed property. More...

std::string	get_property (const std::string &prop) const
	Retrieves a previously set transport-specific property value. More...

TransportType	get_transport_type () const
	Returns the `TransportType` this node is bound to. More...

const std::string &	get_url () const
	Returns the URL string used to construct this node. More...

void	set_record_path (const std::string &path)
	Enables recording of inbound or outbound messages to a bag file. More...

void	set_ser_type (const std::string &ser_type, SchemaType schema_type=SchemaType::kUnknown)
	Overrides the runtime wire-metadata identifiers for this node. More...

const std::string &	get_ser_type () const
	Returns the current concrete runtime type identifier. More...

SchemaType	get_schema_type () const
	Returns the current coarse schema family. More...

void	set_discovery_enabled (bool enable)
	Toggles peer-discovery on this node. More...

bool	get_discovery_enabled () const
	Reports whether peer-discovery is currently enabled. More...

void	bind_proto_arena (void *proto_arena)
	Binds a Protobuf Arena for arena-allocated message objects. More...

double	get_cpu_usage () const
	Returns the cumulative CPU-usage ratio sampled by the profiler. More...

bool	get_safety_quit () const
	Reports whether safe-quit mode is currently active. More...

void	set_safety_quit (bool safety_quit)
	Enables or disables safe-quit mode. More...

void	set_ssl_options (const SslOptions &options)
	Configures transport-layer SSL/TLS encryption for this node. More...

Static Public Member Functions
template<typename SecurityConfigT = Security::Config>
static UniquePtr	create_unique (const std::string &url_str, SecurityConfigT &&sec_cfg={}, InitType type=InitType::kWithInit)
	Heap-allocates a `SecurityServer` and wraps it in a `std::unique_ptr`. More...

template<typename SecurityConfigT = Security::Config>
static SharedPtr	create_shared (const std::string &url_str, SecurityConfigT &&sec_cfg={}, InitType type=InitType::kWithInit)
	Heap-allocates a `SecurityServer` and wraps it in a `std::shared_ptr`. More...

Static Public Member Functions inherited from vlink::Server< ReqT, Traits::EmptyType, SecurityType::kWithSecurity >
static UniquePtr	create_unique (const std::string &url_str, InitType type=InitType::kWithInit)
	Heap-allocates a `Server` and wraps it in a `std::unique_ptr`. More...

static SharedPtr	create_shared (const std::string &url_str, InitType type=InitType::kWithInit)
	Heap-allocates a `Server` and wraps it in a `std::shared_ptr`. More...

Additional Inherited Members
Static Public Attributes inherited from vlink::Server< ReqT, Traits::EmptyType, SecurityType::kWithSecurity >
static constexpr ImplType	kImplType
	Node role tag (`kServer`). More...

static constexpr bool	kHasResp
	`true` when response produced. More...

static constexpr Serializer::Type	kReqType
	Codec for the request. More...

static constexpr Serializer::Type	kRespType
	Codec for the response. More...

Protected Member Functions inherited from vlink::Node< ImplT, SecT >
	Node ()

virtual	~Node ()

bool	enable_security (const Security::Config &cfg)
	Installs a `Security` configuration before transport initialisation. More...

bool	enable_security (Security::Config &&cfg)
	Move overload for construction-time security installation. More...

template<typename CallbackT , typename... ArgsT>
void	invoke_callback (const CallbackT &callback, ArgsT &&... args)

template<typename TypeT >
TypeT	get_default_value ()

Protected Attributes inherited from vlink::Node< ImplT, SecT >
void *	proto_arena_ {nullptr}

bool	is_support_loan_ {false}

bool	is_manual_unloan_ {false}

std::atomic_bool	has_inited_ {false}

std::optional< std::mutex >	quit_mtx_

std::unique_ptr< ImplT >	impl_

Detailed Description

template<typename ReqT, typename RespT = Traits::EmptyType>
class vlink::SecurityServer< ReqT, RespT >

Convenience alias of Server with per-message encryption enabled.

Equivalent to Server<ReqT, RespT, SecurityType::kWithSecurity>. Each incoming request is decrypted before dispatch to the handler, and each outgoing response is encrypted before transmission.

Template Parameters

ReqT	Request message type.
RespT	Response message type. Defaults to `Traits::EmptyType`.

Member Typedef Documentation

◆ SharedPtr

template<typename ReqT , typename RespT = Traits::EmptyType>

using vlink::SecurityServer< ReqT, RespT >::SharedPtr = std::shared_ptr<SecurityServer<ReqT, RespT> >

Owning shared-pointer alias.

◆ UniquePtr

template<typename ReqT , typename RespT = Traits::EmptyType>

using vlink::SecurityServer< ReqT, RespT >::UniquePtr = std::unique_ptr<SecurityServer<ReqT, RespT> >

Owning unique-pointer alias.

Constructor & Destructor Documentation

◆ SecurityServer() [1/2]

template<typename ReqT , typename RespT >

template<typename ConfT , typename SecurityConfigT , typename >

vlink::SecurityServer< ReqT, RespT >::SecurityServer	(	const ConfT &	conf,
		SecurityConfigT &&	sec_cfg = `{}`,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a SecurityServer from a typed configuration object.

Template Parameters

ConfT	Configuration type derived from `Conf`.
SecurityConfigT	Forwardable `Security::Config` compatible type.

Parameters

conf	Populated configuration aggregate.
sec_cfg	Security configuration; empty uses the default symmetric slot.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

Here is the call graph for this function:

◆ SecurityServer() [2/2]

template<typename ReqT , typename RespT >

template<typename SecurityConfigT >

vlink::SecurityServer< ReqT, RespT >::SecurityServer	(	const std::string &	url_str,
		SecurityConfigT &&	sec_cfg = `{}`,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a SecurityServer from a URL string and installs the security configuration.

Builds the base Server in kWithoutInit mode, installs sec_cfg via enable_security(), then calls init() unless deferred. When enable_security() fails to produce a usable NodeImpl::security the subsequent init() will fail.

Template Parameters

SecurityConfigT Forwardable Security::Config compatible type.

Parameters

url_str	Service URL string.
sec_cfg	Security configuration; empty uses the default symmetric slot.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

Here is the call graph for this function:

Member Function Documentation

◆ create_shared()

template<typename ReqT , typename RespT >

template<typename SecurityConfigT >

SecurityServer< ReqT, RespT >::SharedPtr vlink::SecurityServer< ReqT, RespT >::create_shared	(	const std::string &	url_str,
		SecurityConfigT &&	sec_cfg = `{}`,
		InitType	type = `InitType::kWithInit`
	)

inlinestatic

Heap-allocates a SecurityServer and wraps it in a std::shared_ptr.

Template Parameters

SecurityConfigT Forwardable Security::Config compatible type.

Parameters

url_str	Service URL string.
sec_cfg	Security configuration; empty uses the default symmetric slot.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

Returns: Owning SharedPtr to the new secure server.

◆ create_unique()

template<typename ReqT , typename RespT >

template<typename SecurityConfigT >

SecurityServer< ReqT, RespT >::UniquePtr vlink::SecurityServer< ReqT, RespT >::create_unique	(	const std::string &	url_str,
		SecurityConfigT &&	sec_cfg = `{}`,
		InitType	type = `InitType::kWithInit`
	)

inlinestatic

Heap-allocates a SecurityServer and wraps it in a std::unique_ptr.

Template Parameters

SecurityConfigT Forwardable Security::Config compatible type.

Parameters

url_str	Service URL string.
sec_cfg	Security configuration; empty uses the default symmetric slot.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

Returns: Owning UniquePtr to the new secure server.

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

include/vlink/server.h
include/vlink/internal/server-inl.h

Public Types

Public Member Functions

Static Public Member Functions

Additional Inherited Members

Detailed Description

template<typename ReqT, typename RespT = Traits::EmptyType> class vlink::SecurityServer< ReqT, RespT >

Member Typedef Documentation

◆ SharedPtr

◆ UniquePtr

Constructor & Destructor Documentation

◆ SecurityServer() [1/2]

◆ SecurityServer() [2/2]

Member Function Documentation

◆ create_shared()

◆ create_unique()

template<typename ReqT, typename RespT = Traits::EmptyType>
class vlink::SecurityServer< ReqT, RespT >