From 0d68197376b6cf48c6679d77ec9f28f279f3da68 Mon Sep 17 00:00:00 2001
From: Kefu Chai <kchai@redhat.com>
Date: Tue, 17 Oct 2017 12:10:55 +0800
Subject: [PATCH] osd,mon: change "mon_max_pg_per_osd" to uint64_t

as it should never be a negative number. if this option is disabled,
it's 0.

Signed-off-by: Kefu Chai <kchai@redhat.com>
---
 src/common/options.cc |  2 +-
 src/mon/OSDMonitor.cc |  8 ++++----
 src/mon/PGMap.cc      | 10 +++++-----
 src/osd/OSD.cc        |  4 ++--
 4 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/common/options.cc b/src/common/options.cc
index c0d4b7383ea..61d6b405ee6 100644
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -1052,7 +1052,7 @@ std::vector<Option> get_global_options() {
     .set_default(30)
     .set_description(""),
 
-    Option("mon_max_pg_per_osd", Option::TYPE_INT, Option::LEVEL_ADVANCED)
+    Option("mon_max_pg_per_osd", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
     .set_default(200)
     .set_description("Max number of PGs per OSD the cluster will allow"),
 
diff --git a/src/mon/OSDMonitor.cc b/src/mon/OSDMonitor.cc
index 53096a71d5d..3e3cf97853e 100644
--- a/src/mon/OSDMonitor.cc
+++ b/src/mon/OSDMonitor.cc
@@ -5421,10 +5421,10 @@ int OSDMonitor::get_crush_rule(const string &rule_name,
 
 int OSDMonitor::check_pg_num(int64_t pool, int pg_num, int size, ostream *ss)
 {
-  int64_t max_pgs_per_osd = g_conf->get_val<int64_t>("mon_max_pg_per_osd");
-  int num_osds = MAX(osdmap.get_num_in_osds(), 3);   // assume min cluster size 3
-  int64_t max_pgs = max_pgs_per_osd * num_osds;
-  int64_t projected = 0;
+  auto max_pgs_per_osd = g_conf->get_val<uint64_t>("mon_max_pg_per_osd");
+  auto num_osds = std::max(osdmap.get_num_in_osds(), 3u);   // assume min cluster size 3
+  auto max_pgs = max_pgs_per_osd * num_osds;
+  uint64_t projected = 0;
   if (pool < 0) {
     projected += pg_num * size;
   }
diff --git a/src/mon/PGMap.cc b/src/mon/PGMap.cc
index 0b6d3480497..b576a1a7029 100644
--- a/src/mon/PGMap.cc
+++ b/src/mon/PGMap.cc
@@ -2393,12 +2393,12 @@ void PGMap::get_health_checks(
   }
 
   // TOO_FEW_PGS
-  int num_in = osdmap.get_num_in_osds();
-  int sum_pg_up = MAX(pg_sum.up, static_cast<int32_t>(pg_stat.size()));
+  unsigned num_in = osdmap.get_num_in_osds();
+  auto sum_pg_up = std::max(static_cast<size_t>(pg_sum.up), pg_stat.size());
   if (num_in &&
       cct->_conf->mon_pg_warn_min_per_osd > 0 &&
       osdmap.get_pools().size() > 0) {
-    int per = sum_pg_up / num_in;
+    auto per = sum_pg_up / num_in;
     if (per < cct->_conf->mon_pg_warn_min_per_osd && per) {
       ostringstream ss;
       ss << "too few PGs per OSD (" << per
@@ -2408,9 +2408,9 @@ void PGMap::get_health_checks(
   }
 
   // TOO_MANY_PGS
-  int64_t max_pg_per_osd = cct->_conf->get_val<int64_t>("mon_max_pg_per_osd");
+  auto max_pg_per_osd = cct->_conf->get_val<uint64_t>("mon_max_pg_per_osd");
   if (num_in && max_pg_per_osd > 0) {
-    int per = sum_pg_up / num_in;
+    auto per = sum_pg_up / num_in;
     if (per > max_pg_per_osd) {
       ostringstream ss;
       ss << "too many PGs per OSD (" << per
diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index 4a485ac74b3..56129347c3e 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -4169,7 +4169,7 @@ int OSD::handle_pg_peering_evt(
 bool OSD::maybe_wait_for_max_pg(spg_t pgid, bool is_mon_create)
 {
   const auto max_pgs_per_osd =
-    (cct->_conf->get_val<int64_t>("mon_max_pg_per_osd") *
+    (cct->_conf->get_val<uint64_t>("mon_max_pg_per_osd") *
      cct->_conf->get_val<double>("osd_max_pg_per_osd_hard_ratio"));
 
   RWLock::RLocker pg_map_locker{pg_map_lock};
@@ -4206,7 +4206,7 @@ void OSD::resume_creating_pg()
   MOSDPGTemp *pgtemp = nullptr;
   {
     const auto max_pgs_per_osd =
-      (cct->_conf->get_val<int64_t>("mon_max_pg_per_osd") *
+      (cct->_conf->get_val<uint64_t>("mon_max_pg_per_osd") *
        cct->_conf->get_val<double>("osd_max_pg_per_osd_hard_ratio"));
     RWLock::RLocker l(pg_map_lock);
     if (max_pgs_per_osd <= pg_map.size()) {