Improve the performance of radix top-k

cpp/bench/matrix/select_k.cu

@@ -31,6 +31,10 @@
 #include <rmm/mr/device/per_device_resource.hpp>
 #include <rmm/mr/device/pool_memory_resource.hpp>
 
+#include <cstdint>
+#include <cstring>
+#include <type_traits>
+
 namespace raft::matrix {
 
 using namespace raft::bench;  // NOLINT
@@ -46,7 +50,23 @@ struct selection : public fixture {
   {
     raft::sparse::iota_fill(in_ids_.data(), IdxT(p.batch_size), IdxT(p.len), stream);
     raft::random::RngState state{42};
-    raft::random::uniform(handle, state, in_dists_.data(), in_dists_.size(), KeyT(-1.0), KeyT(1.0));
+
+    KeyT min_value = -1.0;
+    KeyT max_value = 1.0;
+    if (p.use_same_leading_bits) {
+      if constexpr (std::is_same_v<KeyT, float>) {
+        uint32_t min_bits = 0x3F800000;  // 1.0
+        uint32_t max_bits = 0x3F8000FF;  // 1.00003
+        memcpy(&min_value, &min_bits, sizeof(KeyT));
+        memcpy(&max_value, &max_bits, sizeof(KeyT));
+      } else if constexpr (std::is_same_v<KeyT, double>) {
+        uint64_t min_bits = 0x3FF0000000000000;  // 1.0
+        uint64_t max_bits = 0x3FF0000FFFFFFFFF;  // 1.000015
+        memcpy(&min_value, &min_bits, sizeof(KeyT));
+        memcpy(&max_value, &max_bits, sizeof(KeyT));
+      }
+    }
+    raft::random::uniform(handle, state, in_dists_.data(), in_dists_.size(), min_value, max_value);
   }
 
   void run_benchmark(::benchmark::State& state) override  // NOLINT
@@ -56,6 +76,7 @@ struct selection : public fixture {
     try {
       std::ostringstream label_stream;
       label_stream << params_.batch_size << "#" << params_.len << "#" << params_.k;
+      if (params_.use_same_leading_bits) { label_stream << "#same-leading-bits"; }
       state.SetLabel(label_stream.str());
       loop_on_state(state, [this, &handle]() {
         select::select_k_impl<KeyT, IdxT>(handle,
@@ -81,21 +102,55 @@ struct selection : public fixture {
 };
 
 const std::vector<select::params> kInputs{
-  {20000, 500, 1, true},   {20000, 500, 2, true},    {20000, 500, 4, true},
-  {20000, 500, 8, true},   {20000, 500, 16, true},   {20000, 500, 32, true},
-  {20000, 500, 64, true},  {20000, 500, 128, true},  {20000, 500, 256, true},
-
-  {1000, 10000, 1, true},  {1000, 10000, 2, true},   {1000, 10000, 4, true},
-  {1000, 10000, 8, true},  {1000, 10000, 16, true},  {1000, 10000, 32, true},
-  {1000, 10000, 64, true}, {1000, 10000, 128, true}, {1000, 10000, 256, true},
-
-  {100, 100000, 1, true},  {100, 100000, 2, true},   {100, 100000, 4, true},
-  {100, 100000, 8, true},  {100, 100000, 16, true},  {100, 100000, 32, true},
-  {100, 100000, 64, true}, {100, 100000, 128, true}, {100, 100000, 256, true},
-
-  {10, 1000000, 1, true},  {10, 1000000, 2, true},   {10, 1000000, 4, true},
-  {10, 1000000, 8, true},  {10, 1000000, 16, true},  {10, 1000000, 32, true},
-  {10, 1000000, 64, true}, {10, 1000000, 128, true}, {10, 1000000, 256, true},
+  {20000, 500, 1, true},
+  {20000, 500, 2, true},
+  {20000, 500, 4, true},
+  {20000, 500, 8, true},
+  {20000, 500, 16, true},
+  {20000, 500, 32, true},
+  {20000, 500, 64, true},
+  {20000, 500, 128, true},
+  {20000, 500, 256, true},
+
+  {1000, 10000, 1, true},
+  {1000, 10000, 2, true},
+  {1000, 10000, 4, true},
+  {1000, 10000, 8, true},
+  {1000, 10000, 16, true},
+  {1000, 10000, 32, true},
+  {1000, 10000, 64, true},
+  {1000, 10000, 128, true},
+  {1000, 10000, 256, true},
+
+  {100, 100000, 1, true},
+  {100, 100000, 2, true},
+  {100, 100000, 4, true},
+  {100, 100000, 8, true},
+  {100, 100000, 16, true},
+  {100, 100000, 32, true},
+  {100, 100000, 64, true},
+  {100, 100000, 128, true},
+  {100, 100000, 256, true},
+
+  {10, 1000000, 1, true},
+  {10, 1000000, 2, true},
+  {10, 1000000, 4, true},
+  {10, 1000000, 8, true},
+  {10, 1000000, 16, true},
+  {10, 1000000, 32, true},
+  {10, 1000000, 64, true},
+  {10, 1000000, 128, true},
+  {10, 1000000, 256, true},
+
+  {10, 1000000, 1, true, false, true},
+  {10, 1000000, 2, true, false, true},
+  {10, 1000000, 4, true, false, true},
+  {10, 1000000, 8, true, false, true},
+  {10, 1000000, 16, true, false, true},
+  {10, 1000000, 32, true, false, true},
+  {10, 1000000, 64, true, false, true},
+  {10, 1000000, 128, true, false, true},
+  {10, 1000000, 256, true, false, true},
 };
 
 #define SELECTION_REGISTER(KeyT, IdxT, A)                          \
@@ -105,24 +160,33 @@ const std::vector<select::params> kInputs{
     RAFT_BENCH_REGISTER(SelectK, #KeyT "/" #IdxT "/" #A, kInputs); \
   }
 
-SELECTION_REGISTER(float, int, kPublicApi);           // NOLINT
-SELECTION_REGISTER(float, int, kRadix8bits);          // NOLINT
-SELECTION_REGISTER(float, int, kRadix11bits);         // NOLINT
-SELECTION_REGISTER(float, int, kWarpAuto);            // NOLINT
-SELECTION_REGISTER(float, int, kWarpImmediate);       // NOLINT
-SELECTION_REGISTER(float, int, kWarpFiltered);        // NOLINT
-SELECTION_REGISTER(float, int, kWarpDistributed);     // NOLINT
-SELECTION_REGISTER(float, int, kWarpDistributedShm);  // NOLINT
-
-SELECTION_REGISTER(double, int, kRadix8bits);   // NOLINT
-SELECTION_REGISTER(double, int, kRadix11bits);  // NOLINT
-SELECTION_REGISTER(double, int, kWarpAuto);     // NOLINT
-
-SELECTION_REGISTER(double, size_t, kRadix8bits);          // NOLINT
-SELECTION_REGISTER(double, size_t, kRadix11bits);         // NOLINT
-SELECTION_REGISTER(double, size_t, kWarpImmediate);       // NOLINT
-SELECTION_REGISTER(double, size_t, kWarpFiltered);        // NOLINT
-SELECTION_REGISTER(double, size_t, kWarpDistributed);     // NOLINT
-SELECTION_REGISTER(double, size_t, kWarpDistributedShm);  // NOLINT
+SELECTION_REGISTER(float, int, kPublicApi);             // NOLINT
+SELECTION_REGISTER(float, int, kRadix8bits);            // NOLINT
+SELECTION_REGISTER(float, int, kRadix11bits);           // NOLINT
+SELECTION_REGISTER(float, int, kRadix8bitsUpdated);     // NOLINT
+SELECTION_REGISTER(float, int, kRadix11bitsUpdated);    // NOLINT
+SELECTION_REGISTER(float, int, kRadix11bitsExtraPass);  // NOLINT
+SELECTION_REGISTER(float, int, kWarpAuto);              // NOLINT
+SELECTION_REGISTER(float, int, kWarpImmediate);         // NOLINT
+SELECTION_REGISTER(float, int, kWarpFiltered);          // NOLINT
+SELECTION_REGISTER(float, int, kWarpDistributed);       // NOLINT
+SELECTION_REGISTER(float, int, kWarpDistributedShm);    // NOLINT
+
+SELECTION_REGISTER(double, int, kRadix8bits);            // NOLINT
+SELECTION_REGISTER(double, int, kRadix11bits);           // NOLINT
+SELECTION_REGISTER(double, int, kRadix8bitsUpdated);     // NOLINT
+SELECTION_REGISTER(double, int, kRadix11bitsUpdated);    // NOLINT
+SELECTION_REGISTER(double, int, kRadix11bitsExtraPass);  // NOLINT
+SELECTION_REGISTER(double, int, kWarpAuto);              // NOLINT
+
+SELECTION_REGISTER(double, size_t, kRadix8bits);            // NOLINT
+SELECTION_REGISTER(double, size_t, kRadix11bits);           // NOLINT
+SELECTION_REGISTER(double, size_t, kRadix8bitsUpdated);     // NOLINT
+SELECTION_REGISTER(double, size_t, kRadix11bitsUpdated);    // NOLINT
+SELECTION_REGISTER(double, size_t, kRadix11bitsExtraPass);  // NOLINT
+SELECTION_REGISTER(double, size_t, kWarpImmediate);         // NOLINT
+SELECTION_REGISTER(double, size_t, kWarpFiltered);          // NOLINT
+SELECTION_REGISTER(double, size_t, kWarpDistributed);       // NOLINT
+SELECTION_REGISTER(double, size_t, kWarpDistributedShm);    // NOLINT
 
 }  // namespace raft::matrix