portelli/Grid
1
0
Fork 0
mirror of https://github.com/paboyle/Grid.git synced 2025-04-09 21:50:45 +01:00
Code Releases Activity

BUg fix, wait till complete.

Browse Source
This commit is contained in:
Peter Boyle 2016-02-14 16:21:21 -06:00
parent 41c2b09184
commit 42a9ac71d2
1 changed files with 21 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lib/Stencil.h
View File

@ -112,7 +112,24 @@ namespace Grid {
comms_bytes+=2.0*bytes; comms_bytes+=2.0*bytes;
Packets.push_back(p); Packets.push_back(p);
} }
/*
void Communicate(void ) {
// typedef CartesianCommunicator::CommsRequest_t CommsRequest_t;
// std::vector<CommsRequest_t> reqs(0);
commtime-=usecond();
for(int i=0;i<Packets.size();i++){
_grid->SendToRecvFrom(
Packets[i].send_buf,
Packets[i].to_rank,
Packets[i].recv_buf,
Packets[i].from_rank,
Packets[i].bytes);
Packets[i].done = 1;
}
// _grid->SendToRecvFromComplete(reqs);
commtime+=usecond();
}
*/
void Communicate(void ) { void Communicate(void ) {
typedef CartesianCommunicator::CommsRequest_t CommsRequest_t; typedef CartesianCommunicator::CommsRequest_t CommsRequest_t;
std::vector<CommsRequest_t> reqs(0); std::vector<CommsRequest_t> reqs(0);
@ -124,10 +141,12 @@ namespace Grid {
Packets[i].recv_buf, Packets[i].recv_buf,
Packets[i].from_rank, Packets[i].from_rank,
Packets[i].bytes); Packets[i].bytes);
Packets[i].done = 1;
} }
_grid->SendToRecvFromComplete(reqs); _grid->SendToRecvFromComplete(reqs);
commtime+=usecond(); commtime+=usecond();
for(int i=0;i<Packets.size();i++){
Packets[i].done = 1;
}
} }
/////////////////////////////////////////// ///////////////////////////////////////////