Skip to content

Commit a537975

Browse files
committed
#2240: Update logs
1 parent e4b05c9 commit a537975

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

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

+11-11
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwo(size_t id)
193193
auto const partner = is_even_ ? this_node_ + 1 : this_node_ - 1;
194194

195195
vt_debug_print(
196-
terse, allreduce, "Rabenseifner (Send Part1): To Node {} ID = {}\n", partner, id
196+
terse, allreduce, "Rabenseifner::adjustForPowerOfTwo: To Node {} ID = {}\n", partner, id
197197
);
198198

199199
if (is_even_) {
@@ -231,7 +231,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoRightHalf(
231231
}
232232

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

@@ -260,7 +260,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoLeftHalf(
260260
}
261261

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

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

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

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

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

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

487487
vt_debug_print(
488488
terse, allreduce,
489-
"Rabenseifner Part3 (step {}): Sending to Node {} starting with idx = {} and "
489+
"Rabenseifner Gather (step {}): Sending to Node {} starting with idx = {} and "
490490
"count "
491491
"{} ID = {}\n",
492492
state.gather_step_, dest, state.r_index_[state.gather_step_],
@@ -516,7 +516,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::gatherIterHandler(
516516
AllreduceRbnRawMsg<Scalar>* msg) {
517517
auto& state = states_.at(msg->id_);
518518
vt_debug_print(
519-
terse, allreduce, "Rabenseifner Part3 (step {}): Received idx = {} from {} ID = {}\n",
519+
terse, allreduce, "Rabenseifner Gather (step {}): Received idx = {} from {} ID = {}\n",
520520
msg->step_, state.s_index_[msg->step_],
521521
theContext()->getFromNodeCurrentTask(), msg->id_
522522
);
@@ -553,7 +553,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::finalPart(size_t id) {
553553

554554
vt_debug_print(
555555
terse, allreduce,
556-
"Rabenseifner Part4: Executing final handler with size {} ID = {}\n", state.val_.size(), id
556+
"Rabenseifner::finalPart(): Executing final handler with size {} ID = {}\n", state.val_.size(), id
557557
);
558558

559559
parent_proxy_[this_node_].template invoke<finalHandler>(
@@ -584,7 +584,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodes(size_t id)
584584
auto& state = states_.at(id);
585585
if (is_part_of_adjustment_group_ and is_even_) {
586586
vt_debug_print(
587-
terse, allreduce, "Rabenseifner Part4: Sending to Node {} ID = {}\n",
587+
terse, allreduce, "Rabenseifner::sendToExcludedNodes(): Sending to Node {} ID = {}\n",
588588
this_node_ + 1, id
589589
);
590590
proxy_[this_node_ + 1]
@@ -600,7 +600,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodesHandler(
600600
auto& state = states_.at(msg->id_);
601601
vt_debug_print(
602602
terse, allreduce,
603-
"Rabenseifner Part4: Received allreduce result with size {} ID = {}\n", msg->size_, msg->id_
603+
"Rabenseifner::sendToExcludedNodesHandler(): Received allreduce result with size {} ID = {}\n", msg->size_, msg->id_
604604
);
605605

606606
parent_proxy_[this_node_].template invoke<finalHandler>(

0 commit comments

Comments
 (0)