diff options
Diffstat (limited to 'src/crimson/osd/ec_backend.h')
-rw-r--r-- | src/crimson/osd/ec_backend.h | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/src/crimson/osd/ec_backend.h b/src/crimson/osd/ec_backend.h new file mode 100644 index 000000000..e15b19970 --- /dev/null +++ b/src/crimson/osd/ec_backend.h @@ -0,0 +1,38 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#pragma once + +#include <boost/intrusive_ptr.hpp> +#include <seastar/core/future.hh> +#include "include/buffer_fwd.h" +#include "osd/osd_types.h" +#include "pg_backend.h" + +class ECBackend : public PGBackend +{ +public: + ECBackend(shard_id_t shard, + CollectionRef coll, + crimson::osd::ShardServices& shard_services, + const ec_profile_t& ec_profile, + uint64_t stripe_width); + seastar::future<> stop() final { + return seastar::now(); + } + void on_actingset_changed(peering_info_t pi) final {} +private: + ll_read_errorator::future<ceph::bufferlist> _read(const hobject_t& hoid, + uint64_t off, + uint64_t len, + uint32_t flags) override; + seastar::future<crimson::osd::acked_peers_t> + _submit_transaction(std::set<pg_shard_t>&& pg_shards, + const hobject_t& hoid, + ceph::os::Transaction&& txn, + const osd_op_params_t& req, + epoch_t min_epoch, epoch_t max_epoch, + std::vector<pg_log_entry_t>&& log_entries) final; + CollectionRef coll; + crimson::os::FuturizedStore* store; +}; |