Changeset 2258 for XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/ressources_manager.cpp

Timestamp:

11/16/21 17:37:42 (3 years ago)

Author:

ymipsl

Message:

One sided protocol improvment.
YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/ressources_manager.cpp (modified) (2 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/manager/ressources_manager.cpp

@@ -72 +72 @@
   void CRessourcesManager::sendNotification(int rank)
   {
-    winNotify_->lockWindow(rank,0) ;
-    winNotify_->pushToWindow(rank, this, &CRessourcesManager::notificationsDumpOut) ;
-    winNotify_->unlockWindow(rank,0) ;
+    winNotify_->lockWindowExclusive(rank) ;
+    winNotify_->pushToLockedWindow(rank, this, &CRessourcesManager::notificationsDumpOut) ;
+    winNotify_->unlockWindow(rank) ;
   }
 
@@ -128 +128 @@
     MPI_Comm_rank(xiosComm_, &commRank) ;
     CTimer::get("CRessourcesManager::checkNotifications lock").resume();
-    winNotify_->lockWindow(commRank,0) ;
+    winNotify_->lockWindowExclusive(commRank) ;
     CTimer::get("CRessourcesManager::checkNotifications lock").suspend();
     CTimer::get("CRessourcesManager::checkNotifications pop").resume();
-    winNotify_->popFromWindow(commRank, this, &CRessourcesManager::notificationsDumpIn) ;
+    winNotify_->popFromLockedWindow(commRank, this, &CRessourcesManager::notificationsDumpIn) ;
     CTimer::get("CRessourcesManager::checkNotifications pop").suspend();
     CTimer::get("CRessourcesManager::checkNotifications unlock").resume();
-    winNotify_->unlockWindow(commRank,0) ;
+    winNotify_->unlockWindow(commRank) ;
     CTimer::get("CRessourcesManager::checkNotifications unlock").suspend();
     if (notifyType_==NOTIFY_CREATE_POOL) createPool() ;