summaryrefslogtreecommitdiffstats
path: root/src/common/weighted_shuffle.h
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-21 11:54:28 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-21 11:54:28 +0000
commite6918187568dbd01842d8d1d2c808ce16a894239 (patch)
tree64f88b554b444a49f656b6c656111a145cbbaa28 /src/common/weighted_shuffle.h
parentInitial commit. (diff)
downloadceph-e6918187568dbd01842d8d1d2c808ce16a894239.tar.xz
ceph-e6918187568dbd01842d8d1d2c808ce16a894239.zip
Adding upstream version 18.2.2.upstream/18.2.2
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/common/weighted_shuffle.h')
-rw-r--r--src/common/weighted_shuffle.h25
1 files changed, 25 insertions, 0 deletions
diff --git a/src/common/weighted_shuffle.h b/src/common/weighted_shuffle.h
new file mode 100644
index 000000000..10def0a01
--- /dev/null
+++ b/src/common/weighted_shuffle.h
@@ -0,0 +1,25 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#pragma once
+
+#include <algorithm>
+#include <iterator>
+#include <random>
+
+template <class RandomIt, class DistIt, class URBG>
+void weighted_shuffle(RandomIt first, RandomIt last,
+ DistIt weight_first, DistIt weight_last,
+ URBG &&g)
+{
+ if (first == last) {
+ return;
+ } else {
+ std::discrete_distribution d{weight_first, weight_last};
+ if (auto n = d(g); n > 0) {
+ std::iter_swap(first, std::next(first, n));
+ std::iter_swap(weight_first, std::next(weight_first, n));
+ }
+ weighted_shuffle(++first, last, ++weight_first, weight_last, std::move(g));
+ }
+}