From: David Zafman <dzafman@redhat.com>
Date: Wed, 24 Jul 2019 01:10:46 +0000 (-0700)
Subject: osd: Add debug_disable_randomized_ping config for use in testing
X-Git-Tag: v15.1.0~1664^2~6
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=f2b26d88f0a0727f0362ccd8b287f8bb3f41dc3c;p=ceph.git

osd: Add debug_disable_randomized_ping config for use in testing

Signed-off-by: David Zafman <dzafman@redhat.com>
---

diff --git a/src/common/options.cc b/src/common/options.cc
index 9f9d1fbe5ae5..731612d53270 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -5579,6 +5579,10 @@ std::vector<Option> get_global_options() {
     .set_description("")
     .add_service({"mon", "osd"})
     .set_long_description("This sets the gss target service name."),
+
+    Option("debug_disable_randomized_ping", Option::TYPE_BOOL, Option::LEVEL_DEV)
+    .set_default(false)
+    .set_description("Disable heartbeat ping randomization for testing purposes"),
   });
 }
 
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 0727e821986d..1f01b7ed876d 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -5031,7 +5031,12 @@ void OSD::heartbeat_entry()
   while (!heartbeat_stop) {
     heartbeat();
 
-    double wait = .5 + ((float)(rand() % 10)/10.0) * (float)cct->_conf->osd_heartbeat_interval;
+    double wait;
+    if (cct->_conf.get_val<bool>("debug_disable_randomized_ping")) {
+      wait = (float)cct->_conf->osd_heartbeat_interval;
+    } else {
+      wait = .5 + ((float)(rand() % 10)/10.0) * (float)cct->_conf->osd_heartbeat_interval;
+    }
     auto w = ceph::make_timespan(wait);
     dout(30) << "heartbeat_entry sleeping for " << wait << dendl;
     heartbeat_cond.wait_for(l, w);