Changeset 2260 for XIOS/dev/dev_ym/XIOS_COUPLING/src/context_client.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_client.cpp (modified) (4 diffs)

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

@@ -118 +118 @@
     {
       list<int> ranks = event.getRanks();
-      info(100)<<"Event "<<timeLine<<" of context "<<context_->getId()<<endl ;
+ 
+//      ostringstream str ;
+//      for(auto& rank : ranks) str<<rank<<" ; " ;
+//      info(100)<<"Event "<<timeLine<<" of context "<<context_->getId()<<"  for ranks : "<<str.str()<<endl ;
+
       if (CXios::checkEventSync)
       {
@@ -165 +169 @@
 
         unlockBuffers(ranks) ;
-        info(100)<<"Event "<<timeLine<<" of context "<<context_->getId()<<"  sent"<<endl ;
-          
         checkBuffers(ranks);
+        
       }
       
@@ -346 +349 @@
       }
       buffer->attachWindows(windows_[rank]) ;
+      if (!isAttachedModeEnabled()) MPI_Barrier(winComm_[rank]) ;
+       
    }
 
@@ -525 +530 @@
   }
   
+  bool CContextClient::havePendingRequests(list<int>& ranks)
+  {
+      list<int>::iterator it;
+      bool pending = false;
+      for (it = ranks.begin(); it != ranks.end(); it++) pending |= buffers[*it]->hasPendingRequest();
+      return pending;
+  }
+
   bool CContextClient::isNotifiedFinalized(void)
   {