diff --git a/sstables/sstable_directory.cc b/sstables/sstable_directory.cc index 34a2fd493e..8cc58d50e7 100644 --- a/sstables/sstable_directory.cc +++ b/sstables/sstable_directory.cc @@ -429,8 +429,8 @@ sstable_directory::filter_sstables(std::function(sstables::shared_s _unshared_local_sstables = std::move(filtered); } -template -requires std::is_invocable_r_v, Func, typename std::decay_t::value_type&> +template +requires std::is_invocable_r_v, Func, typename std::ranges::range_value_t&> future<> sstable_directory::parallel_for_each_restricted(Container& c, Func&& func) { return do_with(std::move(func), [this, &c] (Func& func) mutable { diff --git a/sstables/sstable_directory.hh b/sstables/sstable_directory.hh index 37eed8e35f..4f8081ab81 100644 --- a/sstables/sstable_directory.hh +++ b/sstables/sstable_directory.hh @@ -159,10 +159,9 @@ private: future load_sstable(sstables::entry_descriptor desc, sstables::sstable_open_config cfg = {}) const; future load_sstable(sstables::entry_descriptor desc, process_flags flags) const; - template - requires std::is_invocable_r_v, Func, typename std::decay_t::value_type&> + template + requires std::is_invocable_r_v, Func, typename std::ranges::range_value_t&> future<> parallel_for_each_restricted(Container& C, Func&& func); - future<> load_foreign_sstables(sstable_entry_descriptor_vector info_vec); // Sort the sstable according to owner