#5: LB: switch to handle_.reduce, which is the proper call

Author: lifflander

src/vt-lb/algo/temperedlb/temperedlb.h

@@ -340,7 +340,7 @@ struct TemperedLB final : baselb::BaseLB {
     }
 
     int const root = 0;
-    comm_.reduce(root, MPI_INT, MPI_MAX, &local_clusters, &global_max_clusters_, 1);
+    handle_.reduce(root, MPI_INT, MPI_MAX, &local_clusters, &global_max_clusters_, 1);
 
     if (comm_.getRank() == root) {
       printf("%d: global max clusters across ranks: %d\n", root, global_max_clusters_);
@@ -355,9 +355,9 @@ struct TemperedLB final : baselb::BaseLB {
     double global_min = 0.0;
     double global_max = 0.0;
     double global_sum = 0.0;
-    comm_.reduce(0, MPI_DOUBLE, MPI_MIN, &local_value, &global_min, 1);
-    comm_.reduce(0, MPI_DOUBLE, MPI_MAX, &local_value, &global_max, 1);
-    comm_.reduce(0, MPI_DOUBLE, MPI_SUM, &local_value, &global_sum, 1);
+    handle_.reduce(0, MPI_DOUBLE, MPI_MIN, &local_value, &global_min, 1);
+    handle_.reduce(0, MPI_DOUBLE, MPI_MAX, &local_value, &global_max, 1);
+    handle_.reduce(0, MPI_DOUBLE, MPI_SUM, &local_value, &global_sum, 1);
     double global_avg = global_sum / static_cast<double>(comm_.numRanks());
     double I = (global_max / global_avg) - 1.0;
     if (comm_.getRank() == 0) {

src/vt-lb/comm/vt/proxy_wrapper.impl.h

@@ -62,7 +62,7 @@ template <typename ProxyT>
 template <typename T>
 void ProxyWrapper<ProxyT>::reduceAnonCb(vt::collective::ReduceTMsg<T>* msg, ReduceCtx* ctx) {
   auto const& val = msg->getVal();
-  printf("%d: callback invoked\n", vt::theContext()->getNode());
+  //printf("%d: callback invoked\n", vt::theContext()->getNode());
   if constexpr (
     std::is_same_v<std::decay_t<T>, int> || std::is_same_v<std::decay_t<T>, double> ||
     std::is_same_v<std::decay_t<T>, float> || std::is_same_v<std::decay_t<T>, long> ||
@@ -117,7 +117,7 @@ void ProxyWrapper<ProxyT>::reduce_impl(int root, MPI_Op op, SendBufT sendbuf, Re
   ctx->out_ptr = static_cast<void*>(recvbuf);
   ctx->count = static_cast<std::size_t>(std::max(1, count));
   ctx->done.store(false);
-  printf("%d: initiating reduce\n", vt::theContext()->getNode());
+  //printf("%d: initiating reduce\n", vt::theContext()->getNode());
 
   if (count == 1) {
     T value = *static_cast<T const*>(sendbuf);