From: "Guannan Ren" <gren(a)redhat.com&gt; To: "Xuesong Zhang" <xuzhang(a)redhat.com&gt; Cc: libvir-list(a)redhat.com Sent: Monday, November 25, 2013 1:55:05 PM Subject: Re: [libvirt] [test-API][PATCH] add new patch for testing pinemulator API On 2013年11月22日 14:08, Xuesong Zhang wrote: > --- > 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 ACK and pushed Thanks Guannan