Skip to content

Commit

Permalink
#2240: Update logs
Browse files Browse the repository at this point in the history
  • Loading branch information
JacobDomagala committed Oct 10, 2024
1 parent 1a0879e commit 3b9d697
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions src/vt/collective/reduce/allreduce/rabenseifner.impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -193,7 +193,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwo(size_t 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
terse, allreduce, "Rabenseifner::adjustForPowerOfTwo: To Node {} ID = {}\n", partner, id
);

if (is_even_) {
Expand Down Expand Up @@ -231,7 +231,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoRightHalf(
}

vt_debug_print(
terse, allreduce, "Rabenseifner (Recv Part1): From Node {} ID = {}\n",
terse, allreduce, "Rabenseifner::adjustForPowerOfTwoRightHalf: From Node {} ID = {}\n",
theContext()->getFromNodeCurrentTask(), msg->id_
);

Expand Down Expand Up @@ -260,7 +260,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoLeftHalf(
}

vt_debug_print(
terse, allreduce, "Rabenseifner (Recv Part1): From Node {} ID = {}\n",
terse, allreduce, "Rabenseifner::adjustForPowerOfTwoLeftHalf: From Node {} ID = {}\n",
theContext()->getFromNodeCurrentTask(), msg->id_
);

Expand All @@ -276,7 +276,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoFinalPart(
AllreduceRbnRawMsg<Scalar>* msg) {

vt_debug_print(
terse, allreduce, "Rabenseifner (Recv Part2): From Node {} ID = {}\n",
terse, allreduce, "Rabenseifner::adjustForPowerOfTwoFinalPart: From Node {} ID = {}\n",
theContext()->getFromNodeCurrentTask(), msg->id_
);

Expand Down Expand Up @@ -356,7 +356,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::scatterReduceIter(size_t id) {

vt_debug_print(
terse, allreduce,
"Rabenseifner Part2 (Send step {}): To Node {} starting with idx = {} and "
"Rabenseifner Scatter (Send step {}): To Node {} starting with idx = {} and "
"count "
"{} ID = {}\n",
state.scatter_step_, dest, state.s_index_[state.scatter_step_],
Expand Down Expand Up @@ -408,7 +408,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::scatterReduceIterHandler(

vt_debug_print(
terse, allreduce,
"Rabenseifner Part2 (Recv step {}): scatter_mask_= {} nprocs_pof2_ = {}: "
"Rabenseifner Scatter (Recv step {}): scatter_mask_= {} nprocs_pof2_ = {}: "
"idx = {} from {} ID = {}\n",
msg->step_, state.scatter_mask_, nprocs_pof2_, state.r_index_[msg->step_],
theContext()->getFromNodeCurrentTask(), msg->id_
Expand Down Expand Up @@ -486,7 +486,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::gatherIter(size_t id) {

vt_debug_print(
terse, allreduce,
"Rabenseifner Part3 (step {}): Sending to Node {} starting with idx = {} and "
"Rabenseifner Gather (step {}): Sending to Node {} starting with idx = {} and "
"count "
"{} ID = {}\n",
state.gather_step_, dest, state.r_index_[state.gather_step_],
Expand Down Expand Up @@ -516,7 +516,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::gatherIterHandler(
AllreduceRbnRawMsg<Scalar>* msg) {
auto& state = states_.at(msg->id_);
vt_debug_print(
terse, allreduce, "Rabenseifner Part3 (step {}): Received idx = {} from {} ID = {}\n",
terse, allreduce, "Rabenseifner Gather (step {}): Received idx = {} from {} ID = {}\n",
msg->step_, state.s_index_[msg->step_],
theContext()->getFromNodeCurrentTask(), msg->id_
);
Expand Down Expand Up @@ -553,7 +553,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::finalPart(size_t id) {

vt_debug_print(
terse, allreduce,
"Rabenseifner Part4: Executing final handler with size {} ID = {}\n", state.val_.size(), id
"Rabenseifner::finalPart(): Executing final handler with size {} ID = {}\n", state.val_.size(), id
);

parent_proxy_[this_node_].template invoke<finalHandler>(
Expand Down Expand Up @@ -584,7 +584,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodes(size_t id)
auto& state = states_.at(id);
if (is_part_of_adjustment_group_ and is_even_) {
vt_debug_print(
terse, allreduce, "Rabenseifner Part4: Sending to Node {} ID = {}\n",
terse, allreduce, "Rabenseifner::sendToExcludedNodes(): Sending to Node {} ID = {}\n",
this_node_ + 1, id
);
proxy_[this_node_ + 1]
Expand All @@ -600,7 +600,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodesHandler(
auto& state = states_.at(msg->id_);
vt_debug_print(
terse, allreduce,
"Rabenseifner Part4: Received allreduce result with size {} ID = {}\n", msg->size_, msg->id_
"Rabenseifner::sendToExcludedNodesHandler(): Received allreduce result with size {} ID = {}\n", msg->size_, msg->id_
);

parent_proxy_[this_node_].template invoke<finalHandler>(
Expand Down

0 comments on commit 3b9d697

Please sign in to comment.