From 92d633b8a158c81d3d3adc43325fd37374841aa0 Mon Sep 17 00:00:00 2001 From: "Artem G." Date: Thu, 28 Nov 2024 11:51:22 -0700 Subject: [PATCH] sources are rolled to a newer tasker library (with 'then' instead of 'continue_with') --- frontend/src/frontend_metadata.cpp | 6 +++--- frontend/src/patch_moderator.cpp | 6 +++--- libraries/tasker | 2 +- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/frontend/src/frontend_metadata.cpp b/frontend/src/frontend_metadata.cpp index b4258b09..21113d23 100644 --- a/frontend/src/frontend_metadata.cpp +++ b/frontend/src/frontend_metadata.cpp @@ -77,7 +77,7 @@ namespace micro_profiler auto request_with_caching = task::run([cache, hash] { return cache->load_metadata(hash); }, _worker_queue) - .continue_with([this, module_id, wreq] (const async_result &m) -> task< pair > { + .then([this, module_id, wreq] (const async_result &m) -> task< pair > { auto c = make_shared< task_node< pair > >(); if (*m) @@ -89,12 +89,12 @@ namespace micro_profiler request_ = req; request_with_caching - .continue_with([ready, wreq] (const async_result< pair > &m) { + .then([ready, wreq] (const async_result< pair > &m) { if (!wreq.expired()) ready((*m).first); }, _apartment_queue); request_with_caching - .continue_with([cache] (const async_result< pair > &m) { + .then([cache] (const async_result< pair > &m) { if (!(*m).second) cache->store_metadata(*(*m).first); }, _worker_queue); diff --git a/frontend/src/patch_moderator.cpp b/frontend/src/patch_moderator.cpp index f60d4fa6..59877212 100644 --- a/frontend/src/patch_moderator.cpp +++ b/frontend/src/patch_moderator.cpp @@ -90,10 +90,10 @@ namespace micro_profiler shared_ptr changes, const tables::module_mapping &mapping, profiling_cache_tasks &tasks) { tasks.persisted_module_id(mapping.hash) - .continue_with([cache] (const async_result &cached_module_id) { + .then([cache] (const async_result &cached_module_id) { return cache->load_default_patches(*cached_module_id); }, _worker) - .continue_with([patches, changes, mapping] (const async_result< vector > &loaded) { + .then([patches, changes, mapping] (const async_result< vector > &loaded) { vector rva; auto &changes_symbol_idx = sdb::unique_index(*changes, keyer::symbol_id()); @@ -127,7 +127,7 @@ namespace micro_profiler if (added->empty() && removed->empty()) continue; tasks.persisted_module_id(m->hash) - .continue_with([cache, added, removed] (const async_result &cached_module_id) { + .then([cache, added, removed] (const async_result &cached_module_id) { cache->update_default_patches(*cached_module_id, *added, *removed); }, _worker); } diff --git a/libraries/tasker b/libraries/tasker index 3ba2a52a..f0caa519 160000 --- a/libraries/tasker +++ b/libraries/tasker @@ -1 +1 @@ -Subproject commit 3ba2a52a3fc4a7445f161106863d164fa0d0ffd1 +Subproject commit f0caa5198bca1f92040edafcf5b9813281ff2d55