Type-safe RPC handler for the VLink method communication model. 更多...

#include <server.h>

类 vlink::Server< ReqT, RespT, SecT > 继承关系图:

vlink::Server< ReqT, RespT, SecT > 的协作图:

Public 类型
using	UniquePtr = std::unique_ptr< Server< ReqT, RespT, SecT > >
	Owning unique-pointer alias. 更多...

using	SharedPtr = std::shared_ptr< Server< ReqT, RespT, SecT > >
	Owning shared-pointer alias. 更多...

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

using	ReqRespCallback = Function< void(const ReqT &, RespT &)>
	Synchronous fill-response handler. 更多...

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

Public 类型继承自 vlink::Node< ServerImpl, SecurityType::kWithoutSecurity >
using	StatusCallback = NodeImpl::StatusCallback
	Handler signature for status-change notifications. 更多...

Public 成员函数
template<typename ConfT , typename = std::enable_if_t<std::is_base_of_v<Conf, ConfT>>>
	Server (const ConfT &conf, InitType type=InitType::kWithInit)
	Constructs a server from a typed transport configuration object. 更多...

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

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

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

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

bool	reply (uint64_t req_id, const RespT &resp)
	Emits the asynchronous response for a previously received request. 更多...

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

Public 成员函数继承自 vlink::Node< ServerImpl, SecurityType::kWithoutSecurity >
virtual bool	init ()
	Initialises the node and its transport back-end. 更多...

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

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

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

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

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

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

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

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

bool	suspend ()
	Suspends message delivery on this node. 更多...

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

静态 Public 成员函数
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`. 更多...

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`. 更多...

静态 Public 属性
static constexpr ImplType	kImplType = kServer
	Node role tag (`kServer`). 更多...

static constexpr bool	kHasResp = !std::is_same_v<RespT, Traits::EmptyType>
	`true` when response produced. 更多...

static constexpr Serializer::Type	kReqType = Serializer::get_type_of<ReqT>()
	Codec for the request. 更多...

static constexpr Serializer::Type	kRespType = Serializer::get_type_of<RespT>()
	Codec for the response. 更多...

额外继承的成员函数
Protected 成员函数继承自 vlink::Node< ServerImpl, SecurityType::kWithoutSecurity >
	Node ()

virtual	~Node ()

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

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

void	invoke_callback (const CallbackT &callback, ArgsT &&... args)

TypeT	get_default_value ()

Protected 属性继承自 vlink::Node< ServerImpl, SecurityType::kWithoutSecurity >
void *	proto_arena_

bool	is_support_loan_

bool	is_manual_unloan_

std::atomic_bool	has_inited_

std::optional< std::mutex >	quit_mtx_

std::unique_ptr< ServerImpl >	impl_

详细描述

template<typename ReqT, typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>
class vlink::Server< ReqT, RespT, SecT >

Type-safe RPC handler for the VLink method communication model.

Inherits the full Node API and adds handler-side operations: three listen() variants and the deferred reply() entry point. The transport implementation (ServerImpl) is selected by the URL scheme or by the typed configuration object supplied at construction time.

模板参数

ReqT	Request message type. Must satisfy `Serializer::is_supported()`.
RespT	Response message type. Defaults to `Traits::EmptyType` (no response).
SecT	Security mode; defaults to `SecurityType::kWithoutSecurity`.

成员类型定义说明

◆ ReqAsyncRespCallback

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

using vlink::Server< ReqT, RespT, SecT >::ReqAsyncRespCallback = Function<void(uint64_t, const ReqT&)>

Handler signature for deferred asynchronous replies.

Receives the opaque req_id assigned by the framework alongside the incoming request. The handler must eventually call reply(req_id, resp) from any thread to deliver the response.

◆ ReqCallback

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

using vlink::Server< ReqT, RespT, SecT >::ReqCallback = Function<void(const ReqT&)>

Fire-and-forget handler signature.

◆ ReqRespCallback

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

using vlink::Server< ReqT, RespT, SecT >::ReqRespCallback = Function<void(const ReqT&, RespT&)>

Synchronous fill-response handler.

◆ SharedPtr

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

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

Owning shared-pointer alias.

◆ UniquePtr

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

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

Owning unique-pointer alias.

构造及析构函数说明

◆ Server() [1/2]

template<typename ReqT , typename RespT , SecurityType SecT>

template<typename ConfT , typename >

