Skip to content

Commit c2eeca8

Browse files
authored
Merge pull request #10642 from devreal/osc-ucx-rputget-flushnb-main-fixup
Fixup: osc/ucx: implement rput and rget using ucp_worker_flush_nb
2 parents b1383f4 + e7d8cc7 commit c2eeca8

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

ompi/mca/osc/ucx/osc_ucx_comm.c

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1075,9 +1075,6 @@ int ompi_osc_ucx_rput(const void *origin_addr, int origin_count,
10751075
ret = opal_common_ucx_wpmem_flush_ep_nb(mem, target, req_completion, ucx_req);
10761076

10771077
if (ret != OMPI_SUCCESS) {
1078-
OMPI_OSC_UCX_REQUEST_RETURN(ucx_req);
1079-
return ret;
1080-
10811078
/* fallback to using an atomic op to acquire a request handle */
10821079
ret = opal_common_ucx_wpmem_fence(mem);
10831080
if (ret != OMPI_SUCCESS) {
@@ -1131,9 +1128,6 @@ int ompi_osc_ucx_rget(void *origin_addr, int origin_count,
11311128
ret = opal_common_ucx_wpmem_flush_ep_nb(mem, target, req_completion, ucx_req);
11321129

11331130
if (ret != OMPI_SUCCESS) {
1134-
OMPI_OSC_UCX_REQUEST_RETURN(ucx_req);
1135-
return ret;
1136-
11371131
/* fallback to using an atomic op to acquire a request handle */
11381132
ret = opal_common_ucx_wpmem_fence(mem);
11391133
if (ret != OMPI_SUCCESS) {

0 commit comments

Comments
 (0)