Skip to content

Commit f0baed6

Browse files
author
Sergey Oblomov
committed
PML/UCX: fixed hand on MPI_Finalize
fixes issue openucx/ucx#2656 added flush for worker object to complete all pending operations Signed-off-by: Sergey Oblomov <[email protected]> (cherry picked from commit 0a8261f)
1 parent b9918a3 commit f0baed6

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ompi/mca/pml/ucx/pml_ucx.c

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -429,6 +429,10 @@ int mca_pml_ucx_del_procs(struct ompi_proc_t **procs, size_t nprocs)
429429

430430
mca_pml_ucx_waitall(dreqs, &num_reqs);
431431
free(dreqs);
432+
/* flush worker to allow all pending operations to complete.
433+
* ignore error (we can do nothing here), just try to
434+
* finalize gracefully */
435+
ucp_worker_flush(ompi_pml_ucx.ucp_worker);
432436

433437
opal_pmix.fence(NULL, 0);
434438

0 commit comments

Comments
 (0)