From: Samuel Just <sam.just@inktank.com>
Date: Sat, 26 Oct 2013 23:46:22 +0000 (-0700)
Subject: PG: call on_flushed on FlushEvt
X-Git-Tag: v0.72-rc1~10^2~3
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=ce33892271a3eadbe62f4e8928d61ad2888ab715;p=ceph.git

PG: call on_flushed on FlushEvt

Signed-off-by: Samuel Just <sam.just@inktank.com>
---

diff --git a/src/osd/PG.cc b/src/osd/PG.cc
index 8ba5b6cc2ff05..e92013abdc733 100644
--- a/src/osd/PG.cc
+++ b/src/osd/PG.cc
@@ -5121,6 +5121,7 @@ PG::RecoveryState::Started::react(const FlushedEvt&)
 {
   PG *pg = context< RecoveryMachine >().pg;
   pg->flushed = true;
+  pg->on_flushed();
   pg->requeue_ops(pg->waiting_for_active);
   return discard_event();
 }
@@ -6853,6 +6854,7 @@ PG::RecoveryState::WaitFlushedPeering::react(const FlushedEvt &evt)
   PG *pg = context< RecoveryMachine >().pg;
   pg->flushed = true;
   pg->requeue_ops(pg->waiting_for_active);
+  pg->on_flushed();
   return transit< WaitFlushedPeering >();
 }