66 try {
67 std::rethrow_exception(std::move(ep));
68 } catch (...) {
69 try {
71 std::source_location::current(), "save task failed");
72 }
73
74 catch (...) {
75 }
76 }
77 })
78{
79 m_io_service = std::make_shared<Registry::Service::IOService>();
80
81 m_io_service->request_decode = [
this](uint64_t reader_id) {
83 };
84
88
89 m_io_service->request_frame = [
this](uint64_t reader_id) {
91 };
92
97
99}
#define MF_INFO(comp, ctx,...)
static void register_with_registry()
Register this writer with the ModelWriterRegistry.
static void register_with_registry()
Register this writer with the ImageWriterRegistry.
Core::GlobalStreamInfo & m_stream_info
void dispatch_frame_request(uint64_t reader_id)
IOService::request_frame target — shared-lock lookup + pull_frame_all().
void dispatch_decode_request(uint64_t reader_id)
IOService::request_decode target — shared-lock lookup + signal_decode().
std::shared_ptr< Buffers::BufferManager > m_buffer_manager
std::shared_ptr< Registry::Service::IOService > m_io_service
std::shared_ptr< Vruta::TaskScheduler > m_scheduler
Parallel::AsyncGroup< bool > m_save_tasks
static void register_with_registry()
Register this writer with the ImageWriterRegistry.
static void register_with_registry()
Register this writer with the VolumeWriterRegistry.
void register_service(ServiceFactory factory)
Register a backend service capability.
static BackendRegistry & instance()
Get the global registry instance.
@ FileIO
Filesystem I/O operations.
@ Init
Engine/subsystem initialization.
void error_rethrow(Component component, Context context, std::source_location location=std::source_location::current(), std::string_view additional_context="")
Catch and log an exception, then rethrow it.
@ Core
Core engine, backend, subsystems.
@ IO
Networking, file handling, streaming.