X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=system%2FTestNode.py;h=7f5c46962d370bd2e7f02e4cdce2c3d123ab87fa;hb=8562147f6fff5456f230b560cc7504850df24d1a;hp=687b526c06b79038f514a5d3c5a0eaa8e62e1397;hpb=acc29368268d995c2965a917409dba89d2373397;p=tests.git diff --git a/system/TestNode.py b/system/TestNode.py index 687b526..7f5c469 100644 --- a/system/TestNode.py +++ b/system/TestNode.py @@ -108,7 +108,7 @@ class TestNode: self.test_plc.apiserver.DeleteNode(auth,self.name()) # Do most of the stuff locally - will be pushed on host_box - *not* the plc - later if needed - def init_node(self): + def qemu_local_init(self): utils.system("rm -rf %s"%self.nodedir()) utils.system("mkdir %s"%self.nodedir()) if not self.is_qemu(): @@ -135,12 +135,30 @@ class TestNode: file(filename,'w').write(base64.b64decode(encoded)) return True - def reinstall_node (self): + def nodestate_reinstall (self): self.test_plc.apiserver.UpdateNode(self.test_plc.auth_root(), self.name(),{'boot_state':'reinstall'}) return True - def configure_qemu(self): + def nodestate_safeboot (self): + self.test_plc.apiserver.UpdateNode(self.test_plc.auth_root(), + self.name(),{'boot_state':'safeboot'}) + return True + + def nodestate_boot (self): + self.test_plc.apiserver.UpdateNode(self.test_plc.auth_root(), + self.name(),{'boot_state':'boot'}) + return True + + def nodestate_show (self): + if self.test_plc.options.dry_run: + print "Dry_run: skipped getting current node state" + return True + state=self.test_plc.apiserver.GetNodes(self.test_plc.auth_root(), self.name(), ['boot_state'])[0]['boot_state'] + print self.name(),':',state + return True + + def qemu_local_config(self): if not self.is_qemu(): return mac=self.node_spec['interface_fields']['mac'] @@ -162,7 +180,7 @@ class TestNode: file.close() return True - def export_qemu (self): + def qemu_export (self): # if relevant, push the qemu area onto the host box if self.test_box().is_local(): return True @@ -171,13 +189,13 @@ class TestNode: utils.header ("Transferring configuration files for node %s onto %s"%(self.name(),self.host_box())) return self.test_box().copy(self.nodedir(),recursive=True)==0 - def start_node (self): + def qemu_start (self): model=self.node_spec['node_fields']['model'] #starting the Qemu nodes before if self.is_qemu(): self.start_qemu() else: - utils.header("TestNode.start_node : %s model %s taken as real node"%(self.name(),model)) + utils.header("TestNode.qemu_start : %s model %s taken as real node"%(self.name(),model)) return True def start_qemu (self): @@ -208,10 +226,10 @@ class TestNode: if not self.is_qemu(): return True remote_log="%s/log.txt"%self.nodedir() - local_log="logs/node.qemu.%s.log"%self.name() + local_log="logs/node.qemu.%s.txt"%self.name() self.test_box().test_ssh.fetch(remote_log,local_log) - def clear_known_hosts (self): + def keys_clear_known_hosts (self): TestSsh(self.name()).clear_known_hosts() return True