[libvirt] [test-API][PATCH v2 4/4] Add qemu_hang test case under libvirtd
* repos/libvirtd/qemu_hang.py
qemu process get hang should not cause libvirtd hang or dead
---
repos/libvirtd/qemu_hang.py | 142 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 142 insertions(+), 0 deletions(-)
create mode 100644 repos/libvirtd/qemu_hang.py
diff --git a/repos/libvirtd/qemu_hang.py b/repos/libvirtd/qemu_hang.py
new file mode 100644
index 0000000..f377df3
--- /dev/null
+++ b/repos/libvirtd/qemu_hang.py
@@ -0,0 +1,142 @@
+#!/usr/bin/env python
+""" QEMU get hang should not cause libvirtd hang or dead. This test stop
+ a qemu process and check whether libvird get hang. For doing this
+ test, a running domain is required.
+ libvirtd:qemu_hang
+ guestname
+ #GUESTNAME#
+"""
+
+__author__ = 'Wayne Sun: gsun(a)redhat.com'
+__date__ = 'Thu Sep 2, 2011'
+__version__ = '0.1.0'
+__credits__ = 'Copyright (C) 2011 Red Hat, Inc.'
+__all__ = ['qemu_hang']
+
+import os
+import re
+import sys
+
+def append_path(path):
+ """Append root path of package"""
+ if path not in sys.path:
+ sys.path.append(path)
+
+pwd = os.getcwd()
+result = re.search('(.*)libvirt-test-API', pwd)
+append_path(result.group(0))
+
+from lib import connectAPI
+from lib import domainAPI
+from utils.Python import utils
+
+VIRSH_LIST = "virsh list --all"
+RESTART_CMD = "service libvirtd restart"
+
+def check_params(params):
+ """Verify inputing parameter dictionary"""
+ logger = params['logger']
+ keys = ['guestname']
+ for key in keys:
+ if key not in params:
+ logger.error("%s is required" %key)
+ return 1
+ return 0
+
+def check_domain_running(domobj, guestname, logger):
+ """ check if the domain exists, may or may not be active
"""
+ guest_names = domobj.get_list()
+
+ if guestname not in guest_names:
+ logger.error("%s doesn't exist or not running" % guestname)
+ return 1
+ else:
+ return 0
+
+def libvirtd_check(util, logger):
+ """check libvirtd status
+ """
+ cmd = "service libvirtd status"
+ ret, out = util.exec_cmd(cmd, shell=True)
+ if ret != 0:
+ logger.error("failed to get libvirtd status")
+ return 1
+ else:
+ logger.info(out[0])
+
+ logger.info(VIRSH_LIST)
+ ret, out = util.exec_cmd(VIRSH_LIST, shell=True)
+ if ret != 0:
+ logger.error("failed to get virsh list result")
+ return 1
+ else:
+ for i in range(len(out)):
+ logger.info(out[i])
+
+ return 0
+
+def get_domain_pid(util, logger, guestname):
+ """get the pid of running domain"""
+ logger.info("get the pid of running domain %s" % guestname)
+ get_pid_cmd = "cat /var/run/libvirt/qemu/%s.pid" % guestname
+ ret, pid = util.exec_cmd(get_pid_cmd, shell=True)
+ if ret:
+ logger.error("fail to get the pid of runnings domain %s" % \
+ guestname)
+ return 1, ""
+ else:
+ logger.info("the pid of domain %s is %s" % \
+ (guestname, pid[0]))
+ return 0, pid[0]
+
+def qemu_hang(params):
+ """Hang qemu process, check libvirtd status"""
+ # Initiate and check parameters
+ params_check_result = check_params(params)
+ if params_check_result:
+ return 1
+
+ logger = params['logger']
+ guestname = params['guestname']
+ util = utils.Utils()
+ uri = util.get_uri('127.0.0.1')
+
+ conn = connectAPI.ConnectAPI()
+ virconn = conn.open(uri)
+ domobj = domainAPI.DomainAPI(virconn)
+
+ logger.info("check the domain state")
+ ret = check_domain_running(domobj, guestname, logger)
+ if ret:
+ return 1
+
+ conn.close()
+
+ logger.info("check the libvirtd status:")
+ result = libvirtd_check(util, logger)
+ if result:
+ return 1
+
+ ret, pid = get_domain_pid(util, logger, guestname)
+ if ret:
+ return 1
+
+ cmd = "kill -STOP %s" % pid
+ logger.info(cmd)
+ ret, out = util.exec_cmd(cmd, shell=True)
+ if ret:
+ logger.error("failed to stop qemu process of %s" % guestname)
+ return 1
+
+ logger.info("recheck libvirtd status:")
+ result = libvirtd_check(util, logger)
+ if result:
+ return 1
+
+ return 0
+
+def qemu_hang_cleanup(params):
+ """ clean testing environment """
+ pass
+
+
--
1.7.1