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,
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{
cursor,
nonce,
std::numeric_limits<std::size_t>::max(),
- handler).discard_result();
+ handler);
});
}
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{
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();
});
}
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,