vlink::ProxyServer类 参考

VLink proxy server daemon backed by a MessageLoop. 更多...

#include <proxy_server.h>

类 vlink::ProxyServer 继承关系图:

vlink::ProxyServer 的协作图:

类
struct	Config
	Construction-time configuration for ProxyServer. 更多...

Public 成员函数
	ProxyServer (const Config &config)
	Constructs a ProxyServer and initialises all subsystems.
	~ProxyServer () override
	Destructor.
Public 成员函数 继承自 vlink::MessageLoop
	MessageLoop ()
	Constructs a MessageLoop with kNormalType queue.
	MessageLoop (Type type)
	Constructs a MessageLoop with the specified queue type.
virtual	~MessageLoop ()
	Destructor. Calls quit(true) and waits for the background thread (if any).
void	set_name (const std::string &name)
	Sets a human-readable name for this loop (visible in profiling tools).
const std::string &	get_name () const
	Returns the name set via set_name().
Type	get_type () const
	Returns the queue type this loop was constructed with.
Strategy	get_strategy () const
	Returns the current idle dispatch strategy.
void	set_strategy (Strategy strategy)
	Changes the idle dispatch strategy.
void	register_begin_handler (Callback &&callback)
	Registers a callback invoked once when the loop thread starts.
void	register_end_handler (Callback &&callback)
	Registers a callback invoked once when the loop thread exits.
void	register_idle_handler (Callback &&callback)
	Registers a callback invoked each time the task queue becomes empty.
bool	run ()
	Runs the message loop on the calling thread (blocking).
bool	async_run ()
	Starts the message loop on a new background thread (non-blocking).
bool	spin ()
	Runs the loop continuously in a spin mode (blocking; no background thread).
bool	spin_once (bool block=true)
	Processes one batch of pending tasks and timers.
bool	quit (bool force=false)
	Requests the loop to exit cleanly.
bool	wait_for_idle (int ms=Timer::kInfinite, bool check=true)
	Waits until the task queue is drained.
bool	wait_for_quit (int ms=Timer::kInfinite, bool check=true)
	Waits until the loop has fully exited (after quit() was called).
bool	post_task (Callback &&callback)
	Posts a task to the queue for execution on the loop thread.
bool	post_task_with_priority (Callback &&callback, uint16_t priority)
	Posts a task with an explicit priority (requires kPriorityType loop).
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)
	Posts a scheduled task and returns a Schedule::Status for chaining callbacks.
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)
	Posts a scheduled task and returns a Schedule::RetStatus for chaining callbacks.
bool	wakeup ()
	Wakes the loop thread if it is sleeping (e.g., in kBlockStrategy).
void	reset_lockfree_capacity ()
	Resets the lock-free queue to its initial capacity.
bool	is_running () const
	Returns true if the loop is currently running (started and not quit).
bool	is_ready_to_quit () const
	Returns true if quit() has been called and the loop is winding down.
bool	is_busy () const
	Returns true if the loop is currently executing a task.
size_t	get_task_count () const
	Returns the number of tasks currently in the queue.
virtual size_t	get_max_timer_count () const
	Returns the maximum number of timers that can be attached to this loop.
virtual bool	is_in_same_thread () const
	Returns true if the calling thread is the same as the loop thread.
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)
	Dispatches a callable with an explicit priority and returns a std::future.

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
	Called from the loop thread just before the first task is processed.
void	on_end () override
	Called from the loop thread just after the last task has been processed.
Protected 成员函数 继承自 vlink::MessageLoop
virtual void	on_idle ()
	Called from the loop thread each time the queue becomes empty.
virtual void	on_task_changed (Callback &&callback, uint32_t start_time)
	Called before each task is executed.
virtual void	on_task_timeout (Callback &&callback, uint32_t elapsed_time)
	Called when a task's execution time exceeds get_max_elapsed_time().

额外继承的成员函数
Public 类型 继承自 vlink::MessageLoop
enum	Type : uint8_t { kNormalType = 0 , kLockfreeType = 1 , kPriorityType = 2 }
	Queue implementation type. 更多...
enum	Strategy : uint8_t { kOptimizationStrategy = 0 , kPopStrategy = 1 , kBlockStrategy = 2 }
	Idle strategy controlling CPU and latency trade-offs. 更多...
enum	Priority : uint16_t {   kNoPriority = 0 , kLowestPriority = 1 , kTimerPriority = 50 , kNormalPriority = 100 ,   kHighestPriority = std::numeric_limits<uint16_t>::max() }
	Pre-defined task priority levels for kPriorityType loops. 更多...
using	Callback = std::function<void()>
	Callback type for tasks and event handlers.

详细描述

VLink proxy server daemon backed by a MessageLoop.

Manages all DDS/SHM channels, a DiscoveryViewer, heartbeat timers, and optional runnable plugins. Only one instance may exist per process. Use async_run() (inherited from MessageLoop) to start the event loop.

构造及析构函数说明

ProxyServer()

vlink::ProxyServer::ProxyServer ( const Config & config )

explicit

Constructs a ProxyServer and initialises all subsystems.

Performs the following steps in order:

1. Checks the process-global singleton guard; logs a fatal message and returns early if another instance already exists.
2. Reads the VLINK_INTRA_BIND environment variable.
3. If config.use_iox is true, calls init_shm_roudi() to start an embedded Iceoryx RouDi process.
4. Calls init_server() to create all DDS/SHM channels, subscribe to Control messages, and start the 1-second time_timer and info_timer on the DiscoveryViewer's loop.
5. Calls init_runnable() to load all plugins listed in config.runnable_list.

参数

config

Server configuration. See Config for field details.

注解

The constructor does not start the MessageLoop; call async_run() (or run()) separately.

这是这个函数的调用关系图:

~ProxyServer()

vlink::ProxyServer::~ProxyServer ( )

override

Destructor.

Stops and waits for the MessageLoop, all runnable plugins, the DiscoveryViewer, and all DDS handles in a deterministic teardown sequence. Also marks the singleton guard so future constructions in the same process behave correctly.

成员函数说明

get_max_elapsed_time()

uint32_t vlink::ProxyServer::get_max_elapsed_time ( ) const

overrideprotectedvirtual

Returns the maximum allowed task execution time in milliseconds.

When a task exceeds this duration, on_task_timeout() is called. Returns 0 to disable timeout checking.

返回

Maximum execution time in ms.

重载 vlink::MessageLoop .

get_max_task_count()

size_t vlink::ProxyServer::get_max_task_count ( ) const

overrideprotectedvirtual

Returns the maximum queue depth.

返回

kMaxTaskSize (10000) by default.

重载 vlink::MessageLoop .

on_begin()

void vlink::ProxyServer::on_begin ( )

overrideprotectedvirtual

Called from the loop thread just before the first task is processed.

Override in subclasses to perform per-thread initialisation.

重载 vlink::MessageLoop .

on_end()

void vlink::ProxyServer::on_end ( )

overrideprotectedvirtual

Called from the loop thread just after the last task has been processed.

Override in subclasses to perform per-thread cleanup.

重载 vlink::MessageLoop .

函数调用图:

---

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

• include/vlink/external/proxy_server.h