From bde53e38014b1b56d5d1168008964c52bbdcfff8 Mon Sep 17 00:00:00 2001
From: Sage Weil <sage@redhat.com>
Date: Tue, 25 Jul 2017 18:41:53 -0400
Subject: [PATCH] mon/MonClient: factor un-backoff into helper; add missing
 config option

- move this into a helper
- use the backoff factor for the division instead of hard-coding 2.0
- add a min config option instead of hard-coding 1.0

Signed-off-by: Sage Weil <sage@redhat.com>
---
 src/common/options.cc |  4 ++++
 src/mon/MonClient.cc  | 18 ++++++++++++++----
 src/mon/MonClient.h   |  1 +
 3 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/src/common/options.cc b/src/common/options.cc
index c98bd30a93823..d5bb61c229499 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -1427,6 +1427,10 @@ std::vector<Option> global_options = {
   .set_default(2.0)
   .set_description(""),
 
+  Option("mon_client_hunt_interval_min_multiple", Option::TYPE_FLOAT, Option::LEVEL_ADVANCED)
+  .set_default(1.0)
+  .set_description(""),
+
   Option("mon_client_hunt_interval_max_multiple", Option::TYPE_FLOAT, Option::LEVEL_ADVANCED)
   .set_default(10.0)
   .set_description(""),
diff --git a/src/mon/MonClient.cc b/src/mon/MonClient.cc
index bc5626dad58e4..96975b31c528d 100644
--- a/src/mon/MonClient.cc
+++ b/src/mon/MonClient.cc
@@ -55,7 +55,8 @@ MonClient::MonClient(CephContext *cct_) :
   more_log_pending(false),
   want_monmap(true),
   had_a_connection(false),
-  reopen_interval_multiplier(1.0),
+  reopen_interval_multiplier(
+    cct_->_conf->get_val<double>("mon_client_hunt_interval_min_multiple")),
   last_mon_command_tid(0),
   version_req_id(0)
 {
@@ -729,9 +730,7 @@ void MonClient::_finish_hunting()
   }
 
   had_a_connection = true;
-  reopen_interval_multiplier /= 2.0;
-  if (reopen_interval_multiplier < 1.0)
-    reopen_interval_multiplier = 1.0;
+  _un_backoff();
 }
 
 void MonClient::tick()
@@ -775,6 +774,17 @@ void MonClient::tick()
   schedule_tick();
 }
 
+void MonClient::_un_backoff()
+{
+  // un-backoff our reconnect interval
+  reopen_interval_multiplier = std::max(
+    cct->_conf->get_val<double>("mon_client_hunt_interval_min_multiple"),
+    reopen_interval_multiplier /
+    cct->_conf->get_val<double>("mon_client_hunt_interval_backoff"));
+  ldout(cct, 20) << __func__ << " reopen_interval_multipler now "
+		 << reopen_interval_multiplier << dendl;
+}
+
 void MonClient::schedule_tick()
 {
   struct C_Tick : public Context {
diff --git a/src/mon/MonClient.h b/src/mon/MonClient.h
index 283f2335c0287..0b24e01e2bace 100644
--- a/src/mon/MonClient.h
+++ b/src/mon/MonClient.h
@@ -210,6 +210,7 @@ private:
   void _finish_auth(int auth_err);
   void _reopen_session(int rank = -1);
   MonConnection& _add_conn(unsigned rank, uint64_t global_id);
+  void _un_backoff();
   void _add_conns(uint64_t global_id);
   void _send_mon_message(Message *m);
 
-- 
2.39.5