diff --git a/compaction/table_state.hh b/compaction/table_state.hh index 2bb07f1089..f6cc174ce8 100644 --- a/compaction/table_state.hh +++ b/compaction/table_state.hh @@ -43,6 +43,7 @@ public: virtual future<> update_compaction_history(utils::UUID compaction_id, sstring ks_name, sstring cf_name, std::chrono::milliseconds ended_at, int64_t bytes_in, int64_t bytes_out) = 0; virtual future<> on_compaction_completion(sstables::compaction_completion_desc desc, sstables::offstrategy offstrategy) = 0; virtual bool is_auto_compaction_disabled_by_user() const noexcept = 0; + virtual const tombstone_gc_state& get_tombstone_gc_state() const noexcept = 0; }; } diff --git a/replica/table.cc b/replica/table.cc index 67f6630fd9..d4c93b17f1 100644 --- a/replica/table.cc +++ b/replica/table.cc @@ -2454,6 +2454,9 @@ public: bool is_auto_compaction_disabled_by_user() const noexcept override { return _t.is_auto_compaction_disabled_by_user(); } + const tombstone_gc_state& get_tombstone_gc_state() const noexcept override { + return _t.get_compaction_manager().get_tombstone_gc_state(); + } }; compaction::table_state& table::as_table_state() const noexcept { diff --git a/test/boost/sstable_compaction_test.cc b/test/boost/sstable_compaction_test.cc index c0ca348659..e1a0450436 100644 --- a/test/boost/sstable_compaction_test.cc +++ b/test/boost/sstable_compaction_test.cc @@ -124,10 +124,12 @@ class table_state_for_test : public table_state { column_family_for_tests& _t; test_env& _env; std::vector _compacted_undeleted; + tombstone_gc_state _tombstone_gc_state; public: explicit table_state_for_test(column_family_for_tests& t, test_env& env) : _t(t) , _env(env) + , _tombstone_gc_state(nullptr) { } const schema_ptr& schema() const noexcept override { @@ -179,6 +181,9 @@ public: bool is_auto_compaction_disabled_by_user() const noexcept override { return false; } + const tombstone_gc_state& get_tombstone_gc_state() const noexcept override { + return _tombstone_gc_state; + } }; static std::unique_ptr make_table_state_for_test(column_family_for_tests& t, test_env& env) {