Changeset 1164 for XIOS/dev/branch_yushan_merged/src/client_client_dht_template_impl.hpp

Timestamp:

06/08/17 17:31:50 (7 years ago)

Author:

yushan

Message:

Bug fixed in MPI_(All)Gatherv with displs

File:

• XIOS/dev/branch_yushan_merged/src/client_client_dht_template_impl.hpp (modified) (4 diffs)

XIOS/dev/branch_yushan_merged/src/client_client_dht_template_impl.hpp

@@ -710 +710 @@
   std::vector<ep_lib::MPI_Status> requestStatus(sendBuffSize+recvBuffSize);
 
+  int my_rank;
+  MPI_Comm_rank(this->internalComm_, &my_rank);
+  
   int nRequest = 0;
   for (int idx = 0; idx < recvBuffSize; ++idx)
@@ -715 +718 @@
     MPI_Irecv(&recvBuff[0]+2*idx, 2, MPI_INT,
               recvRank[idx], MPI_DHT_INDEX_0, this->internalComm_, &request[nRequest]);
+    printf("proc %d recv from proc %d with tag %d\n", my_rank, recvRank[idx], MPI_DHT_INDEX_0);          
     ++nRequest;
   }
@@ -724 +728 @@
     sendBuff[idx*2+1] = sendNbElements[offSet];
   }
+  
+  
 
   for (int idx = 0; idx < sendBuffSize; ++idx)
@@ -729 +735 @@
     MPI_Isend(&sendBuff[idx*2], 2, MPI_INT,
               sendRank[idx], MPI_DHT_INDEX_0, this->internalComm_, &request[nRequest]);
+    printf("proc %d send to proc %d with tag %d\n", my_rank, sendRank[idx], MPI_DHT_INDEX_0);
     ++nRequest;
   }