add cluster balance indicator

include/dsn/utility/stddev.h

@@ -0,0 +1,15 @@
+// Copyright (c) 2017, Xiaomi, Inc.  All rights reserved.
+// This source code is licensed under the Apache License Version 2.0, which
+// can be found in the LICENSE file in the root directory of this source tree.
+
+#pragma once
+
+#include <vector>
+
+namespace dsn {
+namespace math {
+
+double mean_stddev(const std::vector<unsigned> &result_set, bool partial_sample);
+
+} // namespace math
+} // namespace dsn

include/dsn/utility/strings.h

@@ -49,5 +49,7 @@ char *trim_string(char *s);
 
 // calculate the md5 checksum of buffer
 std::string string_md5(const char *buffer, unsigned int length);
+
+std::string to_string_with_precision(const double double_val, const int precision);
 }
 }

src/core/core/stddev.cpp

@@ -0,0 +1,34 @@
+// Copyright (c) 2017, Xiaomi, Inc.  All rights reserved.
+// This source code is licensed under the Apache License Version 2.0, which
+// can be found in the LICENSE file in the root directory of this source tree.
+
+#include <numeric>
+#include <algorithm>
+#include <math.h>
+#include <dsn/utility/stddev.h>
+
+namespace dsn {
+namespace math {
+
+double mean_stddev(const std::vector<unsigned> &result_set, bool partial_sample)
+{
+    double sum = std::accumulate(result_set.begin(), result_set.end(), 0.0);
+    double mean = sum / result_set.size();
+
+    double accum = 0.0;
+    std::for_each(result_set.begin(), result_set.end(), [&](const double d) {
+        accum += (d - mean) * (d - mean);
+    });
+
+    double stddev;
+    if (partial_sample)
+        stddev = sqrt(accum / (result_set.size() - 1));
+    else
+        stddev = sqrt(accum / (result_set.size()));
+
+    stddev = ((double)((int)((stddev + 0.005) * 100))) / 100;
+    return stddev;
+}
+
+} // namespace math
+} // namespace dsn

src/core/core/strings.cpp

@@ -183,5 +183,13 @@ std::string string_md5(const char *buffer, unsigned length)
 
     return result;
 }
+
+std::string to_string_with_precision(const double double_val, const int precision)
+{
+    std::ostringstream out;
+    out.precision(precision);
+    out << std::fixed << double_val;
+    return out.str();
+}
 }
 }