From 995cbd714b6382cda5ef40715c13402dc571c977 Mon Sep 17 00:00:00 2001 From: Matan Breizman Date: Sun, 21 Sep 2025 16:11:19 +0000 Subject: [PATCH] crimson/os/seastore/epm: open_for_write() into coroutines Signed-off-by: Matan Breizman --- .../os/seastore/extent_placement_manager.cc | 23 +++++++++---------- 1 file changed, 11 insertions(+), 12 deletions(-) diff --git a/src/crimson/os/seastore/extent_placement_manager.cc b/src/crimson/os/seastore/extent_placement_manager.cc index 48562728b2b7c..110ecae411b56 100644 --- a/src/crimson/os/seastore/extent_placement_manager.cc +++ b/src/crimson/os/seastore/extent_placement_manager.cc @@ -448,21 +448,20 @@ ExtentPlacementManager::open_ertr::future<> ExtentPlacementManager::open_for_write() { LOG_PREFIX(ExtentPlacementManager::open_for_write); - INFO("started with {} devices", num_devices); + DEBUG("started with {} devices", num_devices); ceph_assert(primary_device != nullptr); - return crimson::do_for_each(data_writers_by_gen, [](auto &writer) { + DEBUG("opening DATA writers", num_devices); + for (auto& writer : data_writers_by_gen) { if (writer) { - return writer->open(); + co_await writer->open(); } - return open_ertr::now(); - }).safe_then([this] { - return crimson::do_for_each(md_writers_by_gen, [](auto &writer) { - if (writer) { - return writer->open(); - } - return open_ertr::now(); - }); - }); + } + DEBUG("opening METADATA writers", num_devices); + for (auto& writer : md_writers_by_gen) { + if (writer) { + co_await writer->open(); + } + } } ExtentPlacementManager::dispatch_result_t -- 2.39.5