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

[nobody at svn.erp5.org]

Author: guillaume.bottex
Date: Fri Jul  1 13:27:47 2011
New Revision: 45957

URL: http://svn.erp5.org?rev=45957&view=rev
Log:
Adding waiting time for server synchro.

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

Modified: slapos/trunk/util/slapos.tool.nosqltester_manager.kumo/src/slapos/tool/nosqltester_manager/kumo/__init__.py
URL: http://svn.erp5.org/slapos/trunk/util/slapos.tool.nosqltester_manager.kumo/src/slapos/tool/nosqltester_manager/kumo/__init__.py?rev=45957&r1=45956&r2=45957&view=diff
==============================================================================
--- slapos/trunk/util/slapos.tool.nosqltester_manager.kumo/src/slapos/tool/nosqltester_manager/kumo/__init__.py [utf8] (original)
+++ slapos/trunk/util/slapos.tool.nosqltester_manager.kumo/src/slapos/tool/nosqltester_manager/kumo/__init__.py [utf8] Fri Jul  1 13:27:47 2011
@@ -27,7 +27,7 @@
 #
 ##############################################################################
 
-import sys, csv, re
+import sys, csv, re, time
 from logging import Formatter
 from slapos.tool.nosqltester_manager import NoSQLTesterManager
 
@@ -54,6 +54,15 @@ class KumoTesterManager(NoSQLTesterManag
     self.max_manager = 1
     self.computer_guid_list = self.computer_partition.getConnectionParameter('computer_guid_list').split(':')
 
+  def do_scheduling(self, action):
+    """
+    Override the do_scheduling to add 1 minute sleep,
+    in order to wait kumo server's synchronization.
+    """
+    
+    time.sleep(60)
+    NoSQLTesterManager.do_scheduling(self, action)
+
   def _kumo_init(self):
     try:
       self.logger.debug("Kumo manager")
@@ -66,7 +75,7 @@ class KumoTesterManager(NoSQLTesterManag
         'manager_port':manager_partition.getConnectionParameter('port')}
 
       self.logger.debug("Kumo server 1")
-      self.computer_partition.request(
+      server_partition = self.computer_partition.request(
         self.software_release_url,
         'kumo_server',
         'kumo_server'+str(self.node_count),
@@ -74,6 +83,9 @@ class KumoTesterManager(NoSQLTesterManag
         filter_kw={'computer_guid':self.computer_guid_list[self.max_manager+self.node_count-1]})
       self.logger.debug("Kumo server 1 guid: "+self.computer_guid_list[self.max_manager+self.node_count-1])
 
+      # line made to crash the function call until we call slapgrid
+      server_partition.getConnectionParameter('address')
+
       partition_parameter_kw = {'manager_address':manager_partition.getConnectionParameter('address'),
                                 'manager_port':manager_partition.getConnectionParameter('port')}