Publish-side base shared by every transport-specific publisher. 更多...

#include <publisher_impl.h>

类 vlink::PublisherImpl 继承关系图:

vlink::PublisherImpl 的协作图:

Public 成员函数
	~PublisherImpl () override
	Releases the helper state. 更多...

void	interrupt () override
	Wakes waiters and forwards the interrupt to `NodeImpl`. 更多...

virtual void	detect_subscribers (ConnectCallback &&callback)
	Registers `callback` to fire when subscriber presence changes. 更多...

virtual bool	wait_for_subscribers (std::chrono::milliseconds timeout)
	Blocks until at least one subscriber is reachable or `timeout` elapses. 更多...

virtual bool	has_subscribers () const =0
	Reports whether at least one subscriber is currently connected. 更多...

virtual bool	write (const Bytes &msg_data)=0
	Publishes a serialised payload to every connected subscriber. 更多...

virtual bool	write (const IntraData &intra_data)
	Publishes an in-process payload without serialisation. 更多...

void	update_subscribers ()
	Notifies the base class that subscriber presence may have changed. 更多...

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 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 成员函数
	PublisherImpl ()
	Stamps the node as `kPublisher` and primes the helper state. 更多...

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

详细描述

Publish-side base shared by every transport-specific publisher.

Owns the helper condition variable and connect-callback storage that back Publisher<T>::wait_for_subscribers() and Publisher<T>::detect_subscribers(). Transports invoke update_subscribers() from their discovery threads whenever the subscriber count flips between zero and non-zero.

构造及析构函数说明

◆ ~PublisherImpl()

vlink::PublisherImpl::~PublisherImpl ( )

override

Releases the helper state.

◆ PublisherImpl()

vlink::PublisherImpl::PublisherImpl ( )

protected

Stamps the node as kPublisher and primes the helper state.

成员函数说明

◆ detect_subscribers()

virtual void vlink::PublisherImpl::detect_subscribers ( ConnectCallback && callback )

virtual

Registers callback to fire when subscriber presence changes.

The callback is invoked with true when the first subscriber appears and with false after the last one drops. When subscribers are already known at registration time the callback is primed with true before this function returns.

参数

callback Callable void(bool) describing the new presence.

◆ has_subscribers()

virtual bool vlink::PublisherImpl::has_subscribers ( ) const

pure virtual

Reports whether at least one subscriber is currently connected.

Pure virtual; subclasses query their discovery handle. Used by both wait_for_subscribers() and update_subscribers() to detect state transitions.

返回: true when a subscriber is reachable.

◆ interrupt()

void vlink::PublisherImpl::interrupt ( )

overridevirtual

Wakes waiters and forwards the interrupt to NodeImpl.

Marks the node interrupted and notifies the helper condition variable so pending wait_for_subscribers() calls return false promptly.

重载 vlink::NodeImpl .

◆ update_subscribers()

void vlink::PublisherImpl::update_subscribers ( )

Notifies the base class that subscriber presence may have changed.

Compares has_subscribers() against the helper cache; on a transition the condition variable is signalled and the stored ConnectCallback is invoked. Intended for use from transport discovery threads.

◆ wait_for_subscribers()

virtual bool vlink::PublisherImpl::wait_for_subscribers ( std::chrono::milliseconds timeout )

virtual

Blocks until at least one subscriber is reachable or timeout elapses.

Returns immediately when has_subscribers() already reports true. Negative timeouts (e.g. Timeout::kInfinite) wait indefinitely.

参数

timeout Wait budget; negative disables the deadline.

返回: true when a subscriber arrived in time; false otherwise.

◆ write() [1/2]

virtual bool vlink::PublisherImpl::write ( const Bytes & msg_data )

pure virtual

Publishes a serialised payload to every connected subscriber.

Pure virtual. msg_data is produced by Serializer::serialize() at the public layer.

参数

msg_data Serialised payload bytes.

返回: true when the frame was successfully delivered or queued.

◆ write() [2/2]

virtual bool vlink::PublisherImpl::write ( const IntraData & intra_data )

virtual

Publishes an in-process payload without serialisation.

Default implementation warns and returns false; only IntraPublisherImpl forwards the shared payload directly to co-located subscribers.

参数

intra_data Shared payload pointer.

返回: true when the message was dispatched; false otherwise.

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

include/vlink/impl/publisher_impl.h

Public 成员函数

Protected 成员函数

额外继承的成员函数

详细描述

构造及析构函数说明

◆ ~PublisherImpl()

◆ PublisherImpl()

成员函数说明

◆ detect_subscribers()

◆ has_subscribers()

◆ interrupt()

◆ update_subscribers()

◆ wait_for_subscribers()

◆ write() [1/2]

◆ write() [2/2]