Skip to content

Commit 09c2f4a

Browse files
committed
coll/[sm|han|adapt]: don't disqualify on priority 0
Signed-off-by: Joseph Schuchart <[email protected]>
1 parent dd54af9 commit 09c2f4a

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

ompi/mca/coll/adapt/coll_adapt_module.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,9 @@
33
* of Tennessee Research Foundation. All rights
44
* reserved.
55
* $COPYRIGHT$
6-
*
6+
*
77
* Additional copyrights may follow
8-
*
8+
*
99
* $HEADER$
1010
*/
1111

@@ -146,7 +146,7 @@ mca_coll_base_module_t *ompi_coll_adapt_comm_query(struct ompi_communicator_t *
146146
/* Get the priority level attached to this module.
147147
If priority is less than or equal to 0, then the module is unavailable. */
148148
*priority = mca_coll_adapt_component.adapt_priority;
149-
if (mca_coll_adapt_component.adapt_priority <= 0) {
149+
if (mca_coll_adapt_component.adapt_priority < 0) {
150150
opal_output_verbose(10, ompi_coll_base_framework.framework_output,
151151
"coll:adapt:comm_query (%d/%s): priority too low; "
152152
"disqualifying myself",

ompi/mca/coll/han/coll_han_module.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ mca_coll_han_comm_query(struct ompi_communicator_t * comm, int *priority)
188188
/* Get the priority level attached to this module. If priority is less
189189
* than or equal to 0, then the module is unavailable. */
190190
*priority = mca_coll_han_component.han_priority;
191-
if (mca_coll_han_component.han_priority <= 0) {
191+
if (mca_coll_han_component.han_priority < 0) {
192192
opal_output_verbose(10, ompi_coll_base_framework.framework_output,
193193
"coll:han:comm_query (%d/%s): priority too low; disqualifying myself",
194194
comm->c_contextid, comm->c_name);

ompi/mca/coll/sm/coll_sm_module.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -182,10 +182,10 @@ mca_coll_sm_comm_query(struct ompi_communicator_t *comm, int *priority)
182182
/* Get the priority level attached to this module. If priority is less
183183
* than or equal to 0, then the module is unavailable. */
184184
*priority = mca_coll_sm_component.sm_priority;
185-
if (mca_coll_sm_component.sm_priority <= 0) {
185+
if (mca_coll_sm_component.sm_priority < 0) {
186186
opal_output_verbose(10, ompi_coll_base_framework.framework_output,
187187
"coll:sm:comm_query (%d/%s): priority too low; disqualifying myself", comm->c_contextid, comm->c_name);
188-
return NULL;
188+
return NULL;
189189
}
190190

191191
sm_module = OBJ_NEW(mca_coll_sm_module_t);

0 commit comments

Comments
 (0)