]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
osd/ReplicatedBackend: remove MOSDSubOp cruft from repop_applied
authorJianpeng Ma <jianpeng.ma@intel.com>
Thu, 6 Apr 2017 10:35:52 +0000 (18:35 +0800)
committerJianpeng Ma <jianpeng.ma@intel.com>
Thu, 6 Apr 2017 10:35:52 +0000 (18:35 +0800)
commit:52fbdc5e940d6d6bd forget remove those.

Signed-off-by: Jianpeng Ma <jianpeng.ma@intel.com>
src/osd/ReplicatedBackend.cc

index b897eddf8157ec5e6a5232d183a3da315750ec64..89a2980fcba4d93046b660d7a2a5aa15c0ef99bb 100644 (file)
@@ -1144,24 +1144,12 @@ void ReplicatedBackend::repop_applied(RepModifyRef rm)
   Message *ack = NULL;
   eversion_t version;
 
-  if (m->get_type() == MSG_OSD_SUBOP) {
-    // doesn't have CLIENT SUBOP feature ,use Subop
-    const MOSDSubOp *req = static_cast<const MOSDSubOp*>(m);
-    version = req->version;
-    if (!rm->committed)
-      ack = new MOSDSubOpReply(
-       req, parent->whoami_shard(),
-       0, get_osdmap()->get_epoch(), CEPH_OSD_FLAG_ACK);
-  } else if (m->get_type() == MSG_OSD_REPOP) {
-    const MOSDRepOp *req = static_cast<const MOSDRepOp*>(m);
-    version = req->version;
-    if (!rm->committed)
-      ack = new MOSDRepOpReply(
+  const MOSDRepOp *req = static_cast<const MOSDRepOp*>(m);
+  version = req->version;
+  if (!rm->committed)
+    ack = new MOSDRepOpReply(
        static_cast<const MOSDRepOp*>(m), parent->whoami_shard(),
        0, get_osdmap()->get_epoch(), CEPH_OSD_FLAG_ACK);
-  } else {
-    ceph_abort();
-  }
 
   // send ack to acker only if we haven't sent a commit already
   if (ack) {