@@ -193,7 +193,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwo(size_t id)
193
193
auto const partner = is_even_ ? this_node_ + 1 : this_node_ - 1 ;
194
194
195
195
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
197
197
);
198
198
199
199
if (is_even_) {
@@ -231,7 +231,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoRightHalf(
231
231
}
232
232
233
233
vt_debug_print (
234
- terse, allreduce, " Rabenseifner (Recv Part1) : From Node {} ID = {}\n " ,
234
+ terse, allreduce, " Rabenseifner::adjustForPowerOfTwoRightHalf : From Node {} ID = {}\n " ,
235
235
theContext ()->getFromNodeCurrentTask (), msg->id_
236
236
);
237
237
@@ -260,7 +260,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoLeftHalf(
260
260
}
261
261
262
262
vt_debug_print (
263
- terse, allreduce, " Rabenseifner (Recv Part1) : From Node {} ID = {}\n " ,
263
+ terse, allreduce, " Rabenseifner::adjustForPowerOfTwoLeftHalf : From Node {} ID = {}\n " ,
264
264
theContext ()->getFromNodeCurrentTask (), msg->id_
265
265
);
266
266
@@ -276,7 +276,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::adjustForPowerOfTwoFinalPart(
276
276
AllreduceRbnRawMsg<Scalar>* msg) {
277
277
278
278
vt_debug_print (
279
- terse, allreduce, " Rabenseifner (Recv Part2) : From Node {} ID = {}\n " ,
279
+ terse, allreduce, " Rabenseifner::adjustForPowerOfTwoFinalPart : From Node {} ID = {}\n " ,
280
280
theContext ()->getFromNodeCurrentTask (), msg->id_
281
281
);
282
282
@@ -356,7 +356,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::scatterReduceIter(size_t id) {
356
356
357
357
vt_debug_print (
358
358
terse, allreduce,
359
- " Rabenseifner Part2 (Send step {}): To Node {} starting with idx = {} and "
359
+ " Rabenseifner Scatter (Send step {}): To Node {} starting with idx = {} and "
360
360
" count "
361
361
" {} ID = {}\n " ,
362
362
state.scatter_step_ , dest, state.s_index_ [state.scatter_step_ ],
@@ -408,7 +408,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::scatterReduceIterHandler(
408
408
409
409
vt_debug_print (
410
410
terse, allreduce,
411
- " Rabenseifner Part2 (Recv step {}): scatter_mask_= {} nprocs_pof2_ = {}: "
411
+ " Rabenseifner Scatter (Recv step {}): scatter_mask_= {} nprocs_pof2_ = {}: "
412
412
" idx = {} from {} ID = {}\n " ,
413
413
msg->step_ , state.scatter_mask_ , nprocs_pof2_, state.r_index_ [msg->step_ ],
414
414
theContext ()->getFromNodeCurrentTask (), msg->id_
@@ -486,7 +486,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::gatherIter(size_t id) {
486
486
487
487
vt_debug_print (
488
488
terse, allreduce,
489
- " Rabenseifner Part3 (step {}): Sending to Node {} starting with idx = {} and "
489
+ " Rabenseifner Gather (step {}): Sending to Node {} starting with idx = {} and "
490
490
" count "
491
491
" {} ID = {}\n " ,
492
492
state.gather_step_ , dest, state.r_index_ [state.gather_step_ ],
@@ -516,7 +516,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::gatherIterHandler(
516
516
AllreduceRbnRawMsg<Scalar>* msg) {
517
517
auto & state = states_.at (msg->id_ );
518
518
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 " ,
520
520
msg->step_ , state.s_index_ [msg->step_ ],
521
521
theContext ()->getFromNodeCurrentTask (), msg->id_
522
522
);
@@ -553,7 +553,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::finalPart(size_t id) {
553
553
554
554
vt_debug_print (
555
555
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
557
557
);
558
558
559
559
parent_proxy_[this_node_].template invoke <finalHandler>(
@@ -584,7 +584,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodes(size_t id)
584
584
auto & state = states_.at (id);
585
585
if (is_part_of_adjustment_group_ and is_even_) {
586
586
vt_debug_print (
587
- terse, allreduce, " Rabenseifner Part4 : Sending to Node {} ID = {}\n " ,
587
+ terse, allreduce, " Rabenseifner::sendToExcludedNodes() : Sending to Node {} ID = {}\n " ,
588
588
this_node_ + 1 , id
589
589
);
590
590
proxy_[this_node_ + 1 ]
@@ -600,7 +600,7 @@ void Rabenseifner<DataT, Op, ObjT, finalHandler>::sendToExcludedNodesHandler(
600
600
auto & state = states_.at (msg->id_ );
601
601
vt_debug_print (
602
602
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_
604
604
);
605
605
606
606
parent_proxy_[this_node_].template invoke <finalHandler>(
0 commit comments