From c201c0abb3fb64eabca274f05bd6c7ae9ed564e9 Mon Sep 17 00:00:00 2001 From: Sergey Oblomov Date: Sun, 26 Aug 2018 19:18:28 +0300 Subject: [PATCH] PML/UCX: blocked calls optimizations: removed reset progress count Signed-off-by: Sergey Oblomov --- ompi/mca/pml/ucx/pml_ucx.c | 2 -- 1 file changed, 2 deletions(-) diff --git a/ompi/mca/pml/ucx/pml_ucx.c b/ompi/mca/pml/ucx/pml_ucx.c index 93f558a6d9..1f37212c58 100644 --- a/ompi/mca/pml/ucx/pml_ucx.c +++ b/ompi/mca/pml/ucx/pml_ucx.c @@ -762,7 +762,6 @@ int mca_pml_ucx_iprobe(int src, int tag, struct ompi_communicator_t* comm, if (ucp_msg != NULL) { *matched = 1; mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); - progress_count = 0; } else { (++progress_count % opal_common_ucx.progress_iterations) ? (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress(); @@ -812,7 +811,6 @@ int mca_pml_ucx_improbe(int src, int tag, struct ompi_communicator_t* comm, PML_UCX_VERBOSE(8, "got message %p (%p)", (void*)*message, (void*)ucp_msg); *matched = 1; mca_pml_ucx_set_recv_status_safe(mpi_status, UCS_OK, &info); - progress_count = 0; } else { (++progress_count % opal_common_ucx.progress_iterations) ? (void)ucp_worker_progress(ompi_pml_ucx.ucp_worker) : opal_progress();