Changeset 2547 for XIOS3/trunk/src/node/pool_node.cpp

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/node/pool_node.cpp (modified) (2 diffs)

XIOS3/trunk/src/node/pool_node.cpp

@@ -1 +1 @@
 #include "pool_node.hpp"
 #include "cxios.hpp"
+#include "thread_manager.hpp"
 #include<cmath>
 
@@ -61 +62 @@
     else ERROR("void CPoolNode::allocateRessources(void)",<<"Pool has no name or id, attributes <id> or <name> must be specified")
     ressourcesManager->createPool(poolId, nbRessources) ;
-    ressourcesManager->waitPoolRegistration(poolId) ;
+    if (CThreadManager::isUsingThreads()) 
+      while(!ressourcesManager->hasPool(CXios::defaultPoolId)) 
+      {
+        CXios::getDaemonsManager()->eventLoop() ;
+        CThreadManager::yield() ;
+      }
+    else ressourcesManager->waitPoolRegistration(poolId) ;
     auto services=this->getAllServiceNodes() ;
     for(auto& service : services) service->allocateRessources(poolId) ;