mds: handle Journaler::recover errors in PurgeQueue

Signed-off-by: John Spray <john.spray@redhat.com>

diff --git a/src/mds/PurgeQueue.cc b/src/mds/PurgeQueue.cc
index af2ca3a2ad6576b42918203430aa57987c91dd42..f9617b81643b90c530272da506110ca210aedf12 100644 (file)
--- a/src/mds/PurgeQueue.cc
+++ b/src/mds/PurgeQueue.cc
@@ -136,13 +136,16 @@ void PurgeQueue::open(Context *completion)
       dout(1) << "Purge Queue not found, assuming this is an upgrade and "
                  "creating it." << dendl;
       create(completion);
-    } else {
+    } else if (r == 0) {
       Mutex::Locker l(lock);
       dout(4) << "open complete" << dendl;
       if (r == 0) {
         journaler.set_writeable();
       }
       completion->complete(r);
+    } else {
+      derr << "Error " << r << " loading Journaler" << dendl;
+      on_error->complete(0);
     }
   }));
 }