Changeset 1518 for XIOS/dev/branch_openmp/extern/ep_dev/ep_recv.cpp

Timestamp:

06/01/18 19:36:12 (6 years ago)

Author:

yushan

Message:

optimisation partially finished. To do : special case for intercomm_create and intercomm_merge

File:

• XIOS/dev/branch_openmp/extern/ep_dev/ep_recv.cpp (modified) (1 diff)

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

@@ -65 +65 @@
     EP_PendingRequests->push_back(request);  
     int ep_rank = comm->ep_comm_ptr->size_rank_info[0].first;
-    memcheck("EP_PendingRequests["<<ep_rank<<"]->size() = " << EP_PendingRequests->size());                                                              
-                                          
+    memcheck("EP_PendingRequests["<<ep_rank<<"]->size() = " << EP_PendingRequests->size());    
+
+#ifdef _showinfo
+    if(comm->is_intercomm)
+    {
+      int ep_dest_loc  = comm->ep_rank_map->at(dest_rank).first;
+      int ep_src_loc = comm->ep_comm_ptr->intercomm->intercomm_rank_map->at(src).first;
+      int mpi_tag     = tag_combine(tag, ep_src_loc, ep_dest_loc);
+      int mpi_dest    = comm->ep_comm_ptr->intercomm->intercomm_rank_map->at(src).second.first;
+
+      printf("Irecv : ep_src_loc = %d, ep_dest_loc = %d, mpi_src = %d, mpi_dest = %d, mpi_tag = %d\n", ep_src_loc, ep_dest_loc, comm->ep_comm_ptr->size_rank_info[2].first, mpi_dest, mpi_tag);
+    }                                                          
+#endif                                      
+
     return Request_Check();
   }