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

[nobody at svn.erp5.org]

Author: guillaume.bottex
Date: Wed Jul 27 15:59:17 2011
New Revision: 45982

URL: http://svn.erp5.org?rev=45982&view=rev
Log:
Change due to NoSQLTestBed pluggability feature.

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=45982&r1=45981&r2=45982&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] Wed Jul 27 15:59:17 2011
@@ -59,10 +59,12 @@ class KumoTesterManager(NoSQLTesterManag
     try:
       self.logger.debug("Kumo manager")
       manager_partition = self.computer_partition.request(self.software_release_url, 'kumo_manager', 'kumo_manager',
+                   partition_parameter_kw={'plugin':self.software_release_type},
                    filter_kw={'computer_guid':self.computer_guid_list[0]})
       self.logger.debug("Kumo manager guid: "+self.computer_guid_list[0])
 
       partition_parameter_kw = {
+        'plugin':self.software_release_type,
         'manager_address':manager_partition.getConnectionParameter('address'),
         'manager_port':manager_partition.getConnectionParameter('port')}
 
@@ -78,7 +80,8 @@ class KumoTesterManager(NoSQLTesterManag
       # line made to crash the function call until we call slapgrid
       server_partition.getConnectionParameter('address')
 
-      partition_parameter_kw = {'manager_address':manager_partition.getConnectionParameter('address'),
+      partition_parameter_kw = {'plugin':self.software_release_type,
+                                'manager_address':manager_partition.getConnectionParameter('address'),
                                 'manager_port':manager_partition.getConnectionParameter('port')}
 
       self.logger.debug("Memstrike set gateway")
@@ -92,6 +95,7 @@ class KumoTesterManager(NoSQLTesterManag
 
 
       partition_parameter_kw = {
+        'plugin':self.software_release_type,
         'gateway_address':gateway_partition.getConnectionParameter('address'),
         'gateway_port':gateway_partition.getConnectionParameter('port'),
         'nb_thread':self.nb_thread,
@@ -112,7 +116,8 @@ class KumoTesterManager(NoSQLTesterManag
       tester_partition_list = []
       for i in range(0, self.max_tester):
       
-        partition_parameter_kw = {'manager_address':manager_partition.getConnectionParameter('address'),
+        partition_parameter_kw = {'plugin':self.software_release_type,
+                                  'manager_address':manager_partition.getConnectionParameter('address'),
                                   'manager_port':manager_partition.getConnectionParameter('port'),
                                   'host_address':self.address,
                                   'nb_thread':self.nb_thread,
@@ -149,6 +154,7 @@ class KumoTesterManager(NoSQLTesterManag
   def _add_kumo_server_node(self):
     try:
       partition_parameter_kw = {
+        'plugin':self.software_release_type,
         'manager_address':self.manager_partition.getConnectionParameter('address'),
         'manager_port':self.manager_partition.getConnectionParameter('port')}