row_cache: cache_flat_mutation_reader: close underlying readers

Signed-off-by: Benny Halevy <[email protected]>
mixellent · Apr 25, 2021 · 13dfc41 · 13dfc41
1 parent 0a2670c
commit 13dfc41
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cache_flat_mutation_reader.hh b/cache_flat_mutation_reader.hh
@@ -204,6 +204,11 @@ public:
     virtual future<> fast_forward_to(position_range pr, db::timeout_clock::time_point timeout) override {
         return make_exception_future<>(make_backtraced_exception_ptr<std::bad_function_call>());
     }
+    virtual future<> close() noexcept {
+        auto close_read_context = _read_context_holder ?  _read_context_holder->close() : make_ready_future<>();
+        auto close_underlying = _underlying_holder ? _underlying_holder->close() : make_ready_future<>();
+        return when_all_succeed(std::move(close_read_context), std::move(close_underlying)).discard_result();
+    }
 };
 
 inline