]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/os/seastore: remove unused return value of RecordScanner::scan_valid_records
authorZhang Song <zhangsong02@qianxin.com>
Wed, 3 Apr 2024 08:02:22 +0000 (16:02 +0800)
committerMatan Breizman <mbreizma@redhat.com>
Thu, 16 May 2024 11:41:24 +0000 (14:41 +0300)
Signed-off-by: Zhang Song <zhangsong02@qianxin.com>
(cherry picked from commit 1a914f64070299ab5712ce389096052709b72622)

src/crimson/os/seastore/async_cleaner.cc
src/crimson/os/seastore/journal/circular_bounded_journal.cc
src/crimson/os/seastore/journal/segmented_journal.cc
src/crimson/os/seastore/record_scanner.cc
src/crimson/os/seastore/record_scanner.h

index 053649bedd9873cfd99000f8a78e4513741b582e..b895a88879f97c292f998a4483b7e81b59a192d2 100644 (file)
@@ -1412,7 +1412,7 @@ SegmentCleaner::scan_extents_ret SegmentCleaner::scan_no_tail_segment(
       cursor,
       segment_header.segment_nonce,
       segments.get_segment_size(),
-      handler).discard_result();
+      handler);
   }).safe_then([this, segment_id, segment_header] {
     init_mark_segment_closed(
       segment_id,
index a02c745084174e4c1b9ba0f7237c03d616d9fd90..a848811c1f81d5442ec3fb794cb229dd0ae1131a 100644 (file)
@@ -188,7 +188,7 @@ Journal::replay_ret CircularBoundedJournal::replay_segment(
         cursor,
        cjs.get_cbj_header().magic,
         std::numeric_limits<size_t>::max(),
-        dhandler).safe_then([](auto){}
+        dhandler
       ).handle_error(
         replay_ertr::pass_further{},
         crimson::ct_error::assert_all{
index c40295dbacef4b32da4b1a3e01a9b6e039db0d1e..683481f15b4cb1a9ad1b2ec45291a1b36b9e6cc1 100644 (file)
@@ -219,7 +219,7 @@ SegmentedJournal::scan_last_segment(
       cursor,
       nonce,
       std::numeric_limits<std::size_t>::max(),
-      handler).discard_result();
+      handler);
   });
 }
 
@@ -312,7 +312,7 @@ SegmentedJournal::replay_segment(
        cursor,
        header.segment_nonce,
        std::numeric_limits<size_t>::max(),
-       dhandler).safe_then([](auto){}
+       dhandler
       ).handle_error(
        replay_ertr::pass_further{},
        crimson::ct_error::assert_all{
index 9778bbb77d551d1af198a2320d72b3346e66c7d3..77f7cb422acf67b56966e29b7647832703114a4e 100644 (file)
@@ -98,10 +98,8 @@ RecordScanner::scan_valid_records(
          return seastar::stop_iteration::no;
        }
       });
-    }).safe_then([retref=std::move(retref)]() mutable -> scan_valid_records_ret {
-      return scan_valid_records_ret(
-       scan_valid_records_ertr::ready_future_marker{},
-       std::move(*retref));
+    }).safe_then([retref=std::move(retref)] {
+      return scan_valid_records_ertr::make_ready_future();
     });
 }
 
index 2cbc7c56251e109b9f083af4fe3e5ffc96f95801..2cb17af8df9df796049c20d020ba393c3c687a96 100644 (file)
@@ -14,8 +14,7 @@ class RecordScanner {
 public:
   using read_ertr = SegmentManager::read_ertr;
   using scan_valid_records_ertr = read_ertr;
-  using scan_valid_records_ret = scan_valid_records_ertr::future<
-    size_t>;
+  using scan_valid_records_ret = scan_valid_records_ertr::future<>;
   using found_record_handler_t = std::function<
     scan_valid_records_ertr::future<>(
       record_locator_t record_locator,