MessageLoop-based aggregator of live VLink endpoint announcements. 更多...

#include <discovery_viewer.h>

类 vlink::DiscoveryViewer 继承关系图:

vlink::DiscoveryViewer 的协作图:

类
struct	Info
	One row of the discovery snapshot, describing a URL and its publishers/subscribers. 更多...

struct	Process
	Identity of a process that hosts at least one endpoint for a URL. 更多...

Public 类型
enum	FilterType : uint8_t { kFilterNone = 0 , kFilterAvailable = 1 , kFilterNative = 2 }
	Selects which announcements contribute to the live snapshot. 更多...

using	Callback = Function< void(const std::vector< Info > &info_list)>
	Callback signature delivered whenever the snapshot changes. 更多...

Public 类型继承自 vlink::MessageLoop
enum	Type : uint8_t { kNormalType = 0 , kLockfreeType = 1 , kPriorityType = 2 }
	Internal queue implementation type. 更多...

enum	Strategy : uint8_t { kOptimizationStrategy = 0 , kPopStrategy = 1 , kBlockStrategy = 2 }
	Back-pressure strategy applied when the bounded queue is at capacity. 更多...

enum	Priority : uint16_t { kNoPriority = 0 , kLowestPriority = 1 , kTimerPriority = 50 , kNormalPriority = 100 , kHighestPriority = std::numeric_limits<uint16_t>::max() }
	Built-in priority levels for `kPriorityType` loops; higher values dispatch first. 更多...

using	Callback = MoveFunction< void()>
	Callback type for tasks and event handlers. 更多...

Public 成员函数
	DiscoveryViewer (FilterType type=kFilterNone)
	Builds the viewer with the requested filter mode. 更多...

	~DiscoveryViewer () override
	Stops the viewer loop and releases resources. 更多...

void	register_callback (Callback &&callback)
	Registers the callback notified on every snapshot change. 更多...

std::vector< Info >	get_info_list ()
	Returns a copy of the live snapshot at the moment of the call. 更多...

std::string	get_ser_type (const std::string &url) const
	Resolves the announced serialisation type for `url`. 更多...

SchemaType	get_schema_type (const std::string &url) const
	Resolves the announced coarse schema family for `url`. 更多...

Public 成员函数继承自 vlink::MessageLoop
	MessageLoop ()
	Constructs a loop with the default `kNormalType` queue. 更多...

	MessageLoop (Type type)
	Constructs a loop with the given queue type. 更多...

virtual	~MessageLoop ()
	Destructor; requests quit and joins the dispatcher thread if needed. 更多...

void	set_name (const std::string &name)
	Sets a human-readable name visible to profiling tools. 更多...

const std::string &	get_name () const
	Returns the loop name set via `set_name`. 更多...

Type	get_type () const
	Returns the queue type this loop was constructed with. 更多...

Strategy	get_strategy () const
	Returns the active back-pressure strategy. 更多...

void	set_strategy (Strategy strategy)
	Replaces the back-pressure strategy. 更多...

void	register_begin_handler (Callback &&callback)
	Registers a callback fired once at loop thread startup. 更多...

void	register_end_handler (Callback &&callback)
	Registers a callback fired once when the loop thread exits. 更多...

void	register_idle_handler (Callback &&callback)
	Registers a callback fired every time the queue becomes empty. 更多...

bool	run ()
	Runs the loop on the calling thread until `quit` is requested. 更多...

bool	async_run ()
	Starts the loop on a new background thread. 更多...

bool	spin ()
	Alias of `run` blocking the calling thread. 更多...

bool	spin_once (bool block=true)
	Processes one batch of pending tasks and timers on the calling thread. 更多...

bool	quit (bool force=false)
	Requests the loop to exit. 更多...

bool	wait_for_quit (int ms=Timer::kInfinite, bool check=true)
	Waits until the loop has fully exited. 更多...

bool	post_task (Callback &&callback)
	Posts a task for execution on the loop thread. 更多...

TaskHandle	post_task_handle (Callback &&callback, const PostTaskOptions &options={})
	Tracked variant of `post_task` returning a `TaskHandle`. 更多...

bool	post_task_with_priority (Callback &&callback, uint16_t priority)
	Posts a task with an explicit priority on a `kPriorityType` loop. 更多...

TaskHandle	post_task_with_priority_handle (Callback &&callback, uint16_t priority, const PostTaskOptions &options={})
	Tracked variant of `post_task_with_priority` returning a `TaskHandle`. 更多...

