]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
osd/ReplicatedBackend: rename sub_op_modify* do_repop*
authorSage Weil <sage@redhat.com>
Tue, 28 Mar 2017 18:12:26 +0000 (14:12 -0400)
committerSage Weil <sage@redhat.com>
Fri, 31 Mar 2017 18:42:12 +0000 (14:42 -0400)
Signed-off-by: Sage Weil <sage@redhat.com>
src/osd/ReplicatedBackend.cc
src/osd/ReplicatedBackend.h

index a04f140f9f47bf01c99b846a16e722d78e11bc94..46ea89dd334a5a3b4a9e6f1c25bc109709c74cc9 100644 (file)
@@ -66,7 +66,7 @@ struct ReplicatedBackend::C_OSD_RepModifyApply : public Context {
   C_OSD_RepModifyApply(ReplicatedBackend *pg, RepModifyRef r)
     : pg(pg), rm(r) {}
   void finish(int r) override {
-    pg->sub_op_modify_applied(rm);
+    pg->repop_applied(rm);
   }
 };
 
@@ -76,7 +76,7 @@ struct ReplicatedBackend::C_OSD_RepModifyCommit : public Context {
   C_OSD_RepModifyCommit(ReplicatedBackend *pg, RepModifyRef r)
     : pg(pg), rm(r) {}
   void finish(int r) override {
-    pg->sub_op_modify_commit(rm);
+    pg->repop_commit(rm);
   }
 };
 
@@ -215,12 +215,12 @@ bool ReplicatedBackend::handle_message(
   }
 
   case MSG_OSD_REPOP: {
-    sub_op_modify(op);
+    do_repop(op);
     return true;
   }
 
   case MSG_OSD_REPOPREPLY: {
-    sub_op_modify_reply(op);
+    do_repop_reply(op);
     return true;
   }
 
@@ -621,7 +621,7 @@ void ReplicatedBackend::op_commit(
   }
 }
 
-void ReplicatedBackend::sub_op_modify_reply(OpRequestRef op)
+void ReplicatedBackend::do_repop_reply(OpRequestRef op)
 {
   static_cast<MOSDRepOpReply*>(op->get_nonconst_req())->finish_decode();
   const MOSDRepOpReply *r = static_cast<const MOSDRepOpReply *>(op->get_req());
@@ -1045,7 +1045,7 @@ void ReplicatedBackend::issue_op(
 }
 
 // sub op modify
-void ReplicatedBackend::sub_op_modify(OpRequestRef op)
+void ReplicatedBackend::do_repop(OpRequestRef op)
 {
   static_cast<MOSDRepOp*>(op->get_nonconst_req())->finish_decode();
   const MOSDRepOp *m = static_cast<const MOSDRepOp *>(op->get_req());
@@ -1132,7 +1132,7 @@ void ReplicatedBackend::sub_op_modify(OpRequestRef op)
   // op is cleaned up by oncommit/onapply when both are executed
 }
 
-void ReplicatedBackend::sub_op_modify_applied(RepModifyRef rm)
+void ReplicatedBackend::repop_applied(RepModifyRef rm)
 {
   rm->op->mark_event("sub_op_applied");
   rm->applied = true;
@@ -1173,7 +1173,7 @@ void ReplicatedBackend::sub_op_modify_applied(RepModifyRef rm)
   parent->op_applied(version);
 }
 
-void ReplicatedBackend::sub_op_modify_commit(RepModifyRef rm)
+void ReplicatedBackend::repop_commit(RepModifyRef rm)
 {
   rm->op->mark_commit_sent();
   rm->committed = true;
index 2003083e5c540bdb1eead9d4193315f10c26357a..55966325f54c6e0a9a025c1146ca9bee8663feb7 100644 (file)
@@ -405,8 +405,8 @@ private:
     ObjectStore::Transaction &op_t);
   void op_applied(InProgressOp *op);
   void op_commit(InProgressOp *op);
-  void sub_op_modify_reply(OpRequestRef op);
-  void sub_op_modify(OpRequestRef op);
+  void do_repop_reply(OpRequestRef op);
+  void do_repop(OpRequestRef op);
 
   struct RepModify {
     OpRequestRef op;
@@ -425,8 +425,8 @@ private:
   struct C_OSD_RepModifyApply;
   struct C_OSD_RepModifyCommit;
 
-  void sub_op_modify_applied(RepModifyRef rm);
-  void sub_op_modify_commit(RepModifyRef rm);
+  void repop_applied(RepModifyRef rm);
+  void repop_commit(RepModifyRef rm);
   bool scrub_supported() override { return true; }
   bool auto_repair_supported() const override { return false; }