crimson/mgr: use periodical timer for report

* always rearm the timer when handling MMgrConfigure
* remove `mgr::Client::tick_period`

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/crimson/mgr/client.cc b/src/crimson/mgr/client.cc
index 0cebc1c1e44bbb66e3092d1ada3817543741ed42..6c2a48121c3436332295f76a773bc6637d8e6453 100644 (file)
--- a/src/crimson/mgr/client.cc
+++ b/src/crimson/mgr/client.cc
@@ -62,6 +62,7 @@ seastar::future<> Client::ms_handle_reset(crimson::net::ConnectionRef c)
 {
   if (conn == c) {
     conn = nullptr;
+    tick_timer.cancel();
   }
   return seastar::now();
 }
@@ -100,29 +101,28 @@ seastar::future<> Client::handle_mgr_conf(crimson::net::Connection* conn,
                                           Ref<MMgrConfigure> m)
 {
   logger().info("{} {}", __func__, *m);
-  tick_period = std::chrono::seconds{m->stats_period};
-  if (tick_period.count() && !tick_timer.armed() ) {
-    tick();
+
+  auto tick_period = std::chrono::seconds{m->stats_period};
+  if (tick_period.count()) {
+    if (tick_timer.armed()) {
+      tick_timer.rearm(tick_timer.get_timeout(), tick_period);
+    } else {
+      tick_timer.arm_periodic(tick_period);
+    }
+  } else {
+    tick_timer.cancel();
   }
   return seastar::now();
 }
 
 void Client::tick()
 {
-  (void) seastar::with_gate(gate, [=] {
+  (void) seastar::with_gate(gate, [this] {
     if (conn) {
       auto pg_stats = with_stats.get_stats();
-      return conn->send(std::move(pg_stats)).finally([this] {
-       if (tick_period.count()) {
-         tick_timer.arm(tick_period);
-       }
-      });
+      return conn->send(std::move(pg_stats));
     } else {
-      return reconnect().finally([this] {
-       if (tick_period.count()) {
-         tick_timer.arm(tick_period);
-       }
-      });;
+      return reconnect();
     }
   });
 }

diff --git a/src/crimson/mgr/client.h b/src/crimson/mgr/client.h
index a82b73bc1f81babd45dc26e1b5020911fdea90e4..0332c59d57b42d5d28d1ddf71d2c849d8ed4b38d 100644 (file)
--- a/src/crimson/mgr/client.h
+++ b/src/crimson/mgr/client.h
@@ -52,7 +52,6 @@ private:
   crimson::net::Messenger& msgr;
   WithStats& with_stats;
   crimson::net::ConnectionRef conn;
-  std::chrono::seconds tick_period{0};
   seastar::timer<seastar::lowres_clock> tick_timer;
   seastar::gate gate;
 };