Changeset 2260 for XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp

Timestamp:

11/19/21 15:41:40 (3 years ago)

Author:

ymipsl

Message:

Improvment of one sided protocol

• removed latency
• solve dead-lock

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp (modified) (4 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/context_server.cpp

@@ -166 +166 @@
         MPI_Win_create_dynamic(MPI_INFO_NULL, winComm_[rank], &windows_[rank][1]);
         CTimer::get("create Windows").suspend() ;
+        MPI_Barrier(winComm_[rank]) ;
       }
       else
@@ -302 +303 @@
         buffers[rank]->notifyBufferResizing() ;
         buffers[rank]->updateCurrentWindows() ;
+        info(100)<<"Receive NotifyChangeBufferSize from client rank "<<rank<<endl ;
       } 
       else if (timeLine==timelineEventChangeBufferSize)
@@ -310 +312 @@
         buffers.erase(rank) ;
         buffers.insert(pair<int,CServerBuffer*>(rank,new CServerBuffer(windows_[rank], winAdress, 0, newSize)));
+        info(100)<<"Receive ChangeBufferSize from client rank "<<rank<<"  newSize : "<<newSize<<" Address : "<<winAdress[0]<<" & "<<winAdress[1]<<endl ;
       }
       else
       {
+        info(100)<<"Receive standard event from client rank "<<rank<<"  with timeLine : "<<timeLine<<endl ;
         it=events.find(timeLine);
         if (it==events.end()) it=events.insert(pair<int,CEventServer*>(timeLine,new CEventServer(this))).first;
@@ -391 +395 @@
       else if (pendingRequest.empty()) getBufferFromClient(currentTimeLine) ;
     }
-    else if (pureOneSided) getBufferFromClient(currentTimeLine) ; // if pure one sided check buffer even if no event recorded at current time line
+    else if (pendingRequest.empty()) getBufferFromClient(currentTimeLine) ; // if pure one sided check buffer even if no event recorded at current time line
   }