From: Ilya Dryomov <idryomov@gmail.com>
Date: Tue, 28 Mar 2017 09:49:08 +0000 (+0200)
Subject: osdc/Objecter: respect epoch barrier in _op_submit()
X-Git-Tag: v11.2.1~99^2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=5c7a07677aa142fadbab36d0c1b24aea32ce9ad5;p=ceph.git

osdc/Objecter: respect epoch barrier in _op_submit()

Epoch barrier instructs us to avoid sending (i.e. pause) any OSD ops
until we see a barrier epoch.  The only thing epoch_barrier check in
target_should_be_paused() does is keep already paused ops paused.  We
need to actually pause incoming OSD ops in _op_submit().

Fixes: http://tracker.ceph.com/issues/19396
Signed-off-by: Ilya Dryomov <idryomov@gmail.com>
(cherry picked from commit f8e8efc0a53d7bd807cc0c2178aef7c4bed62ab7)
---

diff --git a/src/osdc/Objecter.cc b/src/osdc/Objecter.cc
index 9d16d24c577..a0bc8b9297d 100644
--- a/src/osdc/Objecter.cc
+++ b/src/osdc/Objecter.cc
@@ -2337,8 +2337,13 @@ void Objecter::_op_submit(Op *op, shunique_lock& sul, ceph_tid_t *ptid)
 
   bool need_send = false;
 
-  if ((op->target.flags & CEPH_OSD_FLAG_WRITE) &&
-      osdmap->test_flag(CEPH_OSDMAP_PAUSEWR)) {
+  if (osdmap->get_epoch() < epoch_barrier) {
+    ldout(cct, 10) << " barrier, paused " << op << " tid " << op->tid
+		   << dendl;
+    op->target.paused = true;
+    _maybe_request_map();
+  } else if ((op->target.flags & CEPH_OSD_FLAG_WRITE) &&
+             osdmap->test_flag(CEPH_OSDMAP_PAUSEWR)) {
     ldout(cct, 10) << " paused modify " << op << " tid " << op->tid
 		   << dendl;
     op->target.paused = true;