class AsyncCleaner {
public:
using state_t = BackgroundListener::state_t;
- using base_ertr = crimson::errorator<
- crimson::ct_error::input_output_error>;
virtual void set_background_callback(BackgroundListener *) = 0;
namespace crimson::os::seastore {
-LBACursor::base_iertr::future<> LBACursor::refresh()
+base_iertr::future<> LBACursor::refresh()
{
LOG_PREFIX(LBACursor::refresh);
return with_btree<lba::LBABtree>(
return val->refcount;
}
- using base_ertr = crimson::errorator<
- crimson::ct_error::input_output_error>;
- using base_iertr = trans_iertr<base_ertr>;
base_iertr::future<> refresh();
};
using LBACursorRef = boost::intrusive_ptr<LBACursor>;
* Different writers write extents to different locations.
*/
class ExtentOolWriter {
- using base_ertr = crimson::errorator<
- crimson::ct_error::input_output_error>;
public:
virtual ~ExtentOolWriter() {}
class JournalAllocator {
public:
- using base_ertr = crimson::errorator<
- crimson::ct_error::input_output_error>;
virtual const std::string& get_name() const = 0;
virtual void update_modify_time(record_t& record) = 0;
// OVERFLOW: outstanding_io > io_depth_limit is impossible
};
- using base_ertr = crimson::errorator<
- crimson::ct_error::input_output_error>;
-
public:
RecordSubmitter(std::size_t io_depth,
std::size_t batch_capacity,
direct_cursor->key);
}
-LBAMapping::next_iertr::future<LBAMapping> LBAMapping::next()
+base_iertr::future<LBAMapping> LBAMapping::next()
{
LOG_PREFIX(LBAMapping::next);
auto ctx = get_effective_cursor().ctx;
});
}
-LBAMapping::refresh_iertr::future<LBAMapping> LBAMapping::refresh()
+base_iertr::future<LBAMapping> LBAMapping::refresh()
{
if (is_viewable()) {
- return refresh_iertr::make_ready_future<LBAMapping>(*this);
+ return base_iertr::make_ready_future<LBAMapping>(*this);
}
return seastar::do_with(
direct_cursor,
if (direct_cursor) {
return direct_cursor->refresh();
}
- return refresh_iertr::now();
+ return base_iertr::now();
}).si_then([&indirect_cursor] {
if (indirect_cursor) {
return indirect_cursor->refresh();
}
- return refresh_iertr::now();
+ return base_iertr::now();
}).si_then([&direct_cursor, &indirect_cursor] {
return LBAMapping(direct_cursor, indirect_cursor);
});
LogicalChildNodeRef peek_logical_extent(Transaction &t) const;
- using refresh_iertr = LBACursor::base_iertr;
//TODO: should be changed to return future<> once all calls
// to refresh are through co_await. We return LBAMapping
// for now to avoid mandating the callers to make sure
// the life of the lba mapping survives the refresh.
- refresh_iertr::future<LBAMapping> refresh();
+ base_iertr::future<LBAMapping> refresh();
- using next_iertr = LBACursor::base_iertr;
- next_iertr::future<LBAMapping> next();
+ base_iertr::future<LBAMapping> next();
private:
friend lba::BtreeLBAManager;