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;
}
}
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;
}
}
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;
}
btree_cursor_stats_t cursor_stats;
- bool need_wait_rewrite = false;
+
+ bool need_wait_visibility = false;
private:
friend class Cache;
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) {