|
| | VCAPReader (const std::string &path, bool read_only=true, bool try_to_fix=false) |
| | Opens an MCAP file for playback. 更多...
|
| |
| | ~VCAPReader () override |
| | Stops playback and releases the MCAP file handle. 更多...
|
| |
| void | bind_plugin_interface (const std::shared_ptr< BagPluginInterface > &plugin_interface) override |
| | Attaches a BagPluginInterface for custom URL or type rewriting. 更多...
|
| |
| void | register_status_callback (StatusCallback &&status_callback) override |
| | Registers a callback invoked on every playback state transition. 更多...
|
| |
| void | register_ready_callback (ReadyCallback &&ready_callback) override |
| | Registers a callback fired once the file is open, parsed, and ready to play. 更多...
|
| |
| void | register_finish_callback (FinishCallback &&finish_callback) override |
| | Registers a callback fired when playback ends naturally or is interrupted. 更多...
|
| |
| void | register_output_callback (OutputCallback &&output_callback) override |
| | Registers the message-delivery callback consumed during playback. 更多...
|
| |
| void | play (const Config &config) override |
| | Starts playback with the given configuration. 更多...
|
| |
| void | stop () override |
| | Stops playback and rewinds to the recording start. 更多...
|
| |
| void | pause () override |
| | Pauses playback at the current position. 更多...
|
| |
| void | resume () override |
| | Resumes paused playback from the current position. 更多...
|
| |
| void | pause_to_next () override |
| | Emits one more message and then pauses again. 更多...
|
| |
| void | jump (int64_t begin_time, double rate, int times, bool force_to_play=false) override |
| | Seeks to begin_time and resumes playback at the new position. 更多...
|
| |
| std::future< bool > | check () override |
| | Verifies the integrity of the MCAP file asynchronously. 更多...
|
| |
| std::future< bool > | reindex () override |
| | Unsupported MCAP reindex operation. 更多...
|
| |
| std::future< bool > | fix (bool rebuild=false) override |
| | Unsupported MCAP repair operation. 更多...
|
| |
| void | tag (const std::string &tag_name) override |
| | Updates the
|
| |
| int64_t | get_timestamp () const override |
| | Returns the current playback cursor in milliseconds. 更多...
|
| |
| int64_t | get_real_timestamp () const override |
| | Returns the timestamp of the last delivered message. 更多...
|
| |
| Status | get_status () const override |
| | Returns the playback status. 更多...
|
| |
| const Info & | get_info () const override |
| | Returns the bag metadata populated when the file was opened. 更多...
|
| |
| std::vector< SchemaData > | detect_schema () override |
| | Enumerates every schema embedded in the MCAP file. 更多...
|
| |
| bool | is_split_mode () const override |
| | Reports whether the bag is split across multiple
|
| |
| int | get_split_index () const override |
| | Returns the index of the split part currently under playback. 更多...
|
| |
| bool | is_jumping () const override |
| | Reports whether a jump() seek is currently being processed. 更多...
|
| |
| | BagReader (const std::string &path, bool read_only=true, bool try_to_fix=false) |
| | Constructs the base reader and stores construction-time options. 更多...
|
| |
| virtual | ~BagReader () |
| | Stops the loop, closes the file and releases backend resources. 更多...
|
| |
| virtual void | clear_plugin_interface () |
| | Detaches the currently bound plugin, if any. 更多...
|
| |
| bool | open_cursor (const Config &config) |
| | Opens (or rewinds) a synchronous sequential read cursor over the bag. 更多...
|
| |
| bool | open_cursor () |
| | Opens (or rewinds) a full, unfiltered sequential read cursor over the bag. 更多...
|
| |
| bool | read_next (Frame &out) |
| | Reads the next frame in recorded order into out. 更多...
|
| |
| BagReader & | operator>> (Frame &out) |
| | Stream-style alias for read_next(), enabling while (reader >> frame). 更多...
|
| |
| bool | eof () const noexcept |
| | Returns whether the cursor has reached the end of the bag. 更多...
|
| |
| bool | fail () const noexcept |
| | Returns whether the last cursor operation failed (open or backend read error). 更多...
|
| |
| | operator bool () const noexcept |
| | Reports whether the cursor is still in a readable state (not at end, not failed). 更多...
|
| |
| virtual std::string | get_ser_type (const std::string &url) const |
| | Resolves the serialisation type associated with url. 更多...
|
| |
| virtual SchemaType | get_schema_type (const std::string &url) const |
| | Resolves the schema family associated with url. 更多...
|
| |
| | 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 uint32_t | get_max_elapsed_time () const |
| | Returns the maximum allowed task execution time in milliseconds. 更多...
|
| |
| 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. 更多...
|
| |
Concrete MCAP-format BagReader implementation with index-driven seek.
Prefer BagReader::create() for format-agnostic instantiation; instantiate this class directly only when an MCAP-specific feature is required.
Public 成员函数 继承自 vlink::BagReader
1.9.1