]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
crimson/osd: settle RMWPipeline and RMWPipeline within ECBackend
authorRadoslaw Zarzynski <rzarzyns@redhat.com>
Mon, 19 May 2025 17:43:02 +0000 (17:43 +0000)
committerRadoslaw Zarzynski <rzarzyns@redhat.com>
Tue, 27 Jan 2026 19:42:59 +0000 (19:42 +0000)
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
src/crimson/osd/ec_backend.cc
src/crimson/osd/ec_backend.h

index 414ab6c8f396160576d2444faf538d3e3dbad107..72c96e8419a05088d0167ef7c57f0faa9f868546 100644 (file)
@@ -530,12 +530,20 @@ ECBackend::maybe_chunked_read(
 void ECBackend::objects_read_and_reconstruct(
   const std::map<hobject_t, std::list<ec_align_t>> &reads,
   bool fast_read,
+  uint64_t object_size,
   GenContextURef<ec_extents_t &&> &&func)
 {
   return read_pipeline.objects_read_and_reconstruct(
     reads, fast_read, std::move(func));
 }
 
+void ECBackend::objects_read_and_reconstruct_for_rmw(
+  std::map<hobject_t, ECCommon::read_request_t> &&to_read,
+  GenContextURef<ECCommon::ec_extents_t&&> &&func)
+{
+  // TODO XXX FIXME
+}
+
 ECBackend::ll_read_ierrorator::future<ECSubReadReply>
 ECBackend::handle_rep_read_op(Ref<MOSDECSubOpRead> m)
 {
index bbf2fff70c0102e5b01b749e4e66db40812762a2..7a60e276400aebff36226cbc28a76199216f06a0 100644 (file)
@@ -102,8 +102,13 @@ private:
   void objects_read_and_reconstruct(
     const std::map<hobject_t, std::list<ec_align_t>> &reads,
     bool fast_read,
+    uint64_t object_size,
     GenContextURef<ec_extents_t &&> &&func) override;
 
+  void objects_read_and_reconstruct_for_rmw(
+    std::map<hobject_t, read_request_t> &&to_read,
+    GenContextURef<ec_extents_t&&> &&func) override;
+
   ceph::ErasureCodeInterfaceRef ec_impl;
   const ECUtil::stripe_info_t sinfo;