From 21d8f8907f7e64813390d0fbef726a2d4ef45b60 Mon Sep 17 00:00:00 2001 From: Nobuhiro Ban Date: Wed, 26 Feb 2025 18:55:53 +0900 Subject: [PATCH] eliminate session::operationg++, -- --- src/concurrency_control/epoch.cpp | 2 ++ src/concurrency_control/include/session.h | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/src/concurrency_control/epoch.cpp b/src/concurrency_control/epoch.cpp index 18eb9ea5..3b583110 100644 --- a/src/concurrency_control/epoch.cpp +++ b/src/concurrency_control/epoch.cpp @@ -23,6 +23,7 @@ namespace shirakami::epoch { inline void check_epoch_load_and_update_idle_living_tx() { +#if 0 auto ce{epoch::get_global_epoch()}; for (auto&& itr : session_table::get_session_table()) { if (itr.get_operating().load(std::memory_order_acquire) == 0) { @@ -30,6 +31,7 @@ inline void check_epoch_load_and_update_idle_living_tx() { if (itr.get_step_epoch() < ce) { itr.set_step_epoch(ce); } } } +#endif } inline void refresh_short_expose_ongoing_status(const epoch_t ce) { diff --git a/src/concurrency_control/include/session.h b/src/concurrency_control/include/session.h index 76179ca5..1bf5772a 100644 --- a/src/concurrency_control/include/session.h +++ b/src/concurrency_control/include/session.h @@ -410,10 +410,13 @@ class alignas(CACHE_LINE_SIZE) session { void process_before_start_step() { // make sure that step_epoch is set when operating becomes 0 to 1 set_step_epoch(epoch::get_global_epoch()); +#if 0 get_operating()++; +#endif } void process_before_finish_step() { +#if 0 auto expected = get_operating().load(std::memory_order_acquire); for (;;) { if (expected == 0) { @@ -428,6 +431,7 @@ class alignas(CACHE_LINE_SIZE) session { break; } } +#endif } void clear_ltx_storage_read_set() {