Skip to content

Commit 972ded5

Browse files
committed
UCX: Propagate MPI serialized for all worker creations
Move MPI to UCX thread mode function to common source. Also use serialized mode for all oshmem initializations. Signed-off-by: Thomas Vegas <[email protected]> (cherry picked from commit 44cc663)
1 parent 6753f8d commit 972ded5

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

ompi/mca/pml/ucx/pml_ucx.c

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,6 @@ int mca_pml_ucx_init(int enable_mpi_threads)
288288

289289
PML_UCX_VERBOSE(1, "mca_pml_ucx_init");
290290

291-
/* TODO check MPI thread mode */
292291
params.field_mask = UCP_WORKER_PARAM_FIELD_THREAD_MODE;
293292
if (enable_mpi_threads) {
294293
params.thread_mode = UCS_THREAD_MODE_MULTI;

oshmem/mca/spml/ucx/spml_ucx_component.c

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -322,6 +322,8 @@ static int spml_ucx_init(void)
322322
wkr_params.field_mask = UCP_WORKER_PARAM_FIELD_THREAD_MODE;
323323
if (oshmem_mpi_thread_requested == SHMEM_THREAD_MULTIPLE) {
324324
wkr_params.thread_mode = UCS_THREAD_MODE_MULTI;
325+
} else if (oshmem_mpi_thread_requested == SHMEM_THREAD_SERIALIZED) {
326+
wkr_params.thread_mode = UCS_THREAD_MODE_SERIALIZED;
325327
} else {
326328
wkr_params.thread_mode = UCS_THREAD_MODE_SINGLE;
327329
}

0 commit comments

Comments
 (0)