vlink::Server< ReqT, RespT, SecT >::Server	(	const ConfT &	conf,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a server from a typed transport configuration object.

Accepts any Conf-derived configuration. A compile-time check enforces that the configuration permits the server role.

模板参数

ConfT Concrete configuration type derived from Conf.

参数

conf	Populated configuration aggregate.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

◆ Server() [2/2]

template<typename ReqT , typename RespT , SecurityType SecT>

vlink::Server< ReqT, RespT, SecT >::Server	(	const std::string &	url_str,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a server from a URL string.

参数

url_str	Service URL such as `"someip://30490/0x1/my_method"`.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

成员函数说明

◆ create_shared()

template<typename ReqT , typename RespT , SecurityType SecT>

Server< ReqT, RespT, SecT >::SharedPtr vlink::Server< ReqT, RespT, SecT >::create_shared	(	const std::string &	url_str,
		InitType	type = `InitType::kWithInit`
	)

inlinestatic

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

参数

url_str	Service URL string.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

返回: Owning SharedPtr to the new server.

◆ create_unique()

template<typename ReqT , typename RespT , SecurityType SecT>

Server< ReqT, RespT, SecT >::UniquePtr vlink::Server< ReqT, RespT, SecT >::create_unique	(	const std::string &	url_str,
		InitType	type = `InitType::kWithInit`
	)

inlinestatic

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

参数

url_str	Service URL such as `"dds://my_service"`.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

返回: Owning UniquePtr to the new server.

◆ listen() [1/2]

template<typename ReqT , typename RespT , SecurityType SecT>

bool vlink::Server< ReqT, RespT, SecT >::listen ( ReqCallback && callback )

inline

Installs a fire-and-forget request handler.

Only available when RespT == EmptyType (enforced by static_assert). The handler is invoked for every received request and no response is produced.

参数

callback void(const ReqT&) handler.

返回: true if registration succeeded.

◆ listen() [2/2]

template<typename ReqT , typename RespT , SecurityType SecT>

bool vlink::Server< ReqT, RespT, SecT >::listen ( ReqRespCallback && callback )

inline

Installs a synchronous request/response handler.

Only available when kHasResp is true. The handler must populate resp before returning; the framework serialises resp immediately and emits the reply on the underlying transport.

参数

callback void(const ReqT&, RespT&) handler that fills resp.

返回: true if registration succeeded.

◆ listen_for_reply()

template<typename ReqT , typename RespT , SecurityType SecT>

bool vlink::Server< ReqT, RespT, SecT >::listen_for_reply ( ReqAsyncRespCallback && callback )

inline

Installs a handler that defers the reply via reply().

Only available when kHasResp is true. The handler receives an opaque req_id and the deserialised request. The handler must eventually invoke reply(req_id, resp) – from any thread – to send the response back to the waiting client.

参数

callback void(uint64_t, const ReqT&) handler.

返回: true if registration succeeded.

◆ reply()

template<typename ReqT , typename RespT , SecurityType SecT>

bool vlink::Server< ReqT, RespT, SecT >::reply	(	uint64_t	req_id,
		const RespT &	resp
	)

inline

Emits the asynchronous response for a previously received request.

Must be paired with listen_for_reply(); calling reply() after a synchronous listen() triggers a fatal log. The req_id must match the value passed to the async handler. Unknown IDs may be silently rejected by the active transport.

参数

req_id	Opaque identifier received in the async handler.
resp	Response value to serialise and emit.

返回: true if the transport accepted the response.

◆ reply_bytes()

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

template<bool HasPtrT>

bool vlink::Server< ReqT, RespT, SecT >::reply_bytes	(	uint64_t	req_id,
		const Bytes &	resp_data,
		bool	is_sync,
		[[maybe_unused] ] Bytes *	resp_data_ptr
	)

inline

类成员变量说明

◆ kHasResp

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr bool vlink::Server< ReqT, RespT, SecT >::kHasResp = !std::is_same_v<RespT, Traits::EmptyType>

staticconstexpr

true when response produced.

◆ kImplType

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr ImplType vlink::Server< ReqT, RespT, SecT >::kImplType = kServer

staticconstexpr

Node role tag (kServer).

◆ kReqType

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr Serializer::Type vlink::Server< ReqT, RespT, SecT >::kReqType = Serializer::get_type_of<ReqT>()

staticconstexpr

Codec for the request.

◆ kRespType

template<typename ReqT , typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr Serializer::Type vlink::Server< ReqT, RespT, SecT >::kRespType = Serializer::get_type_of<RespT>()

staticconstexpr

Codec for the response.

该类的文档由以下文件生成:

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

Public 类型

Public 成员函数

静态 Public 成员函数

静态 Public 属性

额外继承的成员函数

详细描述

template<typename ReqT, typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity> class vlink::Server< ReqT, RespT, SecT >

成员类型定义说明

◆ ReqAsyncRespCallback

◆ ReqCallback

◆ ReqRespCallback

◆ SharedPtr

◆ UniquePtr

构造及析构函数说明

◆ Server() [1/2]

◆ Server() [2/2]

成员函数说明

◆ create_shared()

◆ create_unique()

◆ listen() [1/2]

◆ listen() [2/2]

◆ listen_for_reply()

◆ reply()

◆ reply_bytes()

类成员变量说明

◆ kHasResp

◆ kImplType

◆ kReqType

◆ kRespType

template<typename ReqT, typename RespT = Traits::EmptyType, SecurityType SecT = SecurityType::kWithoutSecurity>
class vlink::Server< ReqT, RespT, SecT >