Changeset 1533 for XIOS/dev/branch_openmp/src

Timestamp:

06/08/18 19:34:51 (6 years ago)

Author:

yushan

Message:

save dev

Location:

XIOS/dev/branch_openmp/src

Files:

• cxios.cpp (modified) (1 diff)
• event_scheduler.cpp (modified) (1 diff)
• server.cpp (modified) (2 diffs)

XIOS/dev/branch_openmp/src/cxios.cpp

@@ -107 +107 @@
       MPI_Comm *ep_comm;
       MPI_Comm_create_endpoints(MPI_COMM_WORLD->mpi_comm, num_ep, info, ep_comm);  // servers should reach here too.
-      passage = ep_comm;  
+      passage = ep_comm; 
+      EP_group_init();
+      //::MPI_Comm_group(to_mpi_comm(MPI_COMM_WORLD->mpi_comm), &MPI_GROUP_WORLD); 
     }
         

XIOS/dev/branch_openmp/src/event_scheduler.cpp

@@ -140 +140 @@
       if (received)
       {
-        printf("probed a message coming from parent\n"),
         recvRequest=new SPendingRequest ;
         MPI_Irecv(recvRequest->buffer, 3, MPI_UNSIGNED_LONG, -2, 1, communicator, &(recvRequest->request)) ;

XIOS/dev/branch_openmp/src/server.cpp

@@ -658 +658 @@
          MPI_Get_count(&status,MPI_CHAR,&(counts.back())) ;
          buffers.push_back(new char[counts.back()]) ;
+         //requests.push_back(request);
+         //MPI_Irecv((void*)(buffers.back()),counts.back(),MPI_CHAR,root,2,intraComm,&(requests.back())) ;
+         MPI_Irecv((void*)(buffers.back()),counts.back(),MPI_CHAR,root,2,intraComm,&request) ;
          requests.push_back(request);
-         MPI_Irecv((void*)(buffers.back()),counts.back(),MPI_CHAR,root,2,intraComm,&(requests.back())) ;
          isEventRegistered.push_back(false);
          isEventQueued.push_back(false);
@@ -668 +670 @@
        {
          // (2) If context id is received, register an event
-         MPI_Test(&requests[ctxNb],&flag,&status) ;
+         if(!isEventRegistered[ctxNb]) MPI_Test(&requests[ctxNb],&flag,&status) ;
          if (flag==true && !isEventRegistered[ctxNb])
          {