Fix dynamic decision for Scan and bug in Allreduce
Signed-off-by: Mikhail Kurnosov <mkurnosov@gmail.com>
Этот коммит содержится в:
родитель
e85fa469f3
Коммит
82a3a5bdb5
@ -1183,7 +1183,7 @@ int ompi_coll_base_allreduce_intra_redscat_allgather(
|
||||
* to recursive doubling (previous step).
|
||||
*/
|
||||
|
||||
step--;
|
||||
step = nsteps - 1;
|
||||
|
||||
for (int mask = nprocs_pof2 >> 1; mask > 0; mask >>= 1) {
|
||||
int vdest = vrank ^ mask;
|
||||
|
@ -690,7 +690,7 @@ int ompi_coll_tuned_scan_intra_dec_dynamic(const void *sbuf, void* rbuf, int cou
|
||||
if (tuned_module->user_forced[SCAN].algorithm) {
|
||||
return ompi_coll_tuned_scan_intra_do_this(sbuf, rbuf, count, dtype,
|
||||
op, comm, module,
|
||||
tuned_module->user_forced[EXSCAN].algorithm);
|
||||
tuned_module->user_forced[SCAN].algorithm);
|
||||
}
|
||||
|
||||
return ompi_coll_base_scan_intra_linear(sbuf, rbuf, count, dtype,
|
||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user