From f2426891465b2a630efceb4465b4cd395614d340 Mon Sep 17 00:00:00 2001 From: "GERMAIN, FLORENT" Date: Wed, 8 Jun 2022 10:15:25 +0200 Subject: [PATCH] Coll han: fix allreduce dynamic calling internal han algo on sub_comm Signed-off-by: Florent Germain --- ompi/mca/coll/han/coll_han_dynamic.c | 2 +- ompi/mca/coll/han/coll_han_subcomms.c | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ompi/mca/coll/han/coll_han_dynamic.c b/ompi/mca/coll/han/coll_han_dynamic.c index adb74a7aefe..656af8c2076 100644 --- a/ompi/mca/coll/han/coll_han_dynamic.c +++ b/ompi/mca/coll/han/coll_han_dynamic.c @@ -632,7 +632,7 @@ mca_coll_han_allreduce_intra_dynamic(const void *sbuf, * They points to the collective to use, according to the dynamic rules * Selector's job is done, call the collective */ - allreduce = mca_coll_han_allreduce_intra; + allreduce = sub_module->coll_allreduce; } return allreduce(sbuf, rbuf, count, dtype, op, comm, sub_module); diff --git a/ompi/mca/coll/han/coll_han_subcomms.c b/ompi/mca/coll/han/coll_han_subcomms.c index bb9397c008a..d33a8eed727 100644 --- a/ompi/mca/coll/han/coll_han_subcomms.c +++ b/ompi/mca/coll/han/coll_han_subcomms.c @@ -116,7 +116,7 @@ int mca_coll_han_comm_create_new(struct ompi_communicator_t *comm, /* * This sub-communicator contains the ranks that share my node. */ - opal_info_set(&comm_info, "ompi_comm_coll_preference", "^han"); + opal_info_set(&comm_info, "ompi_comm_coll_preference", "han"); opal_info_set(&comm_info, "ompi_comm_coll_han_topo_level", "INTRA_NODE"); ompi_comm_split_type(comm, MPI_COMM_TYPE_SHARED, 0, &comm_info, low_comm);