From: Radosław Zarzyński <rzarzyns@redhat.com>
Date: Tue, 24 Oct 2023 10:51:24 +0000 (+0200)
Subject: crimson/osd: ECBackend::handle_sub_write() handles the end of local write
X-Git-Tag: v21.0.0~3^2~69
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=2e97cec6706e8ab023f27084c66d74c140ef8e82;p=ceph.git

crimson/osd: ECBackend::handle_sub_write() handles the end of local write

Signed-off-by: Radosław Zarzyński <rzarzyns@redhat.com>
---

diff --git a/src/crimson/osd/ec_backend.cc b/src/crimson/osd/ec_backend.cc
index ddc4891ba2bc..619c5fabbe56 100644
--- a/src/crimson/osd/ec_backend.cc
+++ b/src/crimson/osd/ec_backend.cc
@@ -380,7 +380,23 @@ void ECBackend::handle_sub_write(
   const ZTracer::Trace &trace,
   ECListener& eclistener)
 {
-  std::ignore = handle_sub_write(from, std::move(op), eclistener);
+  LOG_PREFIX(ECBackend::handle_sub_write);
+  const auto tid = op.tid;
+  DEBUG("tid {}", tid);
+  std::ignore = handle_sub_write(
+    from, std::move(op), eclistener
+  ).si_then([tid, &eclistener, this] {
+    assert(eclistener.pgb_is_primary());
+    ECSubWriteReply reply;
+    reply.tid = tid;
+    //reply.last_complete = last_complete;
+    reply.committed = true;
+    reply.applied = true;
+    reply.from = eclistener.whoami_shard();
+    logger().debug("ECBackend::{} from {}",
+		    "handle_sub_write::reply", reply.from);
+    return handle_rep_write_reply(std::move(reply));
+  }, crimson::ct_error::assert_all{});
 }
 
 ECBackend::write_iertr::future<>