From: Samuel Just <sjust@redhat.com>
Date: Thu, 9 Oct 2025 23:08:59 +0000 (+0000)
Subject: crimson/.../transaction_manager: convert reserve_region to coroutine
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=46e707cdc5bdd076bfb2c0849f12b6c06d71daf0;p=ceph-ci.git

crimson/.../transaction_manager: convert reserve_region to coroutine

Signed-off-by: Samuel Just <sjust@redhat.com>
---

diff --git a/src/crimson/os/seastore/transaction_manager.h b/src/crimson/os/seastore/transaction_manager.h
index 8a9967735ae..24f594e1604 100644
--- a/src/crimson/os/seastore/transaction_manager.h
+++ b/src/crimson/os/seastore/transaction_manager.h
@@ -525,14 +525,13 @@ public:
     extent_len_t len) {
     LOG_PREFIX(TransactionManager::reserve_region);
     SUBDEBUGT(seastore_tm, "hint {}~0x{:x} ...", t, hint, len);
-    return lba_manager->reserve_region(
+    auto pin = co_await lba_manager->reserve_region(
       t,
       hint,
       len
-    ).si_then([FNAME, &t](auto pin) {
-      SUBDEBUGT(seastore_tm, "reserved {}", t, pin);
-      return pin;
-    });
+    );
+    SUBDEBUGT(seastore_tm, "reserved {}", t, pin);
+    co_return pin;
   }
 
   reserve_extent_ret reserve_region(
@@ -542,18 +541,14 @@ public:
     extent_len_t len) {
     LOG_PREFIX(TransactionManager::reserve_region);
     SUBDEBUGT(seastore_tm, "hint {}~0x{:x} ...", t, hint, len);
-    return pos.refresh(
-    ).si_then([FNAME, this, &t, hint, len](auto pos) {
-      return lba_manager->reserve_region(
-	t,
-	std::move(pos),
-	hint,
-	len
-      ).si_then([FNAME, &t](auto pin) {
-	SUBDEBUGT(seastore_tm, "reserved {}", t, pin);
-	return pin;
-      });
-    });
+    pos = co_await pos.refresh();
+    auto pin = co_await lba_manager->reserve_region(
+      t,
+      std::move(pos),
+      hint,
+      len
+    );
+    co_return pin;
   }
 
   /*