template<typename CallbackT , typename = std::enable_if_t<!std::is_convertible_v<CallbackT, Schedule::RetCallback>>>
Schedule::Status	exec_task (const Schedule::Config &config, CallbackT &&callback)
	Schedules a `void-returning` callable and returns a chainable `Schedule::Status`. 更多...

template<typename CallbackT , typename = std::enable_if_t<std::is_convertible_v<CallbackT, Schedule::RetCallback>>>
Schedule::RetStatus	exec_task (const Schedule::Config &config, CallbackT &&callback)
	Schedules a `bool-returning` callable and returns a chainable `Schedule::RetStatus`. 更多...

bool	wakeup ()
	Wakes the loop thread if it is suspended in its idle wait. 更多...

void	reset_lockfree_capacity ()
	Recreates the lock-free queue, clearing all queued tasks and counters. 更多...

bool	is_running () const
	Reports whether the loop is currently running. 更多...

bool	is_ready_to_quit () const
	Reports whether `quit` has been requested and the loop is winding down. 更多...

bool	is_busy () const
	Reports whether the loop is currently executing a task. 更多...

size_t	get_task_count () const
	Returns the current pending task count. 更多...

virtual bool	wait_for_idle (int ms=Timer::kInfinite, bool check=true)
	Waits until the loop has drained its queue and is not executing a task. 更多...

virtual size_t	get_max_timer_count () const
	Returns the maximum number of timers that can be attached. 更多...

virtual bool	is_in_same_thread () const
	Reports whether the calling thread is owned by this loop. 更多...

std::shared_ptr< AliveState >	get_alive_state () const
	Returns the shared lifetime flag used by cross-thread bridges. 更多...

template<class FunctionT , class... ArgsT, typename ResultT = std::invoke_result_t<FunctionT, ArgsT...>>
std::future< ResultT >	invoke_task (FunctionT &&function, ArgsT &&... args)
	Dispatches a callable to the loop thread and returns a `std::future` for the result. 更多...

template<class FunctionT , class... ArgsT, typename ResultT = std::invoke_result_t<FunctionT, ArgsT...>>
std::future< ResultT >	invoke_task_with_priority (FunctionT &&function, uint16_t priority, ArgsT &&... args)
	Priority variant of `invoke_task`; requires a `kPriorityType` loop. 更多...

静态 Public 成员函数
static ImplType	convert_type (std::string_view str)
	Translates a discovery role token to the corresponding `ImplType` bit. 更多...

static std::string	convert_type_to_view (uint32_t type)
	Formats an `ImplType` bitmask as a human-readable label. 更多...

static std::string	convert_type_to_view (uint32_t type, const std::vector< Process > &process_list)
	Formats an `ImplType` bitmask together with its process list. 更多...

static std::string	get_listen_address ()
	Returns the UDP multicast/broadcast address used by the discovery subsystem. 更多...

Protected 成员函数
size_t	get_max_task_count () const override
	Returns the maximum queue depth. 更多...

uint32_t	get_max_elapsed_time () const override
	Returns the maximum allowed task execution time in milliseconds. 更多...

void	on_begin () override
	Hook invoked once on the loop thread before the first task runs. 更多...

void	on_end () override
	Hook invoked once on the loop thread after the last task runs. 更多...

Protected 成员函数继承自 vlink::MessageLoop
virtual void	on_idle ()
	Hook invoked on the loop thread each time the queue becomes empty. 更多...

virtual void	on_task_changed (Callback &&callback, uint32_t start_time)
	Dispatches a ready task on the loop thread. 更多...

virtual void	on_task_timeout (Callback &&callback, uint32_t elapsed_time)
	Hook invoked when a task exceeds `get_max_elapsed_time()`. 更多...

详细描述

MessageLoop-based aggregator of live VLink endpoint announcements.

Construct with the desired filter and start with async_run(). Each viewer is explicitly owned by the caller; no process-global viewer is exposed. The viewer continuously rebuilds an Info list and notifies the registered callback every time the topology changes.

成员类型定义说明

◆ Callback

using vlink::DiscoveryViewer::Callback = Function<void(const std::vector<Info>& info_list)>

Callback signature delivered whenever the snapshot changes.

Invoked on the viewer's MessageLoop thread with the freshly built list.

成员枚举类型说明

◆ FilterType

enum vlink::DiscoveryViewer::FilterType : uint8_t

Selects which announcements contribute to the live snapshot.

Value	Effect
kFilterNone	All announcements visible
kFilterAvailable	Drop remote announcements for local-only URL schemes
kFilterNative	Keep only announcements from the same host

