]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/.../circular_bounded_journal: convert submit_record to coroutine
authorSamuel Just <sjust@redhat.com>
Tue, 26 Aug 2025 20:20:01 +0000 (13:20 -0700)
committerSamuel Just <sjust@redhat.com>
Wed, 17 Sep 2025 16:23:47 +0000 (09:23 -0700)
Signed-off-by: Samuel Just <sjust@redhat.com>
src/crimson/os/seastore/journal/circular_bounded_journal.cc

index 41ff8318aba0bc3bcb3d7e160dc4677cb5487aa3..b30699f95c4b2cc28636fa8f82b39e4f55e2a4a3 100644 (file)
@@ -68,17 +68,14 @@ CircularBoundedJournal::submit_record(
   LOG_PREFIX(CircularBoundedJournal::submit_record);
   DEBUG("H{} {} start ...", (void*)&handle, record);
   assert(write_pipeline);
-  return do_submit_record(
+  co_await do_submit_record(
     std::move(record), handle, std::move(on_submission)
-  ).safe_then([this, t_src] {
-    if (is_trim_transaction(t_src)) {
-      return update_journal_tail(
-       trimmer.get_dirty_tail(),
-       trimmer.get_alloc_tail());
-    } else {
-      return seastar::now();
-    }
-  });
+  );
+  if (is_trim_transaction(t_src)) {
+    co_await update_journal_tail(
+      trimmer.get_dirty_tail(),
+      trimmer.get_alloc_tail());
+  }
 }
 
 CircularBoundedJournal::submit_record_ertr::future<>