Changeset 2453 for XIOS3/dev/XIOS_FILE_SERVICES/src/node/pool_node.cpp

Timestamp:

01/03/23 19:06:42 (18 months ago)

Author:

ymipsl

Message:

Implementation of files service on dev branch

YM

File:

• XIOS3/dev/XIOS_FILE_SERVICES/src/node/pool_node.cpp (modified) (3 diffs)

XIOS3/dev/XIOS_FILE_SERVICES/src/node/pool_node.cpp

@@ -1 +1 @@
 #include "pool_node.hpp"
+#include "cxios.hpp"
+#include<cmath>
 
 namespace xios
@@ -5 +7 @@
   
   CPoolNode::CPoolNode(void) : CObjectTemplate<CPoolNode>(), CPoolNodeAttributes()
-  { /* Ne rien faire de plus */ }
+  { 
+    setVirtualServiceNodeGroup(CServiceNodeGroup::create(getId() + "_virtual_service_node_group"));
+  }
 
   CPoolNode::CPoolNode(const StdString & id) : CObjectTemplate<CPoolNode>(id), CPoolNodeAttributes()
-  { /* Ne rien faire de plus */ }
+  { 
+    setVirtualServiceNodeGroup(CServiceNodeGroup::create(getId() + "_virtual_service_node_group"));
+  }
 
   CPoolNode::~CPoolNode(void)
@@ -17 +23 @@
   {
     SuperClass::parse(node);
+    if (node.goToChildElement())
+    {
+      do
+      {
+        if (node.getElementName()=="service" || node.getElementName()=="service_group") this->getVirtualServiceNodeGroup()->parseChild(node);
+      } while (node.goToNextElement());
+      node.goToParentElement();
+    }
   }
 
-
+  void CPoolNode::allocateRessources(void)
+  {
+    int nonEmpty=0 ;
+    if (!nprocs.isEmpty()) nonEmpty++ ;
+    if (!global_fraction.isEmpty()) nonEmpty++ ;
+    if (!remain_fraction.isEmpty()) nonEmpty++ ;
+    if (!remain.isEmpty()) nonEmpty++ ;
+    if (nonEmpty==0) ERROR("void CPoolNode::allocateRessources(void)",<<"A number a ressource for allocate pool must be specified." 
+                           <<"At least attributes, <nprocs> or <global_fraction> or <remain_fraction> or <remain> must be specified")
+    else if (nonEmpty>1) ERROR("void CPoolNode::allocateRessources(void)",<<"Only one of these attributes : <nprocs> or <global_fraction>"
+                               <<" or <remain_fraction> or <remain> must be specified to determine allocated ressouces."
+                               <<" More than one is currently specified")
+    auto ressourcesManager=CXios::getRessourcesManager() ;
+    int nbRessources ;
+    int globalRessources = ressourcesManager->getRessourcesSize() ;
+    int freeRessources =   ressourcesManager->getFreeRessourcesSize() ;
+    if (!nprocs.isEmpty()) nbRessources = nprocs ;
+    if (!global_fraction.isEmpty()) nbRessources = std::round(globalRessources * global_fraction) ;
+    if (!remain_fraction.isEmpty()) nbRessources = std::round(freeRessources * remain_fraction) ;
+    if (!remain.isEmpty()) nbRessources = freeRessources ;
+    if (nbRessources>freeRessources)
+      ERROR("void CPoolNode::allocateRessources(void)",<<"Cannot allocate required ressources for the pool."
+                                                       <<"  Required is : "<<nbRessources<<"  but free ressource is currently : "<<freeRessources)
+    string poolId ;
+    if (!name.isEmpty()) poolId=name ;
+    else if (!hasAutoGeneratedId() ) poolId=getId() ;
+    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) ;
+    auto services=this->getAllServiceNodes() ;
+    for(auto& service : services) service->allocateRessources(poolId) ;
+  }
 }