Skip to content

Commit a3f3680

Browse files
.
1 parent 6a02b48 commit a3f3680

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/components/tl/ucp/tl_ucp_context.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ UCC_CLASS_INIT_FUNC(ucc_tl_ucp_context_t,
219219
}
220220

221221
#ifdef HAVE_UCX_NODE_LOCAL_ID
222-
if (params->node_local_id != UCC_ULUNITS_AUTO) {
222+
if (params->node_local_id != UCC_ULUNITS_AUTO) {
223223
ucp_params.field_mask |= UCP_PARAM_FIELD_NODE_LOCAL_ID;
224224
ucp_params.node_local_id = params->node_local_id;
225225
}

src/core/ucc_context.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -860,8 +860,7 @@ ucc_status_t ucc_context_create_proc_info(ucc_lib_h lib,
860860
ucc_error("failed to init progress queue for context %p", ctx);
861861
goto error_ctx_create;
862862
}
863-
ctx->id.pi = *proc_info;
864-
ctx->id.seq_num = ucc_atomic_fadd32(&ucc_context_seq_num, 1);
863+
865864
if (params->mask & UCC_CONTEXT_PARAM_FIELD_OOB &&
866865
params->oob.n_oob_eps > 1) {
867866
do {
@@ -877,7 +876,7 @@ ucc_status_t ucc_context_create_proc_info(ucc_lib_h lib,
877876
}
878877
} while (status == UCC_INPROGRESS);
879878

880-
if (topo_required) {
879+
if (topo_required && !ctx->topo) {
881880
/* At least one available CL context reported it needs topo info */
882881
status = ucc_context_topo_init(&ctx->addr_storage, &ctx->topo);
883882
if (UCC_OK != status) {
@@ -950,6 +949,7 @@ ucc_status_t ucc_context_create_proc_info(ucc_lib_h lib,
950949
goto error_ctx_create;
951950
}
952951
}
952+
953953
n_tl_ctx = ctx->n_tl_ctx;
954954
for (i = 0; i < n_tl_ctx; i++) {
955955
tl_ctx = ctx->tl_ctx[i];

0 commit comments

Comments
 (0)