File tree Expand file tree Collapse file tree 1 file changed +14
-16
lines changed Expand file tree Collapse file tree 1 file changed +14
-16
lines changed Original file line number Diff line number Diff line change @@ -281,22 +281,20 @@ int mca_coll_spacc_allreduce_intra_redscat_allgather(
281
281
wsize = rcount [step ];
282
282
step ++ ;
283
283
}
284
- }
285
- /*
286
- * Assertion: each process has 1 / p' of the total reduction result:
287
- * rcount[nsteps - 1] elements in the rbuf[rindex[nsteps - 1], ...].
288
- */
289
-
290
- /*
291
- * Step 3. Allgather by the recursive doubling algorithm.
292
- * Each process has 1 / p' of the total reduction result:
293
- * rcount[nsteps - 1] elements in the rbuf[rindex[nsteps - 1], ...].
294
- * All exchanges are executed in reverse order relative
295
- * to recursive doubling (previous step).
296
- */
297
-
298
- if (vrank != -1 ) {
299
- step = nsteps - 1 ; /* step = ilog2(p') - 1 */
284
+ /*
285
+ * Assertion: each process has 1 / p' of the total reduction result:
286
+ * rcount[nsteps - 1] elements in the rbuf[rindex[nsteps - 1], ...].
287
+ */
288
+
289
+ /*
290
+ * Step 3. Allgather by the recursive doubling algorithm.
291
+ * Each process has 1 / p' of the total reduction result:
292
+ * rcount[nsteps - 1] elements in the rbuf[rindex[nsteps - 1], ...].
293
+ * All exchanges are executed in reverse order relative
294
+ * to recursive doubling (previous step).
295
+ */
296
+
297
+ step -- ;
300
298
301
299
for (int mask = nprocs_pof2 >> 1 ; mask > 0 ; mask >>= 1 ) {
302
300
int vdest = vrank ^ mask ;
You can’t perform that action at this time.
0 commit comments