#2240: Fix compile issues on some compilers and runtime issue with passing proxy by reference

Author: JacobDomagala

src/vt/collective/reduce/allreduce/rabenseifner.impl.h

@@ -74,6 +74,7 @@ Rabenseifner<DataT, Op, ObjT, finalHandler>::Rabenseifner(
     vrt_node_ = this_node_ - nprocs_rem_;
   }
 
+  vt_debug_print(terse, allreduce, "Rabenseifner constructor\n");
   initialize(generateNewId(), std::forward<Args>(data)...);
 }
 
@@ -83,6 +84,8 @@ template <
 {
   auto& state = states_[id];
 
+  vt_debug_print(terse, allreduce, "Rabenseifner initializing state for ID = {}\n", id);
+
   state.scatter_messages_.resize(num_steps_, nullptr);
   state.scatter_steps_recv_.resize(num_steps_, false);
   state.scatter_steps_reduced_.resize(num_steps_, false);
@@ -173,6 +176,7 @@ template <
   typename DataT, template <typename Arg> class Op, typename ObjT,
   auto finalHandler>
 void Rabenseifner<DataT, Op, ObjT, finalHandler>::allreduce(size_t id) {
+  vt_debug_print(terse, allreduce, "Rabenseifner allreduce is_part_of_adjustment_group_ = {}\n", is_part_of_adjustment_group_);
   if (is_part_of_adjustment_group_) {
     adjustForPowerOfTwo(id);
   } else {
@@ -188,6 +192,10 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwo(size_t id)
     auto& state = states_.at(id);
     auto const partner = is_even_ ? this_node_ + 1 : this_node_ - 1;
 
+    vt_debug_print(
+      terse, allreduce, "Rabenseifner (Send Part1): To Node {} ID = {}\n", partner, id
+    );
+
     if (is_even_) {
       proxy_[partner]
         .template send<&Rabenseifner::adjustForPowerOfTwoRightHalf>(
@@ -204,10 +212,6 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwo(size_t id)
         adjustForPowerOfTwoRightHalf(state.right_adjust_message_.get());
       }
     }
-
-    vt_debug_print(
-      terse, allreduce, "Rabenseifner (Send Part1): To Node {} ID = {}\n", partner, id
-    );
   }
 }
 

src/vt/collective/reduce/allreduce/recursive_doubling.impl.h

@@ -241,7 +241,7 @@ void RecursiveDoubling<DataT, Op, ObjT, finalHandler>::tryReduce(size_t id, int3
 
   vt_debug_print(
       terse, allreduce, "RecursiveDoubling Part2 (Reduce step {}): state.step_ = {} state.steps_reduced_[step] = {} state.steps_recv_[step] = {} all_msgs_received = {} ID = {} \n",
-      step, state.step_, state.steps_reduced_[step], state.steps_recv_[step], all_msgs_received, id);
+      step, state.step_, static_cast<bool>(state.steps_reduced_[step]), static_cast<bool>(state.steps_recv_[step]), all_msgs_received, id);
 
   if (
     (step < state.step_) and not state.steps_reduced_[step] and

src/vt/objgroup/manager.impl.h

@@ -299,7 +299,7 @@ ObjGroupManager::PendingSendType ObjGroupManager::allreduce(
 
   return PendingSendType{
     theTerm()->getEpoch(),
-    [&] { grp_proxy[this_node].template invoke<&Reducer::allreduce>(id); }
+    [=] { grp_proxy[this_node].template invoke<&Reducer::allreduce>(id); }
   };
 }
 

tests/perf/allreduce.cc

@@ -53,7 +53,6 @@
 #include <vt/collective/reduce/allreduce/rabenseifner.h>
 #include <vt/collective/reduce/allreduce/recursive_doubling.h>
 
-#include <fmt-vt/core.h>
 #ifdef MAGISTRATE_KOKKOS_ENABLED
 #include <Kokkos_Core.hpp>
 #endif