ceph/src/crimson/osd/ec_backend.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #pragma once
   5
   6 #include <boost/intrusive_ptr.hpp>
   7 #include <seastar/core/future.hh>
   8 #include "include/buffer_fwd.h"
   9 #include "osd/osd_types.h"
  10 #include "pg_backend.h"
  11
  12 class ECBackend : public PGBackend
  13 {
  14 public:
  15   ECBackend(shard_id_t shard,
  16             CollectionRef coll,
  17             crimson::osd::ShardServices& shard_services,
  18             const ec_profile_t& ec_profile,
  19             uint64_t stripe_width);
  20   seastar::future<> stop() final {
  21     return seastar::now();
  22   }
  23   void on_actingset_changed(peering_info_t pi) final {}
  24 private:
  25   ll_read_ierrorator::future<ceph::bufferlist>
  26   _read(const hobject_t& hoid, uint64_t off, uint64_t len, uint32_t flags) override;
  27   rep_op_fut_t
  28   _submit_transaction(std::set<pg_shard_t>&& pg_shards,
  29                       const hobject_t& hoid,
  30                       ceph::os::Transaction&& txn,
  31                       osd_op_params_t&& req,
  32                       epoch_t min_epoch, epoch_t max_epoch,
  33                       std::vector<pg_log_entry_t>&& log_entries) final;
  34   CollectionRef coll;
  35   crimson::os::FuturizedStore* store;
  36   seastar::future<> request_committed(const osd_reqid_t& reqid,
  37                                        const eversion_t& version) final {
  38     return seastar::now();
  39   }
  40 };