Type-safe latest-value writer for the VLink field communication model. 更多...

#include <setter.h>

类 vlink::Setter< ValueT, SecT > 继承关系图:

vlink::Setter< ValueT, SecT > 的协作图:

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

using	SharedPtr = std::shared_ptr< Setter< ValueT, SecT > >
	Owning shared-pointer alias. 更多...

Public 类型继承自 vlink::Node< SetterImpl, 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>>>
	Setter (const ConfT &conf, InitType type=InitType::kWithInit)
	Constructs a setter from a typed transport configuration object. 更多...

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

	~Setter () override
	Destroys the setter and drains in-flight transport callbacks. 更多...

bool	init () override
	Initialises the setter and registers the late-getter `sync()` hook. 更多...

bool	deinit () override
	Deinitialises the setter and releases the underlying transport resources. 更多...

void	set (const ValueT &value)
	Writes a new field value and emits it to every connected `Getter`. 更多...

void	mark_as_publisher ()
	Promotes this setter to behave as a `Publisher` at the transport layer. 更多...

Public 成员函数继承自 vlink::Node< SetterImpl, SecurityType::kWithoutSecurity >
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 `Setter` and wraps it in a `std::unique_ptr`. 更多...

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

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

static constexpr Serializer::Type	kValueType = Serializer::get_type_of<ValueT>()
	Codec resolved from `ValueT`. 更多...

额外继承的成员函数
Protected 成员函数继承自 vlink::Node< SetterImpl, 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< SetterImpl, 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< SetterImpl >	impl_

详细描述

template<typename ValueT, SecurityType SecT = SecurityType::kWithoutSecurity>
class vlink::Setter< ValueT, SecT >

Type-safe latest-value writer for the VLink field communication model.

Inherits the full Node API and adds field-specific operations: cached set(), automatic late-joiner sync via an internally registered sync() callback, and bridging hooks to behave as a plain publisher on transports that do not natively differentiate the two roles.

模板参数

ValueT	C++ value type. Must satisfy `Serializer::is_supported()`.
SecT	Security mode; defaults to `SecurityType::kWithoutSecurity`.

成员类型定义说明

◆ SharedPtr

template<typename ValueT , SecurityType SecT = SecurityType::kWithoutSecurity>

using vlink::Setter< ValueT, SecT >::SharedPtr = std::shared_ptr<Setter<ValueT, SecT> >

Owning shared-pointer alias.

◆ UniquePtr

template<typename ValueT , SecurityType SecT = SecurityType::kWithoutSecurity>

using vlink::Setter< ValueT, SecT >::UniquePtr = std::unique_ptr<Setter<ValueT, SecT> >

Owning unique-pointer alias.

构造及析构函数说明

◆ Setter() [1/2]

template<typename ValueT , SecurityType SecT>

template<typename ConfT , typename >

vlink::Setter< ValueT, SecT >::Setter	(	const ConfT &	conf,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a setter from a typed transport configuration object.

Accepts any Conf-derived configuration. Following init() the setter registers a transport-level sync() callback that re-emits the cached value whenever a late Getter connects.

模板参数

ConfT Concrete configuration type derived from Conf.

参数

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

◆ Setter() [2/2]

template<typename ValueT , SecurityType SecT>

vlink::Setter< ValueT, SecT >::Setter	(	const std::string &	url_str,
		InitType	type = `InitType::kWithInit`
	)

inlineexplicit

Constructs a setter from a URL string.

参数

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

◆ ~Setter()

template<typename ValueT , SecurityType SecT>

vlink::Setter< ValueT, SecT >::~Setter

inlineoverride

Destroys the setter and drains in-flight transport callbacks.

Required so the sync() callback installed by init() cannot fire on the transport thread after this setter's mutex and cached value have already been destroyed. Mirrors the lifecycle contract of Client and Getter.

成员函数说明

◆ create_shared()

template<typename ValueT , SecurityType SecT>

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

inlinestatic

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

参数

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

返回: Owning SharedPtr to the new setter.

◆ create_unique()

template<typename ValueT , SecurityType SecT>

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

inlinestatic

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

参数

url_str	Field URL such as `"shm://vehicle/gear"`.
type	Whether to call `init()` inline; default is `InitType::kWithInit`.

返回: Owning UniquePtr to the new setter.

◆ deinit()

template<typename ValueT , SecurityType SecT>

bool vlink::Setter< ValueT, SecT >::deinit

inlineoverridevirtual

Deinitialises the setter and releases the underlying transport resources.

Delegates to the base Node teardown path. After deinitialisation the setter no longer participates in sync() or writes until init() is called again.

返回: true on first successful deinitialisation; false if not initialised.

重载 vlink::Node< SetterImpl, SecurityType::kWithoutSecurity > .

函数调用图:

◆ init()

template<typename ValueT , SecurityType SecT>

bool vlink::Setter< ValueT, SecT >::init

inlineoverridevirtual

Initialises the setter and registers the late-getter sync() hook.

Calls the base Node initialisation, then installs a transport-level callback that resends the cached value whenever a new Getter joins after this setter has already been written.

返回: true on first successful initialisation; false otherwise.

重载 vlink::Node< SetterImpl, SecurityType::kWithoutSecurity > .

◆ mark_as_publisher()

template<typename ValueT , SecurityType SecT>

void vlink::Setter< ValueT, SecT >::mark_as_publisher

inline

Promotes this setter to behave as a Publisher at the transport layer.

Switches impl_type from kSetter to kPublisher so that event-mode semantics are applied (no latest-value retention). Reinitialises the transport extension if called post-init(). Useful on transports that do not natively distinguish the two roles.

◆ set()

template<typename ValueT , SecurityType SecT>

void vlink::Setter< ValueT, SecT >::set ( const ValueT & value )

inline

Writes a new field value and emits it to every connected Getter.

Caches value under mtx_, then serialises and writes it via the transport. When security is enabled the serialised payload is encrypted before transmission. The cached value is automatically re-emitted when a late Getter joins (see init()).

参数

value New field value to publish.

类成员变量说明

◆ kImplType

template<typename ValueT , SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr ImplType vlink::Setter< ValueT, SecT >::kImplType = kSetter

staticconstexpr

Node role tag (kSetter).

◆ kValueType

template<typename ValueT , SecurityType SecT = SecurityType::kWithoutSecurity>

constexpr Serializer::Type vlink::Setter< ValueT, SecT >::kValueType = Serializer::get_type_of<ValueT>()

staticconstexpr

Codec resolved from ValueT.

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

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

Public 类型

Public 成员函数

静态 Public 成员函数

静态 Public 属性

额外继承的成员函数

详细描述

template<typename ValueT, SecurityType SecT = SecurityType::kWithoutSecurity> class vlink::Setter< ValueT, SecT >

成员类型定义说明

◆ SharedPtr

◆ UniquePtr

构造及析构函数说明

◆ Setter() [1/2]

◆ Setter() [2/2]

◆ ~Setter()

成员函数说明

◆ create_shared()

◆ create_unique()

◆ deinit()

◆ init()

◆ mark_as_publisher()

◆ set()

类成员变量说明

◆ kImplType

◆ kValueType

template<typename ValueT, SecurityType SecT = SecurityType::kWithoutSecurity>
class vlink::Setter< ValueT, SecT >