osd/PGBackend: remove on_applied() from interface

PrimaryLogPG calls it synchronously, on its own, after
submit_transaction.  That means the backends no longer need to
track it or call back to it.

Signed-off-by: Sage Weil <sage@redhat.com>

diff --git a/src/osd/ECBackend.cc b/src/osd/ECBackend.cc
index 299676ac375a424e56b73dbad4376c0dbc4d0e8e..1b65ac3568ff1fec6900dfc4cb9e180977d0dab4 100644 (file)
--- a/src/osd/ECBackend.cc
+++ b/src/osd/ECBackend.cc
@@ -929,7 +929,6 @@ void ECBackend::handle_sub_write(
   tls.push_back(std::move(op.t));
   tls.push_back(std::move(localt));
   get_parent()->queue_transactions(tls, msg);
-  parent->op_applied(op.at_version);
 }
 
 void ECBackend::handle_sub_read(

diff --git a/src/osd/PrimaryLogPG.cc b/src/osd/PrimaryLogPG.cc
index 09bfafc3fbdc5abf48e3c2baf9eb4da5e464c898..6b62ae3f98478db753bdb9f36efa5d247a61b958 100644 (file)
--- a/src/osd/PrimaryLogPG.cc
+++ b/src/osd/PrimaryLogPG.cc
@@ -10027,6 +10027,7 @@ void PrimaryLogPG::issue_repop(RepGather *repop, OpContext *ctx)
     repop->rep_tid,
     ctx->reqid,
     ctx->op);
+  op_applied(ctx->at_version);
 }
 
 PrimaryLogPG::RepGather *PrimaryLogPG::new_repop(

diff --git a/src/osd/PrimaryLogPG.h b/src/osd/PrimaryLogPG.h
index 52bdfe9a7ec3319b4100585a2610563c5f59abe7..0cdbc3a40a269620d14695e4c0f1a437d39e11e9 100644 (file)
--- a/src/osd/PrimaryLogPG.h
+++ b/src/osd/PrimaryLogPG.h
@@ -414,9 +414,7 @@ public:
     append_log(logv, trim_to, roll_forward_to, t, transaction_applied);
   }
 
-  struct C_OSD_OnApplied;
-  void op_applied(
-    const eversion_t &applied_version) override;
+  void op_applied(const eversion_t &applied_version);  // remove me
 
   bool should_send_op(
     pg_shard_t peer,

diff --git a/src/osd/ReplicatedBackend.cc b/src/osd/ReplicatedBackend.cc
index 2d79b61d1d353f4b52cbfb0bb5b14681e20a5ef0..5138627ffd7070b3f075a4cde91fca17d045c31d 100644 (file)
--- a/src/osd/ReplicatedBackend.cc
+++ b/src/osd/ReplicatedBackend.cc
@@ -518,7 +518,6 @@ void ReplicatedBackend::op_applied(
   }
 
   op->waiting_for_applied.erase(get_parent()->whoami_shard());
-  parent->op_applied(op->v);
 
   if (op->waiting_for_applied.empty()) {
     op->on_applied->complete(0);
@@ -1148,7 +1147,6 @@ void ReplicatedBackend::repop_applied(RepModifyRef rm)
       rm->ackerosd, ack, get_osdmap()->get_epoch());
   }
 
-  parent->op_applied(version);
 }
 
 void ReplicatedBackend::repop_commit(RepModifyRef rm)