From a7bc3ed39179a4f6ff0493138c8281d7857c8b07 Mon Sep 17 00:00:00 2001 From: Stan Moore Date: Fri, 15 Dec 2017 13:30:17 -0700 Subject: [PATCH] Add missing fences in comm_kokkos --- src/KOKKOS/comm_kokkos.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/KOKKOS/comm_kokkos.cpp b/src/KOKKOS/comm_kokkos.cpp index 03b3074eb1..de35431eb9 100644 --- a/src/KOKKOS/comm_kokkos.cpp +++ b/src/KOKKOS/comm_kokkos.cpp @@ -324,6 +324,7 @@ void CommKokkos::reverse_comm_device() size_reverse_recv[iswap],MPI_DOUBLE, sendproc[iswap],0,world,&request); n = avec->pack_reverse_kokkos(recvnum[iswap],firstrecv[iswap],k_buf_send); + DeviceType::fence(); if (n) MPI_Send(k_buf_send.view().ptr_on_device(),n, MPI_DOUBLE,recvproc[iswap],0,world); @@ -331,6 +332,7 @@ void CommKokkos::reverse_comm_device() } avec->unpack_reverse_kokkos(sendnum[iswap],k_sendlist,iswap, k_buf_recv); + DeviceType::fence(); } else { if (sendnum[iswap]) n = avec->unpack_reverse_self(sendnum[iswap],k_sendlist,iswap, @@ -933,7 +935,6 @@ void CommKokkos::borders_device() { "implemented with Kokkos"); n = avec->pack_border_vel(nsend,sendlist[iswap],buf_send, pbc_flag[iswap],pbc[iswap]); - DeviceType::fence(); } else { n = avec->