From: Sage Weil <sage@redhat.com>
Date: Tue, 25 Jul 2017 22:41:53 +0000 (-0400)
Subject: mon/MonClient: factor un-backoff into helper; add missing config option
X-Git-Tag: v12.1.2~90^2~2
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=bde53e38014b1b56d5d1168008964c52bbdcfff8;p=ceph.git

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>
---

diff --git a/src/common/options.cc b/src/common/options.cc
index c98bd30a9382..d5bb61c22949 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 bc5626dad58e..96975b31c528 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 283f2335c028..0b24e01e2bac 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);