3:55 a.m.
V3->V4:
Remove getSysinfo() check for lxc connection.
Fix minor problems.
V2->V3:
Refactor connection_nodeinfo.
Change the way of getting version number.
V1->V2:
Seperate check functions in each test case.
Improve log message.
V1:
Add test case for virconnect
Add test case for nodeinfo of virconnect
Add connection_version test case
Add conf file of virconnect test
jmiao (4):
Add test case for virConnect
Add connection_nodeinfo test case
Add connection_version test case
Add test_connection.conf
cases/test_connection.conf | 31 +++++++
repos/virconn/__init__.py | 0
repos/virconn/connection_attributes.py | 92 +++++++++++++++++++++
repos/virconn/connection_nodeinfo.py | 146 +++++++++++++++++++++++++++++++++
repos/virconn/connection_version.py | 119 +++++++++++++++++++++++++++
5 files changed, 388 insertions(+)
create mode 100644 cases/test_connection.conf
create mode 100644 repos/virconn/__init__.py
create mode 100644 repos/virconn/connection_attributes.py
create mode 100644 repos/virconn/connection_nodeinfo.py
create mode 100644 repos/virconn/connection_version.py
--
1.8.3.1
3:55 a.m.
New subject: [libvirt] [libvirt-test-API][PATCH V4 1/4] Add test case for virConnect
From: jmiao <jmiao(a)redhat.com>
Add a connect_attributes.py for testing API: isAlive, getType, getURI,
getHostname, getSysinfo, getCapabilities.
Signed-off-by: jmiao <jmiao(a)redhat.com>
---
repos/virconn/__init__.py | 0
repos/virconn/connection_attributes.py | 92 ++++++++++++++++++++++++++++++++++
2 files changed, 92 insertions(+)
create mode 100644 repos/virconn/__init__.py
create mode 100644 repos/virconn/connection_attributes.py
diff --git a/repos/virconn/__init__.py b/repos/virconn/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/repos/virconn/connection_attributes.py
b/repos/virconn/connection_attributes.py
new file mode 100644
index 0000000..6fd702b
--- /dev/null
+++ b/repos/virconn/connection_attributes.py
@@ -0,0 +1,92 @@
+#!/usr/bin/env python
+# test libvirt connection attributes
+
+import libvirt
+from libvirt import libvirtError
+
+from src import sharedmod
+from utils import utils
+
+required_params = ()
+optional_params = {'conn': ''}
+
+
+def check_conn_type(conn, logger):
+ """check connection's type
+ """
+ logger.info("Test connection's type")
+ uri_type = conn.getType()
+ logger.info("The connection's type is %s" % uri_type)
+ uri_str = conn.getURI()
+ logger.info("The connection's URI is %s" % uri_str)
+ # because remote:// is redirect to the default hypervisor URI
+ if 'remote' in uri_str:
+ logger.info("Ignore remote:// URI testing")
+ else:
+ if str.lower(uri_type) not in str.lower(uri_str):
+ logger.error("The connection %s has wrong type: %s" %
+ (uri_str, uri_type))
+ return False
+ return True
+
+
+def check_conn_hostname(conn, logger):
+ """check connection's hostname
+ """
+ logger.info("Test connection's hostname")
+ output = utils.get_local_hostname()
+ conn_hostname = conn.getHostname()
+ logger.info("The connection's hostname is %s" % conn_hostname)
+
+ if not conn_hostname == output:
+ logger.error("The connection's hostname(%s) wrong, should be %s" %
+ (conn_hostname, output))
+ return False
+ return True
+
+
+def connection_attributes(params):
+ """test libvirt connection attributes
+ """
+ logger = params['logger']
+
+ try:
+ # get connection firstly.
+ # If conn is not specified, use conn from sharedmod
+ if 'conn' in params:
+ conn = libvirt.open(params['conn'])
+ else:
+ conn = sharedmod.libvirtobj['conn']
+
+ # test connection is Alive
+ if not conn.isAlive():
+ logger.error("The connection is not alive")
+ return 1
+
+ # test connection type
+ if not check_conn_type(conn, logger):
+ logger.error("Failed to check connection type")
+ return 1
+
+ # test hostname of the connection
+ if not check_conn_hostname(conn, logger):
+ logger.error("Failed to check connection hostname")
+ return 1
+
+ # test connection's sysinfo
+ logger.info("Test connection's sysinfo")
+ conn_sysinfo = conn.getSysinfo(0)
+ logger.info("The connection's sysinfo is:\n %s" % conn_sysinfo)
+
+ # test connection's capabilities
+ logger.info("Test connection's capabilities")
+ conn_caps = conn.getCapabilities()
+ logger.info("The connection's capabilities is:\n %s" % conn_caps)
+
+ except libvirtError, e:
+ logger.error("API error message: %s, error code is %s" %
+ e.message)
+ logger.error("start failed")
+ return 1
+
+ return 0
--
1.8.3.1
3:55 a.m.
New subject: [libvirt] [libvirt-test-API][PATCH V4 2/4] Add connection_nodeinfo test case
From: jmiao <jmiao(a)redhat.com>
The connection_nodeinfo.py test the node infomation the virConnect saved,
like: arch, memory, cpus.
Signed-off-by: jmiao <jmiao(a)redhat.com>
---
repos/virconn/connection_nodeinfo.py | 146 +++++++++++++++++++++++++++++++++++
1 file changed, 146 insertions(+)
create mode 100644 repos/virconn/connection_nodeinfo.py
diff --git a/repos/virconn/connection_nodeinfo.py b/repos/virconn/connection_nodeinfo.py
new file mode 100644
index 0000000..85fb5cb
--- /dev/null
+++ b/repos/virconn/connection_nodeinfo.py
@@ -0,0 +1,146 @@
+#!/usr/bin/env python
+# test libvirt connection node infomation
+
+import libvirt
+from libvirt import libvirtError
+
+from src import sharedmod
+from utils import utils
+
+required_params = ()
+optional_params = {'conn': ''}
+
+
+def get_model(logger):
+ """get nodeinfo model
+ """
+ output = utils.get_host_arch()
+ logger.info("model is %s" % output)
+ return output
+
+
+def get_memory(logger):
+ """get nodeinfo memory
+ """
+ output = utils.get_host_memory()
+ # the memory value python API returned is devided by 1024
+ mem_cap = int(output) / 1024
+ logger.info("memory is %s MiB" % mem_cap)
+ return mem_cap
+
+
+def get_cpus(logger):
+ """get nodeinfo cpus
+ """
+ output = utils.get_host_cpus()
+ logger.info("cpus is %s" % output)
+ return output
+
+
+def get_cpu_mhz(logger):
+ """get nodeinfo cpu_mhz
+ """
+ output = utils.get_host_frequency()
+ cpu_mhz = int(output.split('.')[0])
+ logger.info("cpu MHz is %d" % cpu_mhz)
+ return cpu_mhz
+
+
+def get_nodes(logger):
+ """get nodeinfo nodes
+ """
+ cmds = "lscpu | grep 'node(s)' | awk {'print $3'}"
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Exec_cmd failed: %s" % cmds)
+ return ""
+ logger.info("nodes is %s" % output[0])
+ return int(output[0])
+
+
+def get_sockets(logger):
+ """get nodeinfo sockets
+ """
+ cmds = "lscpu | grep 'Socket(s)' | awk {'print $2'}"
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Exec_cmd failed: %s" % cmds)
+ return ""
+ logger.info("cpu sockets is %s" % output[0])
+ return int(output[0])
+
+
+def get_cores(logger):
+ """get nodeinfo cores
+ """
+ cmds = "lscpu | grep 'Core(s)' | awk {'print $4'}"
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Exec_cmd failed: %s" % cmds)
+ return ""
+ logger.info("cpu cores is %s" % output[0])
+ return int(output[0])
+
+
+def get_threads(logger):
+ """get nodeinfo threads
+ """
+ cmds = "lscpu | grep 'Thread(s)' | awk {'print $4'}"
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Exec_cmd failed: %s" % cmds)
+ return ""
+ logger.info("cpu threads is %s" % output[0])
+ return int(output[0])
+
+
+def check_conn_nodeinfo(conn_nodeinfo, logger):
+ """check each nodeinfo value
+ """
+ ret = True
+ # python2.6 does not have ordered dict, so that enumerate
+ # could not get the defined sequence which API getInfo() returned.
+ res_types = ['model', 'memory', 'cpus', 'cpu_mhz',
'nodes',
+ 'sockets', 'cores', 'threads']
+ get_res_func = [get_model, get_memory, get_cpus, get_cpu_mhz,
+ get_nodes, get_sockets, get_cores, get_threads]
+
+ for idx, res in enumerate(zip(res_types, get_res_func)):
+ logger.debug("Checking %s" % res[0])
+ logger.debug("Executing %s" % res[1])
+ get_res = res[1](logger)
+ if get_res != conn_nodeinfo[idx]:
+ logger.error("Failed to check nodeinfo's %s" % res[0])
+ logger.error("%s %s is wrong, should be %s" %
+ (res, conn_nodeinfo[idx], get_res))
+ ret = False
+
+ return ret
+
+
+def connection_nodeinfo(params):
+ """test libvirt connection node infomation
+ """
+ logger = params['logger']
+
+ try:
+ # get connection firstly.
+ # If conn is not specified, use conn from sharedmod
+ if 'conn' in params:
+ conn = libvirt.open(params['conn'])
+ else:
+ conn = sharedmod.libvirtobj['conn']
+
+ logger.info("get connection node infomation")
+ conn_nodeinfo = conn.getInfo()
+ logger.info("connection node infomation is %s" % conn_nodeinfo)
+
+ check_conn_nodeinfo(conn_nodeinfo, logger)
+
+ except libvirtError, e:
+ logger.error("API error message: %s, error code is %s" %
+ e.message)
+ logger.error("start failed")
+ return 1
+
+ return 0
--
1.8.3.1
3:55 a.m.
New subject: [libvirt] [libvirt-test-API][PATCH V4 3/4] Add connection_version test case
From: jmiao <jmiao(a)redhat.com>
The connection_version.py test the version of libvirt and hypervisor
the virConnect saved.
Currently, hypervisor checking only support qemu and lxc, need expanding
more hypervisors in furture.
Signed-off-by: jmiao <jmiao(a)redhat.com>
---
repos/virconn/connection_version.py | 119 ++++++++++++++++++++++++++++++++++++
1 file changed, 119 insertions(+)
create mode 100644 repos/virconn/connection_version.py
diff --git a/repos/virconn/connection_version.py b/repos/virconn/connection_version.py
new file mode 100644
index 0000000..3aee44f
--- /dev/null
+++ b/repos/virconn/connection_version.py
@@ -0,0 +1,119 @@
+#!/usr/bin/env python
+# test libvirt connection version
+
+import libvirt
+from libvirt import libvirtError
+
+from src import sharedmod
+from utils import utils
+
+required_params = ()
+optional_params = {'conn': ''}
+
+
+def produce_ver_num(major, minor, release):
+ """produce the version number
+ """
+ num = major * 1000000 + minor * 1000 + release
+ return num
+
+
+def check_libvirt_ver_num(conn, logger):
+ """check libvirt version number
+ """
+ libvirt_version = utils.get_libvirt_version()
+ logger.info("libvirt version is %s" % libvirt_version)
+ ver = libvirt_version.split('-')[1]
+ x = int(ver.split('.')[0])
+ y = int(ver.split('.')[1])
+ z = int(ver.split('.')[2])
+ libvirt_ver_num = produce_ver_num(x, y, z)
+
+ conn_lib_ver = conn.getLibVersion()
+ logger.info("get libvirt version from connection: %s" % conn_lib_ver)
+
+ if conn_lib_ver != libvirt_ver_num:
+ logger.error("libvirt version is wrong, should be %s" %
+ libvirt_ver_num)
+ return False
+ return True
+
+
+def check_hypervisor_ver_num(conn, logger):
+ """check hypervisor version number
+ """
+ # TODO: modify utils.get_hypervisor, support lxc, openvz, and so on
+ conn_type = conn.getType()
+ logger.info("connection's type is %s" % conn_type)
+
+ if str.lower(conn_type) == 'qemu':
+ cmds = "rpm -q qemu-kvm"
+ ver_num_pos = 2
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ cmds = "rpm -q qemu-kvm-rhev"
+ ver_num_pos = 3
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Could not be aware of qemu")
+ return False
+ hyper_version = output[0]
+ ver = hyper_version.split('-')[ver_num_pos]
+ x = int(ver.split('.')[0])
+ y = int(ver.split('.')[1])
+ z = int(ver.split('.')[2])
+ elif str.lower(conn_type) == 'lxc':
+ cmds = "uname -r"
+ (status, output) = utils.exec_cmd(cmds, shell=True)
+ if status != 0:
+ logger.error("Exec_cmd failed: %s" % cmds)
+ return False
+ hyper_version = output[0]
+ ver = hyper_version.split('-')[0]
+ x = int(ver.split('.')[0])
+ y = int(ver.split('.')[1])
+ z = int(ver.split('.')[2])
+ else:
+ logger.error("This hypervisor %s is unsupported currently" %
conn_type)
+ return False
+
+ hyper_ver_num = produce_ver_num(x, y, z)
+
+ conn_hyper_ver = conn.getVersion()
+ logger.info("get hypervisor version from connection: %s" % conn_hyper_ver)
+ if conn_hyper_ver != hyper_ver_num:
+ logger.error("libvirt version is wrong, should be %s" % hyper_ver_num)
+ return False
+ return True
+
+
+def connection_version(params):
+ """test libvirt connection version
+ """
+ logger = params['logger']
+
+ try:
+ # get connection firstly.
+ # If conn is not specified, use conn from sharedmod
+ if 'conn' in params:
+ conn = libvirt.open(params['conn'])
+ else:
+ conn = sharedmod.libvirtobj['conn']
+
+ # check libvirt version number
+ if not check_libvirt_ver_num(conn, logger):
+ logger.error("Failed to check libvirt version number")
+ return 1
+
+ # check hypervisor version number
+ if not check_hypervisor_ver_num(conn, logger):
+ logger.error("Failed to check hypervisor version number")
+ return 1
+
+ except libvirtError, e:
+ logger.error("API error message: %s, error code is %s" %
+ e.message)
+ logger.error("start failed")
+ return 1
+
+ return 0
--
1.8.3.1
3:55 a.m.
New subject: [libvirt] [libvirt-test-API][PATCH V4 4/4] Add test_connection.conf
From: jmiao <jmiao(a)redhat.com>
Signed-off-by: jmiao <jmiao(a)redhat.com>
---
cases/test_connection.conf | 31 +++++++++++++++++++++++++++++++
1 file changed, 31 insertions(+)
create mode 100644 cases/test_connection.conf
diff --git a/cases/test_connection.conf b/cases/test_connection.conf
new file mode 100644
index 0000000..ccde119
--- /dev/null
+++ b/cases/test_connection.conf
@@ -0,0 +1,31 @@
+virconn:connection_nodeinfo
+ conn
+ qemu:///system
+
+virconn:connection_attributes
+ conn
+ qemu:///system
+
+virconn:connection_version
+ conn
+ qemu:///system
+
+virconn:connection_nodeinfo
+ conn
+ qemu:///session
+
+virconn:connection_attributes
+ conn
+ qemu:///session
+
+virconn:connection_version
+ conn
+ qemu:///session
+
+virconn:connection_nodeinfo
+ conn
+ lxc:///
+
+virconn:connection_version
+ conn
+ lxc:///
--
1.8.3.1
12:42 a.m.
ACK and pushed
Thanks
On 04/25/2014 04:55 PM, Jincheng Miao wrote:
V3->V4:
Remove getSysinfo() check for lxc connection.
Fix minor problems.
V2->V3:
Refactor connection_nodeinfo.
Change the way of getting version number.
V1->V2:
Seperate check functions in each test case.
Improve log message.
V1:
Add test case for virconnect
Add test case for nodeinfo of virconnect
Add connection_version test case
Add conf file of virconnect test
jmiao (4):
Add test case for virConnect
Add connection_nodeinfo test case
Add connection_version test case
Add test_connection.conf
cases/test_connection.conf | 31 +++++++
repos/virconn/__init__.py | 0
repos/virconn/connection_attributes.py | 92 +++++++++++++++++++++
repos/virconn/connection_nodeinfo.py | 146 +++++++++++++++++++++++++++++++++
repos/virconn/connection_version.py | 119 +++++++++++++++++++++++++++
5 files changed, 388 insertions(+)
create mode 100644 cases/test_connection.conf
create mode 100644 repos/virconn/__init__.py
create mode 100644 repos/virconn/connection_attributes.py
create mode 100644 repos/virconn/connection_nodeinfo.py
create mode 100644 repos/virconn/connection_version.py
3660
days inactive
3897
days old
5 comments
2 participants
participants (2)
-
hongming -
Jincheng Miao