Skip to content

Commit a5cef90

Browse files
authored
Merge pull request #10456 from FlorentGermain-Bull/coll_han_fix_dynamic_allreduce
Coll han: fix allreduce dynamic calling internal han algo on sub_comm
2 parents b4355c2 + f242689 commit a5cef90

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

ompi/mca/coll/han/coll_han_dynamic.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -632,7 +632,7 @@ mca_coll_han_allreduce_intra_dynamic(const void *sbuf,
632632
* They points to the collective to use, according to the dynamic rules
633633
* Selector's job is done, call the collective
634634
*/
635-
allreduce = mca_coll_han_allreduce_intra;
635+
allreduce = sub_module->coll_allreduce;
636636
}
637637
return allreduce(sbuf, rbuf, count, dtype,
638638
op, comm, sub_module);

ompi/mca/coll/han/coll_han_subcomms.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ int mca_coll_han_comm_create_new(struct ompi_communicator_t *comm,
116116
/*
117117
* This sub-communicator contains the ranks that share my node.
118118
*/
119-
opal_info_set(&comm_info, "ompi_comm_coll_preference", "^han");
119+
opal_info_set(&comm_info, "ompi_comm_coll_preference", "han");
120120
opal_info_set(&comm_info, "ompi_comm_coll_han_topo_level", "INTRA_NODE");
121121
ompi_comm_split_type(comm, MPI_COMM_TYPE_SHARED, 0,
122122
&comm_info, low_comm);

0 commit comments

Comments
 (0)