Salome HOME
add method NameChanged to update title name
[modules/kernel.git] / src / ResourcesManager / SALOME_LoadRateManager.cxx
index ab5aa4d88554f66909c83dc8c0b34dfeec365f70..c5028ba07face718d88525d0fbbecf313c7fda2e 100644 (file)
@@ -1,9 +1,95 @@
+// Copyright (C) 2007-2016  CEA/DEN, EDF R&D, OPEN CASCADE
+//
+// Copyright (C) 2003-2007  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
+// CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
+//
+// This library is free software; you can redistribute it and/or
+// modify it under the terms of the GNU Lesser General Public
+// License as published by the Free Software Foundation; either
+// version 2.1 of the License, or (at your option) any later version.
+//
+// This library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+// Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public
+// License along with this library; if not, write to the Free Software
+// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
+//
+// See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
+//
+
 #include "SALOME_LoadRateManager.hxx"
+#include <iostream>
+#include <map>
+
+std::string LoadRateManagerFirst::Find(const std::vector<std::string>& hosts,
+                                       const MapOfParserResourcesType& resList)
+{
+  if (hosts.size() == 0)
+    return std::string("");
+
+  return std::string(hosts[0]);
+}
+
+std::string LoadRateManagerCycl::Find(const std::vector<std::string>& hosts,
+                                      const MapOfParserResourcesType& resList)
+{
+  static int imachine = 0;
+  static int iproc = 0;
 
-using namespace std;
+  // if empty list return empty string
+  if (hosts.size() == 0)
+    return std::string("");
+  else{
+    MapOfParserResourcesType::const_iterator it(resList.find(hosts[imachine]));
+    ParserResourcesType resource;
+    if(it!=resList.end())
+      resource = (*it).second;
+    int nbproc = resource.DataForSort._nbOfProcPerNode * resource.DataForSort._nbOfNodes;
+    if( nbproc <= 0) nbproc = 1;
+    if( iproc < nbproc ){
+      iproc++;
+      return std::string(hosts[imachine]);
+    }
+    else{
+      iproc = 1;
+      imachine++;
+      if(imachine >= (int)hosts.size())
+        imachine = 0;
+      return std::string(hosts[imachine]);
+    }
+  }
+}
 
-string SALOME_LoadRateManager::FindBest(const Engines::MachineList& hosts)
+std::string LoadRateManagerAltCycl::Find(const std::vector<std::string>& hosts,
+                                         const MapOfParserResourcesType& resList)
 {
-  // for the moment then "maui" will be used for dynamic selection ...
-  return string(hosts[0]);
+  if (hosts.size() == 0)
+    return std::string("");
+
+  std::string selected=hosts[0];
+  int uses=0;
+  if(_numberOfUses.count(selected) != 0)
+    uses=_numberOfUses[selected];
+  else
+    uses=0;
+
+  for (std::vector<std::string>::const_iterator iter = hosts.begin(); iter != hosts.end(); iter++)
+    {
+      std::string machine=*iter;
+      if(_numberOfUses.count(machine) == 0)
+        _numberOfUses[machine]=0;
+      if(_numberOfUses[machine] < uses)
+        {
+          selected=machine;
+          uses=_numberOfUses[machine];
+        }
+    }
+
+  _numberOfUses[selected]=_numberOfUses[selected]+1;
+  //std::cerr << "selected: " << selected << " " << _numberOfUses[selected] << std::endl;
+  return selected;
 }
+