Re: [libvirt] [test-API][PATCH] add new patch for testing pinemulator API

--- cases/pinemulator.conf | 46 +++++++++++++++++++++++++ repos/domain/pinemulator.py | 84 +++++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 130 insertions(+) create mode 100755 cases/pinemulator.conf create mode 100755 repos/domain/pinemulator.py diff --git a/cases/pinemulator.conf b/cases/pinemulator.conf new file mode 100755 index 0000000..2f270f3 --- /dev/null +++ b/cases/pinemulator.conf @@ -0,0 +1,46 @@ +domain:install_linux_cdrom + guestname + $defaultname + guestos + $defaultos + guestarch + $defaultarch + vcpu + $defaultvcpu + memory + $defaultmem + hddriver + $defaulthd + nicdriver + $defaultnic + imageformat + qcow2 + +domain:pinemulator + guestname + $defaultname + cpulist + 0-2 + +domain:pinemulator + guestname + $defaultname + cpulist + 3 + +domain:pinemulator + guestname + $defaultname + cpulist + 0,2 + +domain:destroy + guestname + $defaultname + + +domain:undefine + guestname + $defaultname + +options cleanup=enable \ No newline at end of file diff --git a/repos/domain/pinemulator.py b/repos/domain/pinemulator.py new file mode 100755 index 0000000..8d7b800 --- /dev/null +++ b/repos/domain/pinemulator.py @@ -0,0 +1,84 @@ +#!/usr/bin/env python +""" Query or change the pinning of domain's emulator threads to + host physical CPUs.""" + + +import libvirt +from libvirt import libvirtError + +from src import sharedmod +from utils import utils + +required_params = ('guestname', 'cpulist',) +optional_params = {} + +def check_pinemulator(guestname, maxcpu, pininfo_after): + """check emulator status of the running virtual machine + """ + + cmd = "cat /var/run/libvirt/qemu/%s.pid" % guestname + status, pid = utils.exec_cmd(cmd, shell=True) + if status: + logger.error("failed to get the pid of domain %s" % guestname) + return 1 + + cmd = "grep Cpus_allowed_list /proc/%s/task/%s/status" % (pid[0], pid[0]) + status, output = utils.exec_cmd(cmd, shell=True) + if status: + logger.error("failed to get Cpus_allowed_list") + return 1 + + cpu_allowed_list = output[0] + cpulistcheck = cpu_allowed_list.split('\t')[1] + pininfo_in_process = str(utils.param_to_tuple(cpulistcheck, maxcpu)) + + if cmp(pininfo_in_process, pininfo_after): + logger.error("domain emulator pin failed") + return 1 + else: + logger.info("domain emulator pin successed") + return 0 + + +def pinemulator(params): + """Dynamically change the real CPUs which can be allocated to the + emulator process of a domain. This function requires privileged + access to the hypervisor. """ + global logger + logger = params['logger'] + guestname = params['guestname'] + cpulist = params['cpulist'] + + logger.info("the name of virtual machine is %s" % guestname) + logger.info("the given cpulist is %s" % cpulist) + + maxcpu = utils.get_host_cpus() + logger.info("%s physical cpu on host" % maxcpu) + + cpumap = utils.param_to_tuple(cpulist, maxcpu) + if not cpumap: + logger.error("cpulist: Invalid format") + return 1 + + conn = sharedmod.libvirtobj['conn'] + + try: + domobj = conn.lookupByName(guestname) + + pininfo_original = str(domobj.emulatorPinInfo()) + logger.info("the original emulator pin of the domain is: %s" % \ + pininfo_original) + + logger.info("pin domain emulator to host cpu %s" % cpulist) + domobj.pinEmulator(cpumap) + + pininfo_after = str(domobj.emulatorPinInfo()) + logger.info("the revised emulator pin of the domain is: %s" % \ + pininfo_after) + + ret = check_pinemulator(guestname, maxcpu, pininfo_after) + return ret + + except libvirtError, e: + logger.error("libvirt call failed: " + str(e)) + return 1