[Erp5-report] r45934 guillaume.bottex - /slapos/trunk/util/slapos.tool.nosqltester_manager....

[nobody at svn.erp5.org]

Author: guillaume.bottex
Date: Tue Jun 21 15:56:00 2011
New Revision: 45934

URL: http://svn.erp5.org?rev=45934&view=rev
Log:
Adding ERP5 add tester method.

Modified:
    slapos/trunk/util/slapos.tool.nosqltester_manager.erp5/src/slapos/tool/nosqltester_manager/erp5/__init__.py

Modified: slapos/trunk/util/slapos.tool.nosqltester_manager.erp5/src/slapos/tool/nosqltester_manager/erp5/__init__.py
URL: http://svn.erp5.org/slapos/trunk/util/slapos.tool.nosqltester_manager.erp5/src/slapos/tool/nosqltester_manager/erp5/__init__.py?rev=45934&r1=45933&r2=45934&view=diff
==============================================================================
--- slapos/trunk/util/slapos.tool.nosqltester_manager.erp5/src/slapos/tool/nosqltester_manager/erp5/__init__.py [utf8] (original)
+++ slapos/trunk/util/slapos.tool.nosqltester_manager.erp5/src/slapos/tool/nosqltester_manager/erp5/__init__.py [utf8] Tue Jun 21 15:56:00 2011
@@ -35,6 +35,7 @@ class ERP5ScalabilityTesterManager(NoSQL
   def __init__(self, params):
     NoSQLTesterManager.__init__(self, params)
     
+    self.node_type = "tester"
     self.host_address = params['address']
     
     #argv = sys.argv[16:]
@@ -52,7 +53,7 @@ class ERP5ScalabilityTesterManager(NoSQL
                                            'repeat':self.computer_partition.getConnectionParameter('repeat'),
                                            'nb_users':self.computer_partition.getConnectionParameter('nb_users')}))
       for partition in tester_computer_partition:
-        self.logger.debug("Appending Kumo testers' url")
+        self.logger.debug("Appending ERP5 testers' url")
         self.tester_urls.append(partition.getConnectionParameter('url'))
       self.logger.debug("Before remove duplicates: %s" % str(self.tester_urls))
       self.tester_urls = list(set(self.tester_urls)) # remove duplicates
@@ -62,12 +63,24 @@ class ERP5ScalabilityTesterManager(NoSQL
       self.logger.debug(str(sys.exc_info()))
       return False
 
-  def _add_erp5_server_node(self):
+  def _add_erp5_tester_node(self):
     try:
-      pass
+      tester_computer_partition = []
+      for i in range(0, self.user_range_increment):
+        tester_computer_partition.append(self.computer_partition.request(self.software_release_url, 'erp5_tester', 'erp5_tester'+str(i),
+                   partition_parameter_kw={'host_address':self.host_address,
+                                           'erp5_url':self.computer_partition.getConnectionParameter('erp5_url'),
+                                           'benchmark_suites':self.computer_partition.getConnectionParameter('benchmark_suites'),
+                                           'repeat':self.computer_partition.getConnectionParameter('repeat'),
+                                           'nb_users':self.computer_partition.getConnectionParameter('nb_users')}))
+      for partition in tester_computer_partition:
+        self.logger.debug("Appending ERP5 testers' url")
+        self.tester_urls.append(partition.getConnectionParameter('url'))
+      self.logger.debug("Before remove duplicates: %s" % str(self.tester_urls))
+      self.tester_urls = list(set(self.tester_urls)) # remove duplicates
+      self.logger.debug("After remove duplicates: %s" % str(self.tester_urls))
       return True
     except:
       self.logger.debug(str(sys.exc_info()))
       return False
 
-