Changeset 1601 for XIOS/dev/dev_trunk_omp/src/event_scheduler.cpp

Timestamp:

11/19/18 15:52:54 (5 years ago)

Author:

yushan

Message:

branch_openmp merged with trunk r1597

File:

• XIOS/dev/dev_trunk_omp/src/event_scheduler.cpp (modified) (3 diffs)

XIOS/dev/dev_trunk_omp/src/event_scheduler.cpp

@@ -3 +3 @@
 #include "mpi.hpp"
 #include "tracer.hpp"
+
+using namespace ep_lib;
 
 namespace xios
@@ -135 +137 @@
     while(received)
     {
-      MPI_Iprobe(MPI_ANY_SOURCE,1,communicator,&received, &status) ;
+      MPI_Iprobe(-2,1,communicator,&received, &status) ;
       if (received)
       {
         recvRequest=new SPendingRequest ;
-        MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, MPI_ANY_SOURCE, 1, communicator, &(recvRequest->request)) ;
+        MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, -2, 1, communicator, &(recvRequest->request)) ;
         pendingRecvParentRequest.push(recvRequest) ;
       }
@@ -177 +179 @@
     while(received)
     {
-      MPI_Iprobe(MPI_ANY_SOURCE,0,communicator,&received, &status) ;
+      MPI_Iprobe(-2,0,communicator,&received, &status) ;
       if (received)
       {
         recvRequest=new SPendingRequest ;
-        MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, MPI_ANY_SOURCE, 0, communicator, &recvRequest->request) ;
+        MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, -2, 0, communicator, &recvRequest->request) ;
         pendingRecvChildRequest.push_back(recvRequest) ;
       }