X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=system%2FTestPlc.py;h=f1ecd2780b095103732669dec5ea766ae8f0b9b5;hb=c9b1f49bcd36492664afbd091f0468b144aa7e85;hp=c9738e8873e31185476e036d0a85d155c5c64b0d;hpb=4dc5e41ee83b669f49f7a8d3d94ef8cc857bc5bb;p=tests.git diff --git a/system/TestPlc.py b/system/TestPlc.py index c9738e8..f1ecd27 100644 --- a/system/TestPlc.py +++ b/system/TestPlc.py @@ -98,7 +98,7 @@ class TestPlc: 'ssh_node_debug@1', 'plcsh_stress_test@1', SEP, 'ssh_node_boot@1', 'ssh_slice', 'check_initscripts', SEP, 'ssh_slice_sfa@1', 'sfa_delete_slice@1', 'sfa_delete_user@1', SEPSFA, - 'check_tcp', 'check_netflow', SEP, + 'check_tcp', 'check_sys_slice', SEP, 'force_gather_logs', SEP, ] other_steps = [ @@ -146,6 +146,9 @@ class TestPlc: self.url="https://%s:443/PLCAPI/"%plc_spec['vserverip'] self.apiserver=TestApiserver(self.url,options.dry_run) + def has_addresses_api (self): + return hasattr(self.apiserver,'AddIpAddress') + def name(self): name=self.plc_spec['name'] return "%s.%s"%(name,self.vservername) @@ -191,14 +194,14 @@ class TestPlc: def vm_timestamp_path (self): if self.options.plcs_use_lxc: - return "/var/lib/lxc/%s.timestamp"%(self.vservername) + return "/var/lib/lxc/%s/%s.timestamp"%(self.vservername,self.vservername) else: return "/vservers/%s.timestamp"%(self.vservername) #start/stop the vserver def start_guest_in_host(self): if self.options.plcs_use_lxc: - return "lxc-start --name=%s"%(self.vservername) + return "lxc-start --daemon --name=%s"%(self.vservername) else: return "vserver %s start"%(self.vservername) @@ -357,8 +360,8 @@ class TestPlc: #################### display config def show (self): "show test configuration after localization" - self.display_pass (1) - self.display_pass (2) + self.show_pass (1) + self.show_pass (2) return True def export (self): @@ -382,7 +385,7 @@ class TestPlc: # entry point always_display_keys=['PLC_WWW_HOST','nodes','sites',] - def display_pass (self,passno): + def show_pass (self,passno): for (key,val) in self.plc_spec.iteritems(): if not self.options.verbose and key not in TestPlc.always_display_keys: continue if passno == 2: @@ -1125,9 +1128,12 @@ class TestPlc: return overall # painfully enough, we need to allow for some time as netflow might show up last - def check_netflow (self): - "all nodes: check that the netflow slice is alive" - return self.check_systemslice ('netflow') + def check_sys_slice (self): + "all nodes: check that a system slice is alive" +# would probably make more sense to check for netflow, +# but that one is currently not working in the lxc distro +# return self.check_systemslice ('netflow') + return self.check_systemslice ('drl') # we have the slices up already here, so it should not take too long def check_systemslice (self, slicename, timeout_minutes=5, period=15): @@ -1135,7 +1141,7 @@ class TestPlc: test_nodes=self.all_nodes() while test_nodes: for test_node in test_nodes: - if test_node.check_systemslice (slicename): + if test_node.check_systemslice (slicename,dry_run=self.options.dry_run): utils.header ("ok") test_nodes.remove(test_node) else: @@ -1442,6 +1448,7 @@ class TestPlc: "gets all possible logs from plc's/qemu node's/slice's for future reference" # (1.a) get the plc's /var/log/ and store it locally in logs/myplc.var-log./* # (1.b) get the plc's /var/lib/pgsql/data/pg_log/ -> logs/myplc.pgsql-log./* + # (1.c) get the plc's /root/sfi -> logs/sfi./ # (2) get all the nodes qemu log and store it as logs/node.qemu..log # (3) get the nodes /var/log and store is as logs/node.var-log./* # (4) as far as possible get the slice's /var/log as logs/sliver.var-log./* @@ -1451,6 +1458,9 @@ class TestPlc: # (1.b) print "-------------------- TestPlc.gather_logs : PLC's /var/lib/psql/data/pg_log/" self.gather_pgsql_logs () + # (1.c) + print "-------------------- TestPlc.gather_logs : PLC's /root/sfi/" + self.gather_root_sfi () # (2) print "-------------------- TestPlc.gather_logs : nodes's QEMU logs" for site_spec in self.plc_spec['sites']: @@ -1488,6 +1498,12 @@ class TestPlc: command = to_plc + "| tar -C logs/myplc.pgsql-log.%s -xf -"%self.name() utils.system(command) + def gather_root_sfi (self): + utils.system("mkdir -p logs/sfi.%s"%self.name()) + to_plc = self.actual_command_in_guest("tar -C /root/sfi/ -cf - .") + command = to_plc + "| tar -C logs/sfi.%s -xf -"%self.name() + utils.system(command) + def gather_nodes_var_logs (self): for site_spec in self.plc_spec['sites']: test_site = TestSite (self,site_spec)