ICODE-ADC/lammps
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add Kokkos threaded reverse comm option

Browse Source
This commit is contained in:
Stan Moore
2017-10-03 10:14:24 -06:00
parent 529eeb6039
commit ca032f21fb
17 changed files with 748 additions and 1850 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/comm_brick.cpp
View File

@ -476,8 +476,7 @@ void CommBrick::forward_comm(int dummy)
if (sendproc[iswap] != me) {
if (comm_x_only) {
if (size_forward_recv[iswap]) {
if (size_forward_recv[iswap]) buf = x[firstrecv[iswap]];
else buf = NULL;
buf = x[firstrecv[iswap]];
MPI_Irecv(buf,size_forward_recv[iswap],MPI_DOUBLE,
recvproc[iswap],0,world,&request);
}
@ -547,8 +546,7 @@ void CommBrick::reverse_comm()
MPI_Irecv(buf_recv,size_reverse_recv[iswap],MPI_DOUBLE,
sendproc[iswap],0,world,&request);
if (size_reverse_send[iswap]) {
if (size_reverse_send[iswap]) buf = f[firstrecv[iswap]];
else buf = NULL;
buf = f[firstrecv[iswap]];
MPI_Send(buf,size_reverse_send[iswap],MPI_DOUBLE,
recvproc[iswap],0,world);
}