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

Bug fix to detection case

This commit is contained in:
Peter Boyle 2022-02-15 10:27:39 -05:00
parent e83f6a6ae9
commit fad5a74a4b

View File

@ -601,6 +601,7 @@ public:
obj.recv_buf = recv_buf; obj.recv_buf = recv_buf;
obj.bytes = bytes; obj.bytes = bytes;
obj.lane = lane; obj.lane = lane;
for(int i=0;i<CachedTransfers.size();i++){ for(int i=0;i<CachedTransfers.size();i++){
if ( (CachedTransfers[i].direction ==direction) if ( (CachedTransfers[i].direction ==direction)
&&(CachedTransfers[i].OrthogPlane==OrthogPlane) &&(CachedTransfers[i].OrthogPlane==OrthogPlane)
@ -611,12 +612,11 @@ public:
std::cout << "Found duplicate copy plane dir "<<direction<<" plane "<< OrthogPlane<< " simd "<<lane << " relproc "<<DestProc<<std::endl; std::cout << "Found duplicate copy plane dir "<<direction<<" plane "<< OrthogPlane<< " simd "<<lane << " relproc "<<DestProc<<std::endl;
AddCopy(CachedTransfers[i].recv_buf,recv_buf,bytes); AddCopy(CachedTransfers[i].recv_buf,recv_buf,bytes);
return 1; return 1;
} else {
std::cout << "No duplicate plane dir "<<direction<<" plane "<< OrthogPlane<< " simd "<<lane << " relproc "<<DestProc<<std::endl;
CachedTransfers.push_back(obj);
return 0;
} }
} }
std::cout << "No duplicate plane dir "<<direction<<" plane "<< OrthogPlane<< " simd "<<lane << " relproc "<<DestProc<<std::endl;
CachedTransfers.push_back(obj);
return 0; return 0;
} }
void AddPacket(void *xmit,void * rcv, Integer to,Integer from,Integer bytes){ void AddPacket(void *xmit,void * rcv, Integer to,Integer from,Integer bytes){