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 private:
  21   ll_read_errorator::future<ceph::bufferlist> _read(const hobject_t& hoid,
  22                                                     uint64_t off,
  23                                                     uint64_t len,
  24                                                     uint32_t flags) override;
  25   seastar::future<crimson::osd::acked_peers_t>
  26   _submit_transaction(std::set<pg_shard_t>&& pg_shards,
  27                       const hobject_t& hoid,
  28                       ceph::os::Transaction&& txn,
  29                       osd_reqid_t req_id,
  30                       epoch_t min_epoch, epoch_t max_epoch,
  31                       eversion_t ver) final;
  32   CollectionRef coll;
  33   crimson::os::FuturizedStore* store;
  34 };