Remove cluster_client_t::stop()

src/cluster_client.cpp

@@ -96,14 +96,6 @@ cluster_client_t::~cluster_client_t()
     }
 }
 
-void cluster_client_t::stop()
-{
-    while (msgr.clients.size() > 0)
-    {
-        msgr.stop_client(msgr.clients.begin()->first);
-    }
-}
-
 void cluster_client_t::continue_ops(bool up_retry)
 {
     for (auto op_it = cur_ops.begin(); op_it != cur_ops.end(); )
@@ -250,6 +242,11 @@ void cluster_client_t::on_change_osd_state_hook(uint64_t peer_osd)
     }
 }
 
+bool cluster_client_t::is_ready()
+{
+    return pgs_loaded;
+}
+
 void cluster_client_t::on_ready(std::function<void(void)> fn)
 {
     if (pgs_loaded)

src/cluster_client.h

@@ -87,8 +87,8 @@ public:
     cluster_client_t(ring_loop_t *ringloop, timerfd_manager_t *tfd, json11::Json & config);
     ~cluster_client_t();
     void execute(cluster_op_t *op);
+    bool is_ready();
     void on_ready(std::function<void(void)> fn);
-    void stop();
 
 protected:
     void continue_ops(bool up_retry = false);

src/qemu_proxy.cpp

@@ -47,7 +47,6 @@ public:
 
     ~QemuProxy()
     {
-        cli->stop();
         delete cli;
         delete tfd;
     }