枚举值
kFilterNone	No filtering applied.
kFilterAvailable	Drop remote announcements for local-only URL schemes.
kFilterNative	Keep only same-host announcements.

构造及析构函数说明

◆ DiscoveryViewer()

vlink::DiscoveryViewer::DiscoveryViewer ( FilterType type = kFilterNone )

explicit

Builds the viewer with the requested filter mode.

参数

type	Filter selecting which announcements survive (default: `kFilterNone`).

◆ ~DiscoveryViewer()

vlink::DiscoveryViewer::~DiscoveryViewer ( )

override

Stops the viewer loop and releases resources.

成员函数说明

◆ convert_type()

static ImplType vlink::DiscoveryViewer::convert_type ( std::string_view str )

static

Translates a discovery role token to the corresponding ImplType bit.

参数

str	Role token: `"Ser"`, `"Cli"`, `"Pub"`, `"Sub"`, `"Set"` or `"Get"`.

返回: Matching ImplType, or 0 when the token is not recognised.

◆ convert_type_to_view() [1/2]

static std::string vlink::DiscoveryViewer::convert_type_to_view ( uint32_t type )

static

Formats an ImplType bitmask as a human-readable label.

参数

type	ImplType bitmask.

返回: Display string suitable for tooling output.

◆ convert_type_to_view() [2/2]

static std::string vlink::DiscoveryViewer::convert_type_to_view	(	uint32_t	type,
		const std::vector< Process > &	process_list
	)

static

Formats an ImplType bitmask together with its process list.

参数

type	ImplType bitmask.
process_list	Processes to include in the display.

返回: Combined display string.

◆ get_info_list()

std::vector<Info> vlink::DiscoveryViewer::get_info_list ( )

Returns a copy of the live snapshot at the moment of the call.

返回: Vector of Info rows.

◆ get_listen_address()

static std::string vlink::DiscoveryViewer::get_listen_address ( )

static

Returns the UDP multicast/broadcast address used by the discovery subsystem.

◆ get_max_elapsed_time()

uint32_t vlink::DiscoveryViewer::get_max_elapsed_time ( ) const

overrideprotectedvirtual

Returns the maximum allowed task execution time in milliseconds.

Tasks exceeding this duration trigger on_task_timeout. Zero disables the check.

返回: Maximum execution time in milliseconds.

重载 vlink::MessageLoop .

◆ get_max_task_count()

size_t vlink::DiscoveryViewer::get_max_task_count ( ) const

overrideprotectedvirtual

Returns the maximum queue depth.

返回: kMaxTaskSize (10000) by default.

重载 vlink::MessageLoop .

◆ get_schema_type()

SchemaType vlink::DiscoveryViewer::get_schema_type ( const std::string & url ) const

Resolves the announced coarse schema family for url.

参数

url	Topic URL.

返回: SchemaType, or SchemaType::kUnknown when unavailable.

◆ get_ser_type()

std::string vlink::DiscoveryViewer::get_ser_type ( const std::string & url ) const

Resolves the announced serialisation type for url.

参数

url	Topic URL.

返回: Announced serialisation type, or an empty string when unknown.

◆ on_begin()

void vlink::DiscoveryViewer::on_begin ( )

overrideprotectedvirtual

Hook invoked once on the loop thread before the first task runs.

Subclasses override to perform per-thread initialisation.

重载 vlink::MessageLoop .

◆ on_end()

void vlink::DiscoveryViewer::on_end ( )

overrideprotectedvirtual

Hook invoked once on the loop thread after the last task runs.

Subclasses override to perform per-thread cleanup.

重载 vlink::MessageLoop .

◆ register_callback()

void vlink::DiscoveryViewer::register_callback ( Callback && callback )

Registers the callback notified on every snapshot change.

Replaces any previously installed callback; only the most recent registration remains effective.

参数

callback Function invoked with the new Info list.

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

include/vlink/extension/discovery_viewer.h

类

Public 类型

Public 成员函数

静态 Public 成员函数

Protected 成员函数

详细描述

成员类型定义说明

◆ Callback

成员枚举类型说明

◆ FilterType

构造及析构函数说明

◆ DiscoveryViewer()

◆ ~DiscoveryViewer()

成员函数说明

◆ convert_type()

◆ convert_type_to_view() [1/2]

◆ convert_type_to_view() [2/2]

◆ get_info_list()

◆ get_listen_address()

◆ get_max_elapsed_time()

◆ get_max_task_count()

◆ get_schema_type()

◆ get_ser_type()

◆ on_begin()

◆ on_end()

◆ register_callback()