Field-model writer base shared by every transport-specific setter. 更多...

#include <setter_impl.h>

类 vlink::SetterImpl 继承关系图:

vlink::SetterImpl 的协作图:

Public 成员函数
	~SetterImpl () override
	Releases backend resources. 更多...

virtual void	write (const Bytes &msg_data)=0
	Writes a new value to every reachable getter. 更多...

virtual void	sync (SyncCallback &&callback)=0
	Installs the transport-specific late-getter sync callback. 更多...

Public 成员函数继承自 vlink::NodeImpl
virtual void	init ()=0
	Brings the underlying transport channel online. 更多...

virtual void	deinit ()=0
	Tears the underlying transport channel down. 更多...

virtual bool	suspend ()
	Pauses message delivery without releasing the channel. 更多...

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

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

virtual void	interrupt ()
	Marks the node interrupted and wakes blocking operations. 更多...

virtual bool	is_support_loan () const
	Indicates whether zero-copy loaning is available on this backend. 更多...

virtual Bytes	loan (int64_t size)
	Borrows a write buffer of `size` bytes from the transport. 更多...

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

virtual void	set_manual_unloan (bool manual_unloan)
	Toggles automatic versus manual release of received loaned buffers. 更多...

virtual const struct Conf *	get_conf () const
	Returns the associated transport `Conf`, or `nullptr` in the base. 更多...

virtual const AbstractNode *	get_abstract_node () const
	Returns the companion `AbstractNode`, when the impl is split. 更多...

virtual Status::BasePtr	get_status (Status::Type type) const
	Retrieves a transport-specific status object. 更多...

virtual bool	check_version (const Version &version)
	Compares `version` with the runtime VLink library version. 更多...

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

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

class MessageLoop *	get_message_loop () const
	Returns the currently attached `MessageLoop`. 更多...

template<typename T >
const T *	get_target_conf () const
	Convenience downcast wrapper around `get_conf()`. 更多...

void	register_status_handler (StatusCallback &&callback)
	Installs a DDS-family status handler. 更多...

bool	has_register_status () const
	Reports whether a status handler has been registered. 更多...

void	call_status (Status::BasePtr ptr)
	Delivers a status notification to the registered handler. 更多...

void	set_property (const std::string &prop, const std::string &value)
	Sets a named property on this node. 更多...

std::string	get_property (const std::string &prop) const
	Retrieves the value of a named property. 更多...

Conf::PropertiesMap	get_all_properties () const
	Returns a copy of every property currently set on this node. 更多...

void	set_discovery_enabled (bool enable)
	Toggles whether this node is reported to the discovery layer. 更多...

bool	get_discovery_enabled () const
	Returns the current discovery-reporting flag. 更多...

void	set_record_path (const std::string &path)
	Configures per-node message recording. 更多...

bool	enable_security (const Security::Config &cfg)
	Installs application-layer security from a const-reference config. 更多...

bool	enable_security (Security::Config &&cfg)
	Installs application-layer security by consuming `cfg`. 更多...

void	set_ssl_options (const SslOptions &options)
	Merges SSL options into the node property map. 更多...

void	try_record (ActionType action_type, const Bytes &data)
	Records a message to the global and / or per-node bag writers. 更多...

void	reset_interrupted ()
	Clears the interrupted flag set by `interrupt()`. 更多...

bool	is_interrupted () const
	Reports whether `interrupt()` has been called and not yet reset. 更多...

void	init_ext ()
	Registers the node with the runtime-owned discovery reporter. 更多...

void	deinit_ext ()
	Deregisters the node from the runtime-owned discovery reporter. 更多...

Protected 成员函数
	SetterImpl ()
	Stamps the node as `kSetter`. 更多...

Protected 成员函数继承自 vlink::NodeImpl
	NodeImpl (ImplType type)

virtual	~NodeImpl ()

额外继承的成员函数
Public 类型继承自 vlink::NodeImpl
using	ConnectCallback = Function< void(bool)>
	Callback fired when peer presence changes. 更多...

using	StatusCallback = Function< void(const Status::BasePtr &ptr)>
	Callback fired on DDS-family status notifications (e.g. deadline missed). 更多...

using	SyncCallback = Function< void()>
	Callback fired when a `SetterImpl` completes a late-getter sync. 更多...

using	ReqRespCallback = Function< void(uint64_t, const Bytes &, Bytes *)>
	Request / response handler installed by `ServerImpl::listen()`. 更多...

using	MsgCallback = Function< void(const Bytes &)>
	Callback delivering a serialised payload to a subscriber or getter. 更多...

using	IntraMsgCallback = Function< void(const IntraData &)>
	Callback delivering an in-process payload to an intra:// subscriber. 更多...

静态 Public 成员函数继承自 vlink::NodeImpl
static void	global_init ()
	Initialises process-wide VLink singletons. 更多...

Public 属性继承自 vlink::NodeImpl
std::string	url
	Full URL string of the node, e.g. `"dds://my/topic"`. 更多...

std::string	ser_type
	Concrete serialisation type tag (e.g. `"demo.proto.PointCloud"`). 更多...

ImplType	impl_type {kUnknownImplType}
	Role of this implementation node. 更多...

SchemaType	schema_type {SchemaType::kUnknown}
	Coarse schema family reported to discovery and bag / proxy paths. 更多...

TransportType	transport_type {TransportType::kUnknown}
	Transport backend identifier for this node. 更多...

bool	is_cdr_type {false}
	`true` when DDS native CDR serialisation is in use. 更多...

bool	is_security_type {false}
	`true` when an authenticated transport is enabled. 更多...

bool	is_discovery_enabled {true}
	Whether the node is reported to the discovery layer. 更多...

std::atomic_bool	has_suspend {false}
	Atomic suspend flag (currently unused by the default impls). 更多...

std::unique_ptr< CpuProfiler >	profiler
	Optional per-node CPU profiler activated under global profiling. 更多...

std::unique_ptr< Security >	security
	Installed per-node message-security context, or `nullptr`. 更多...

详细描述

Field-model writer base shared by every transport-specific setter.

Backends override write() to dispatch the serialised value onto the transport and sync() to receive the transport-specific late-join notification so the public Setter can resend its cached value.

构造及析构函数说明

◆ ~SetterImpl()

vlink::SetterImpl::~SetterImpl ( )

override

Releases backend resources.

◆ SetterImpl()

vlink::SetterImpl::SetterImpl ( )

protected

Stamps the node as kSetter.

成员函数说明

◆ sync()

virtual void vlink::SetterImpl::sync ( SyncCallback && callback )

pure virtual

Installs the transport-specific late-getter sync callback.

Pure virtual. Backends that detect a freshly attached getter invoke callback so the public Setter can resend the cached latest value; transports without such a signal may simply discard the callback.

参数

callback Callable invoked when a late-getter sync is requested.

◆ write()

virtual void vlink::SetterImpl::write ( const Bytes & msg_data )

pure virtual

Writes a new value to every reachable getter.

Pure virtual. msg_data is produced by Serializer::serialize() in the public layer; the call overwrites any previously stored value on the topic.

参数

msg_data Serialised value bytes.

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

include/vlink/impl/setter_impl.h

Public 成员函数

Protected 成员函数