Changeset 1522 for XIOS/dev/branch_openmp/extern/ep_dev/main.cpp

Timestamp:

06/05/18 19:14:40 (6 years ago)

Author:

yushan

Message:

Test_client 6*8 clients 2 servers OK. TO DO : intercomm->intracomm, comm_free_intercomm

File:

• XIOS/dev/branch_openmp/extern/ep_dev/main.cpp (modified) (4 diffs)

XIOS/dev/branch_openmp/extern/ep_dev/main.cpp

@@ -852 +852 @@
 
       if(rank == 0) printf("            \t Test iP2P for intercomm \t OK\n");
+      
+      
 
 
@@ -888 +890 @@
       MPI_Comm_size(inter_comm_dup_merged, &inter_comm_dup_merged_size);
 
-      printf("rank = %d, inter_comm_dup_merged_rank = %d, inter_comm_dup_merged_size = %d\n", rank, inter_comm_dup_merged_rank, inter_comm_dup_merged_size);
+      //printf("rank = %d, inter_comm_dup_merged_rank = %d, inter_comm_dup_merged_size = %d\n", rank, inter_comm_dup_merged_rank, inter_comm_dup_merged_size);
+      
+      // TEST OF TESTALL
+      
+        int merged_size, merged_rank;
+        MPI_Comm_rank(inter_comm_dup_merged, &merged_rank);
+        MPI_Comm_size(inter_comm_dup_merged, &merged_size);
+        
+        int left = merged_rank>0? merged_rank-1 : merged_size-1;
+        int right = (merged_rank+1) % merged_size;
+        
+        //printf("rank = %d, left = %d, right = %d\n", merged_rank, left, right);
+        
+        int N=10000;
+        int *left_buf = new int[N];
+        int *right_buf = new int[N];
+                
+        for(int i=0; i<N; i++)
+        {
+          right_buf[i] = merged_rank*100000+i;
+        }
+        
+        MPI_Request request[2];
+        MPI_Status status[2];
+        
+        MPI_Irecv(left_buf, N, MPI_INT, left, 0, inter_comm_dup_merged, &request[0]);
+        MPI_Isend(right_buf, N, MPI_INT, right, 0, inter_comm_dup_merged, &request[1]);
+        
+        
+        int flag;
+        MPI_Testall(2, request, &flag, status);
+      
+        printf("rank = %d, flag = %d\n", merged_rank, flag);
+        
+        while(!flag) MPI_Testall(2, request, &flag, status);
+        //if(!flag)  MPI_Waitall(2, request, status);
+        
+        int recv_count;
+        MPI_Get_count(&status[0], MPI_INT, &recv_count);
+        
+        MPI_Barrier(inter_comm_dup_merged);
+        
+        printf("rank = %d, recv_count = %d, left_buf[5-10] = %d\t%d\t%d\t%d\t%d\t%d\n", merged_rank, recv_count, left_buf[5], left_buf[6], left_buf[7], left_buf[8], left_buf[9], left_buf[10]);
+                        
+        delete[] left_buf;
+        delete[] right_buf;
+      
+      
 
       // TEST OF GATHER
@@ -961 +1010 @@
 
       // TEST OF EXSCAN
-      {
+      /*{
  
         std::vector<int>sendbuf(2, inter_comm_dup_merged_rank);
@@ -988 +1037 @@
         if(inter_comm_dup_merged_rank == 0 && exscan_result)  printf("            \t test MPI_Exscan for merged comm \t OK\n");
         if(inter_comm_dup_merged_rank == 0 && !exscan_result) printf("            \t test MPI_Exscan for merged comm \t FAILED %d\n", exscan_result);
-      }
+      }*/
 
       // TEST OF SCATTERV