The coredump_with_format.py uses coreDumpWithFormat() to validate
new API virDomainCoreDumpWithFormat of libvirt.
---
repos/domain/coredump_with_format.py | 239 +++++++++++++++++++++++++++++++++++
1 file changed, 239 insertions(+)
create mode 100644 repos/domain/coredump_with_format.py
diff --git a/repos/domain/coredump_with_format.py b/repos/domain/coredump_with_format.py
new file mode 100644
index 0000000..f1f7c67
--- /dev/null
+++ b/repos/domain/coredump_with_format.py
@@ -0,0 +1,239 @@
+#!/usr/bin/env python
+# test coreDumpWithFormat() API for libvirt
+
+import os
+import libvirt
+import thread
+
+from libvirt import libvirtError
+from src import sharedmod
+from utils import utils
+
+required_params = ('guestname','topath','dumpformat','flags',)
+optional_params = {}
+
+df = {"raw": libvirt.VIR_DOMAIN_CORE_DUMP_FORMAT_RAW,
+ "zlib": libvirt.VIR_DOMAIN_CORE_DUMP_FORMAT_KDUMP_ZLIB,
+ "lzo": libvirt.VIR_DOMAIN_CORE_DUMP_FORMAT_KDUMP_LZO,
+ "snappy": libvirt.VIR_DOMAIN_CORE_DUMP_FORMAT_KDUMP_SNAPPY}
+
+fg = {"mem": libvirt.VIR_DUMP_MEMORY_ONLY,
+ "reset": libvirt.VIR_DUMP_RESET,
+ "bypass": libvirt.VIR_DUMP_BYPASS_CACHE,
+ "live": libvirt.VIR_DUMP_LIVE,
+ "crash": libvirt.VIR_DUMP_CRASH}
+
+def check_crash_command(logger):
+ """
+ check crash command on current OS
+ """
+ CMD = "which crash"
+ status, output = utils.exec_cmd(CMD, shell=True)
+ if status != 0:
+ logger.info("Can not find crash command")
+ return False
+ else:
+ return True
+
+def check_dumpfile_type(topath,flags,logger):
+ """
+ check file type of generated file
+ """
+ GREP1 = "file %s |grep QEMU"
+ GREP2 = "file %s |grep ELF"
+ if flags < libvirt.VIR_DUMP_MEMORY_ONLY:
+ status, output = utils.exec_cmd(GREP1 % topath, shell=True)
+ if not status:
+ logger.info("Check type of %s: Pass, %s" % (topath, output[0]))
+ return True
+ else:
+ logger.info("Check type of %s: Fail, %s" % (topath, output[0]))
+ return False
+ elif flags >= libvirt.VIR_DUMP_MEMORY_ONLY:
+ status, output = utils.exec_cmd(GREP2 % topath, shell=True)
+ if not status:
+ logger.info("Check type of %s: Pass, %s" % (topath, output[0]))
+ return True
+ else:
+ logger.info("Check type of %s: Fail, %s" % (topath, output[0]))
+ return False
+
+def check_dump_file(*args):
+ """
+ check whether core dump file is generated
+ """
+ (core_file_path, logger) = args
+ if os.access(core_file_path, os.R_OK):
+ logger.info("Check core dump file %s: Pass" % core_file_path)
+ return True
+ else:
+ logger.info("Check core dump file %s: Fail" % core_file_path)
+ return False
+
+def compare_compress_type(topath,dumpformat,logger):
+ """
+ check the compress type of file
+ """
+ GREP = "crash -d1 %s | grep \"COMPRESSED\""
+ status, output = utils.exec_cmd(GREP % topath, shell=True)
+ if not status:
+ temp1 = output[0].strip()[:-1].split("_")[-1]
+ if temp1 == dumpformat:
+ logger.info("Check compress type %s of %s: Pass" %(temp1,topath))
+ return True
+ else:
+ logger.info("Check compress type %s of %s: Fail, %s" \
+%(temp1,topath,dumpformat))
+ return False
+ else:
+ logger.error("Can not get compress type from given file %s" % topath)
+ return False
+
+def check_domain_state(vmstate,flags,logger):
+ """
+ check domain state after doing coredump
+ """
+ if libvirt.VIR_DUMP_CRASH == libvirt.VIR_DUMP_CRASH&flags:
+ if vmstate == [libvirt.VIR_DOMAIN_SHUTOFF,\
+ libvirt.VIR_DOMAIN_SHUTOFF_CRASHED]:
+ logger.info("domain status is %s,shut off (crashed): Pass" \
+% vmstate)
+ return True
+ else:
+ logger.info("domain status is %s: Fail" % vmstate)
+ return False
+ else:
+ if vmstate == [libvirt.VIR_DOMAIN_RUNNING,\
+ libvirt.VIR_DOMAIN_RUNNING_UNPAUSED]:
+ logger.info("domain status is %s,running (unpaused): Pass" \
+% vmstate)
+ return True
+ else:
+ logger.info("domain status is %s: Fail" % vmstate)
+ return False
+
+def get_fileflags(topath,logger):
+ """
+ Get the file flags of coredump file
+ """
+ CMD = "cat /proc/$(lsof -w %s|awk '/libvirt_i/{print $2}')/fdinfo/1 \
+ |grep flags|awk '{print $NF}'"
+ global fileflags
+ while True:
+ (status, output) = utils.exec_cmd(CMD % topath, shell=True)
+ if status == 0:
+ if len(output) == 1:
+ logger.info("The flags of saved file %s " % output[0])
+ fileflags = output[0][-5]
+ break
+ else:
+ logger.error("Fail to get the flags of saved file")
+ return 1
+
+ thread.exit_thread()
+
+def check_fileflag(fileflags,logger):
+ """
+ Check the file flags of file if include O_DIRECT
+ """
+ if int(fileflags) == 4:
+ logger.info("File flags include O_DIRECT: Pass")
+ return True
+ else:
+ logger.error("File flags doesn't include O_DIRECT: Fail")
+ return False
+
+def coredump_with_format(params):
+ """
+ test APIs for coreDumpWithFormat in class virDomain
+ """
+ bypass_f = False
+ logger = params['logger']
+ domain_name = params['guestname']
+ topath = params['topath']
+ dumpformat = params['dumpformat']
+ Udumpformat = dumpformat.upper()
+ logger.info("The given dumpformat is %s" % dumpformat)
+ if dumpformat == 'raw':
+ dumpformat = df.get('raw')
+ elif dumpformat == 'zlib':
+ dumpformat = df.get('zlib')
+ elif dumpformat == 'lzo':
+ dumpformat = df.get('lzo')
+ elif dumpformat == 'snappy':
+ dumpformat = df.get('snappy')
+ else:
+ logger.info("Unknown flags")
+ return 1
+
+ flags = params['flags']
+ logger.info("The flags are %s" % flags)
+ flags_string = flags.split("|")
+ flags = 0
+ for flag in flags_string:
+ if flag == 'mem':
+ flags |= fg.get('mem')
+ elif flag == 'reset':
+ flags |= fg.get('reset')
+ elif flag == 'bypass':
+ flags |= fg.get('bypass')
+ bypass_f = True
+ elif flag == 'live':
+ flags |= fg.get('live')
+ elif flag == 'crash':
+ flags |= fg.get('crash')
+ else:
+ logger.error("Unknown flags")
+ return 1
+ logger.info("The given flags is %d" % flags)
+ try:
+ conn = sharedmod.libvirtobj['conn']
+
+ if conn.lookupByName(domain_name):
+ dom = conn.lookupByName(domain_name)
+ else:
+ logger.error("Domain %s is not exist" % domain_name)
+ return 1
+ if not dom.isActive():
+ logger.error("Domain %s is not running" % domain_name)
+ return 1
+ logger.info("The given path is %s" % topath)
+ if bypass_f == True:
+ thread.start_new_thread(get_fileflags,(topath,logger,))
+ logger.info("Call the coreDumpWithFormat API")
+ if dom.coreDumpWithFormat(topath,dumpformat,flags) == 0:
+
+ if not check_dump_file(topath,logger):
+ return 1
+ if Udumpformat == "RAW":
+ if not check_dumpfile_type(topath,flags,logger):
+ return 1
+ else:
+ if not check_crash_command(logger):
+ return 1
+ if not compare_compress_type(topath,Udumpformat,logger):
+ return 1
+ vmstate = dom.state()
+ if not check_domain_state(vmstate,flags,logger):
+ return 1
+ if bypass_f == True:
+ if not check_fileflag(fileflags,logger):
+ return 1
+
+ except libvirtError, e:
+ logger.error("API error message: %s" % e.message)
+ return 1
+
+ return 0
+
+def coredump_with_format_clean(params):
+ """clean testing environment"""
+
+ logger = params['logger']
+ topath = params['topath']
+ CMD = "rm -rf %s"
+ status, output = utils.exec_cmd(CMD % topath, shell=True)
+ if status != 0:
+ logger.info("Can not delete %s" % topath)
+ else:
+ logger.info("Deleted %s successfully" % topath)
--
1.8.3.1
--
libvir-list mailing list
libvir-list@xxxxxxxxxx
https://www.redhat.com/mailman/listinfo/libvir-list