#include "crimson/os/futurized_store.h"
#include "os/Transaction.h"
+using std::string;
using read_errorator = crimson::os::FuturizedStore::read_errorator;
void OSDMeta::create(ceph::os::Transaction& t)
seastar::future<bufferlist> OSDMeta::load_map(epoch_t e)
{
- return store->read(coll,
- osdmap_oid(e), 0, 0,
- CEPH_OSD_OP_FLAG_FADVISE_WILLNEED).handle_error(
+ return store.read(coll,
+ osdmap_oid(e), 0, 0,
+ CEPH_OSD_OP_FLAG_FADVISE_WILLNEED).handle_error(
read_errorator::all_same_way([e] {
throw std::runtime_error(fmt::format("read gave enoent on {}",
osdmap_oid(e)));
seastar::future<OSDSuperblock> OSDMeta::load_superblock()
{
- return store->read(coll, superblock_oid(), 0, 0).safe_then(
+ return store.read(coll, superblock_oid(), 0, 0).safe_then(
[] (bufferlist&& bl) {
auto p = bl.cbegin();
OSDSuperblock superblock;
std::string,
OSDMeta::ec_profile_t>>
OSDMeta::load_final_pool_info(int64_t pool) {
- return store->read(coll, final_pool_info_oid(pool),
+ return store.read(coll, final_pool_info_oid(pool),
0, 0).safe_then([] (bufferlist&& bl) {
auto p = bl.cbegin();
pg_pool_t pi;