]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/os/seastore/transaction: rename need_wait_rewrite
authorMatan Breizman <mbreizma@redhat.com>
Mon, 30 Mar 2026 14:23:46 +0000 (17:23 +0300)
committerMatan Breizman <mbreizma@redhat.com>
Tue, 21 Apr 2026 07:28:00 +0000 (07:28 +0000)
We will need this gate for other types of txns as well

Signed-off-by: Matan Breizman <mbreizma@redhat.com>
src/crimson/os/seastore/cached_extent.cc
src/crimson/os/seastore/transaction.h
src/crimson/os/seastore/transaction_manager.cc

index cb65589a28e21c6a329dca8068631eeaf249a108..1aae9c43ed4d79d327006d5ddbec87129e880733 100644 (file)
@@ -506,7 +506,7 @@ void ExtentCommitter::block_trans(Transaction &t) {
   for (auto &item : prior.read_transactions) {
     TRACET("blocking trans {} for rewriting {}",
       t, item.t->get_trans_id(), *item.ref);
-    item.t->need_wait_rewrite = true;
+    item.t->need_wait_visibility = true;
   }
 }
 
@@ -516,7 +516,7 @@ void ExtentCommitter::unblock_trans(Transaction &t) {
   for (auto &item : prior.read_transactions) {
     TRACET("unblocking trans {} for rewriting {}",
       t, item.t->get_trans_id(), *item.ref);
-    item.t->need_wait_rewrite = false;
+    item.t->need_wait_visibility = false;
   }
 }
 
index 1b118457cee3ae8ab6b25dbc8b899cd6d10bd8bb..7b0a4433c5130708e7d651acaf16d2e57464b7be 100644 (file)
@@ -572,7 +572,7 @@ public:
     ool_write_stats = {};
     rewrite_stats = {};
     conflicted = false;
-    need_wait_rewrite = false;
+    need_wait_visibility = false;
     assert(backref_entries.empty());
     if (!has_reset) {
       has_reset = true;
@@ -690,7 +690,8 @@ public:
   }
 
   btree_cursor_stats_t cursor_stats;
-  bool need_wait_rewrite = false;
+
+ bool need_wait_visibility = false;
 
 private:
   friend class Cache;
index ddf4051e7fad2e47a580cd859481303a670b169b..de8b62cb3c49ae3b3e9759ebec0ee9aab88b2e4f 100644 (file)
@@ -544,7 +544,7 @@ TransactionManager::do_submit_transaction(
     tref.get_handle().enter(write_pipeline.prepare)
   );
 
-  while (tref.need_wait_rewrite) {
+  while (tref.need_wait_visibility) {
     co_await trans_intr::make_interruptible(seastar::yield());
   }
   if (trim_alloc_to && *trim_alloc_to != JOURNAL_SEQ_NULL) {