Changeset 2547 for XIOS3/trunk/src/manager/token_manager.hpp

Timestamp:

08/29/23 17:24:04 (10 months ago)

Author:

ymipsl

Message:

Major update :

• New method to lock and unlock one-sided windows (window_dynamic) to avoid network overhead
• Introducing multithreading on server sided to manage more efficiently dead-lock occuring (similar to co-routine which will be available and implemented in futur c++ standard), based on c++ threads
• Suprression of old "attached mode" which is replaced by online writer and reder filters

YM

File:

• XIOS3/trunk/src/manager/token_manager.hpp (modified) (2 diffs)

XIOS3/trunk/src/manager/token_manager.hpp

@@ -26 +26 @@
           memset( winBufferRetrieved_, 0, windowSize );
         }
+        MPI_Win_lock_all(0, winCurrentToken_) ;
+        MPI_Win_lock_all(0, winRetrievedToken_) ;
       }
-
+      
+      ~CTokenManager()
+      {
+        MPI_Win_unlock_all(winCurrentToken_) ;
+        MPI_Win_unlock_all(winRetrievedToken_) ;
+        MPI_Win_free(&winCurrentToken_) ;
+        MPI_Win_free(&winRetrievedToken_) ;
+      }
+      
       size_t getToken(void)
       {
         size_t inc=1 ;
         size_t token ;
-        MPI_Win_lock(MPI_LOCK_EXCLUSIVE, leader_, 0, winCurrentToken_) ;
         MPI_Fetch_and_op(&inc, &token, MPI_SIZE_T, leader_, 0, MPI_SUM, winCurrentToken_) ;
-        MPI_Win_unlock(leader_, winCurrentToken_) ;
+        MPI_Win_flush(leader_, winCurrentToken_);
         return token ;
       }
 
-      bool lockToken(size_t token)
+      bool checkToken(size_t token)
       {
         size_t tokenRead ;
-        MPI_Win_lock(MPI_LOCK_SHARED, leader_, 0, winRetrievedToken_) ;
-        MPI_Get(&tokenRead, 1, MPI_SIZE_T, leader_, 0, 1, MPI_SIZE_T, winRetrievedToken_ ) ;
-        MPI_Win_unlock(leader_, winRetrievedToken_) ;
-        if (token==tokenRead) return true ;
-        else return false ;
+        size_t inc=0 ;
+        MPI_Fetch_and_op(&inc, &tokenRead, MPI_SIZE_T, leader_, 0, MPI_NO_OP, winRetrievedToken_) ;
+        MPI_Win_flush(leader_, winRetrievedToken_);
+        return tokenRead==token ;
       }
-
-      void unlockToken(size_t token)
+      
+      void updateToken(size_t token)
+      {
+        size_t inc=1 ;
+        size_t tokenRead ;
+        MPI_Fetch_and_op(&inc, &tokenRead, MPI_SIZE_T, leader_, 0, MPI_SUM, winRetrievedToken_) ;
+        MPI_Win_flush(leader_, winRetrievedToken_);
+        if (token!=tokenRead)  ERROR("void CTokenManager::unlockToken(size_t token)",<<"Cannot release token="<<token<<
+                                     " that is not corresponding to the locked token="<<tokenRead) ;     
+      }
+/*      void unlockToken(size_t token)
       {
         size_t inc=1 ;
@@ -59 +76 @@
                                      " that is not corresponding to the locked token="<<tokenRead) ;     
       }
-
+*/
     private: