]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
PG: call on_flushed on FlushEvt
authorSamuel Just <sam.just@inktank.com>
Sat, 26 Oct 2013 23:46:22 +0000 (16:46 -0700)
committerSamuel Just <sam.just@inktank.com>
Mon, 28 Oct 2013 20:35:10 +0000 (13:35 -0700)
Signed-off-by: Samuel Just <sam.just@inktank.com>
src/osd/PG.cc

index 8ba5b6cc2ff0527cfb5c898a5a95f24cfd889428..e92013abdc73325653141846a6bc9875135100de 100644 (file)
@@ -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 >();
 }