From: Alex Ainscow <aainscow@uk.ibm.com>
Date: Thu, 5 Feb 2026 13:47:11 +0000 (+0000)
Subject: osdc: Move SplitOp decision point to later in submit procedure.
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=380e071fdd74a04464d7fe03efa4eb4601f8a47b;p=ceph-ci.git

osdc: Move SplitOp decision point to later in submit procedure.

Previously, split ops was being calculated immediately the op was
submitted.  Here we move the submit down to below the throttling
and timeout code.  This way we throttle/timeout the original op.

Handling the timeout (op_cancel) will be handled in a latter  commit.

Signed-off-by: Alex Ainscow <aainscow@uk.ibm.com>
---

diff --git a/src/osdc/Objecter.cc b/src/osdc/Objecter.cc
index db38fc11df2..918f86b236c 100644
--- a/src/osdc/Objecter.cc
+++ b/src/osdc/Objecter.cc
@@ -2418,11 +2418,7 @@ void Objecter::op_submit(Op *op, ceph_tid_t *ptid, int *ctx_budget)
     ptid = &tid;
   op->trace.event("op submit");
 
-  bool was_split = SplitOp::create(op, *this, rl, ptid, ctx_budget, cct);
-
-  if (!was_split) {
-    _op_submit_with_budget(op, rl, ptid, ctx_budget);
-  }
+  _op_submit_with_budget(op, rl, ptid, ctx_budget);
 }
 
 void Objecter::_op_submit_with_budget(Op *op,
@@ -2456,7 +2452,28 @@ void Objecter::_op_submit_with_budget(Op *op,
 				      op_cancel(tid, -ETIMEDOUT); });
   }
 
-  _op_submit(op, sul, ptid);
+
+  bool was_split = SplitOp::create(op, *this, sul, cct);
+
+  if (was_split) {
+    // All the ops have been sent, but we need to track the op with a tid.
+    if (op->tid == 0) {
+      op->tid = ++last_tid;
+    }
+    *ptid = op->tid;
+    OSDSession *s;
+    int r = _get_session(op->target.osd, &s, sul);
+    // The lock has been held since the last calc_target, so it should not
+    // be possible for a new map to have appeared.
+    ceph_assert(r == 0);
+    unique_lock sl(s->lock);
+    _session_op_assign(s, op);
+    inflight_ops++;
+    sl.unlock();
+    put_session(s);
+  } else {
+    _op_submit(op, sul, ptid);
+  }
 }
 
 void Objecter::_send_op_account(Op *op)