mon/Paxos: flush io on reset()

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

diff --git a/src/mon/Paxos.cc b/src/mon/Paxos.cc
index 03058781b6f685161f8f45da657356db2e4c7b03..c85beaabbf41a2fcb90d1a8b9091766b1f4007a3 100644 (file)
--- a/src/mon/Paxos.cc
+++ b/src/mon/Paxos.cc
@@ -1339,6 +1339,13 @@ void Paxos::restart()
   cancel_events();
   new_value.clear();
 
+  if (is_writing()) {
+    dout(10) << __func__ << " flushing" << dendl;
+    mon->lock.Unlock();
+    mon->store->flush();
+    mon->lock.Lock();
+    dout(10) << __func__ << " flushed" << dendl;
+  }
   state = STATE_RECOVERING;
 
   finish_contexts(g_ceph_context, proposals, -EAGAIN);