cephfs-mirror: record failed FSMirror instances

Signed-off-by: Venky Shankar <vshankar@redhat.com>

diff --git a/src/tools/cephfs_mirror/FSMirror.cc b/src/tools/cephfs_mirror/FSMirror.cc
index a0bae498be12a6382c0212206b5a396a49c7d972..e6563bdd1c47de2b746f1da7ef60ad2c580a643e 100644 (file)
--- a/src/tools/cephfs_mirror/FSMirror.cc
+++ b/src/tools/cephfs_mirror/FSMirror.cc
@@ -268,8 +268,8 @@ void FSMirror::init_instance_watcher(Context *on_finish) {
   dout(20) << dendl;
 
   m_on_init_finish = new LambdaContext([this, on_finish](int r) {
-                                         if (r == 0 ) {
-                                           init_replayers();
+                                         if (r < 0) {
+                                           m_init_failed = true;
                                          }
                                          on_finish->complete(r);
                                          if (m_on_shutdown_finish != nullptr) {
@@ -420,14 +420,18 @@ void FSMirror::remove_peer(const Peer &peer) {
 void FSMirror::mirror_status(Formatter *f) {
   std::scoped_lock locker(m_lock);
   f->open_object_section("status");
-  f->open_object_section("peers");
-  for ([[maybe_unused]] auto &[peer, peer_replayer] : m_peer_replayers) {
-    peer.dump(f);
+  if (m_init_failed) {
+    f->dump_string("state", "failed");
+  } else {
+    f->open_object_section("peers");
+    for ([[maybe_unused]] auto &[peer, peer_replayer] : m_peer_replayers) {
+      peer.dump(f);
+    }
+    f->close_section(); // peers
+    f->open_object_section("snap_dirs");
+    f->dump_int("dir_count", m_directories.size());
+    f->close_section(); // snap_dirs
   }
-  f->close_section(); // peers
-  f->open_object_section("snap_dirs");
-  f->dump_int("dir_count", m_directories.size());
-  f->close_section(); // snap_dirs
   f->close_section(); // status
 }
 

diff --git a/src/tools/cephfs_mirror/FSMirror.h b/src/tools/cephfs_mirror/FSMirror.h
index 575fa9c6cd152fcdb723041a1f92f1195b8c3eac..d5584497a630f63dc6bb45b247862aabb02ee657 100644 (file)
--- a/src/tools/cephfs_mirror/FSMirror.h
+++ b/src/tools/cephfs_mirror/FSMirror.h
@@ -37,6 +37,11 @@ public:
     return m_stopping;
   }
 
+  bool is_failed() {
+    std::scoped_lock locker(m_lock);
+    return m_init_failed;
+  }
+
   // admin socket helpers
   void mirror_status(Formatter *f);