Skip to content

Commit b942a02

Browse files
committed
Reverting unecessary change in portals
1 parent 580f7ae commit b942a02

File tree

1 file changed

+2
-28
lines changed

1 file changed

+2
-28
lines changed

src/transport_portals4.h

Lines changed: 2 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1063,34 +1063,8 @@ shmem_transport_fetch_atomic_nbi(shmem_transport_ctx_t* ctx, void *target,
10631063
size_t len, int pe, ptl_op_t op,
10641064
ptl_datatype_t datatype)
10651065
{
1066-
int ret;
1067-
ptl_pt_index_t pt;
1068-
long offset;
1069-
ptl_process_t peer;
1070-
1071-
peer.rank = pe;
1072-
PORTALS4_GET_REMOTE_ACCESS(target, pt, offset);
1073-
1074-
shmem_internal_assert(len <= shmem_transport_portals4_max_fetch_atomic_size);
1075-
shmem_internal_assert(len <= shmem_transport_portals4_max_volatile_size);
1076-
1077-
shmem_internal_cntr_inc(&ctx->pending_get_cntr);
1078-
1079-
/* Issue a non-blocking fetch atomic */
1080-
ret = PtlFetchAtomic(ctx->get_md,
1081-
(ptl_size_t) dest,
1082-
ctx->put_volatile_md,
1083-
(ptl_size_t) source,
1084-
len,
1085-
peer,
1086-
pt,
1087-
0,
1088-
offset,
1089-
NULL,
1090-
0,
1091-
op,
1092-
SHMEM_TRANSPORT_DTYPE(datatype));
1093-
if (PTL_OK != ret) { RAISE_ERROR(ret); }
1066+
/* transport_fetch_atomic already buffers the source argument */
1067+
shmem_transport_fetch_atomic(ctx, target, source, dest, len, pe, op, datatype);
10941068
}
10951069

10961070

0 commit comments

Comments
 (0)