Skip to content

Commit f4adf5f

Browse files
committed
got rid of atomic timestamp store
1 parent e72704a commit f4adf5f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tests/examples/test_load_latency.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def ping_pong(
3737
for i in range(niter + skip):
3838
if i == skip:
3939
start = read_realtime()
40-
tl.atomic_xchg(mm_begin_timestamp_ptr + peer_rank * BLOCK_SIZE + offsets, start, time_stmp_mask)
40+
tl.store(mm_begin_timestamp_ptr + peer_rank * BLOCK_SIZE + offsets, start, time_stmp_mask)
4141
first_rank = tl.minimum(curr_rank, peer_rank) if (i % 2) == 0 else tl.maximum(curr_rank, peer_rank)
4242
token_first_done = i + 1
4343
token_second_done = i + 2
@@ -53,7 +53,7 @@ def ping_pong(
5353
iris.store(flag + offsets, token_second_done, curr_rank, peer_rank, heap_bases, flag_mask)
5454

5555
stop = read_realtime()
56-
tl.atomic_xchg(mm_end_timestamp_ptr + peer_rank * BLOCK_SIZE + offsets, stop, time_stmp_mask)
56+
tl.store(mm_end_timestamp_ptr + peer_rank * BLOCK_SIZE + offsets, stop, time_stmp_mask)
5757

5858

5959
if __name__ == "__main__":

0 commit comments

Comments
 (0)