|
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-changelog] Replace xm vcpu-enable and xm vcpu-disable with one command, xm set-vcpus,
# HG changeset patch
# User emellor@xxxxxxxxxxxxxxxxxxxxxx
# Node ID 2b92f50b769237c0eca0e524e9427dbc8b16964a
# Parent 446aa56ca4fee7d3ea2badfb59e8bb3540b507ae
Replace xm vcpu-enable and xm vcpu-disable with one command, xm set-vcpus,
which sets the number of active CPUs. Xend then toggles the VCPUs to ensure a
contiguous group of them are enabled.
Added a server command to get VCPU information, and use this info to fix
xm vcpu-list. That xm command now has extra information, too. CPU == -1 is no
longer used as an indicator for a VCPU that is disabled -- a separate state
field is available, and the CPU is set merely to '-'. Individual CPU time is
now available.
Deprecated xm list -v. -v is conventionally used for --verbose, so using it
to list vcpus is confusing. Furthermore, we already have an equivalent command
xm vcpu-list.
Tidied up the horrendous xm list / xm vcpu-list code.
Removed the vcpus field from the dict returned by xc_domain_getinfo, and the
vcpu_to_cpu map from the sxpr returned for xm list.
Move the dom0_enforce_vcpus code into XendDomain.
Signed-off-by: Ewan Mellor <ewan@xxxxxxxxxxxxx>
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/lowlevel/xc/xc.c
--- a/tools/python/xen/lowlevel/xc/xc.c Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/lowlevel/xc/xc.c Mon Oct 17 13:07:47 2005
@@ -317,11 +317,9 @@
PyObject *pyhandle = PyList_New(sizeof(xen_domain_handle_t));
for ( j = 0; j < sizeof(xen_domain_handle_t); j++ )
PyList_SetItem(pyhandle, j, PyInt_FromLong(info[i].handle[j]));
- info_dict = Py_BuildValue("{s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:i"
+ info_dict = Py_BuildValue("{s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:i"
",s:l,s:L,s:l,s:i,s:i}",
"dom", info[i].domid,
- /* XXX 'vcpus' field is obsolete! */
- "vcpus", info[i].nr_online_vcpus,
"online_vcpus", info[i].nr_online_vcpus,
"max_vcpu_id", info[i].max_vcpu_id,
"dying", info[i].dying,
@@ -980,8 +978,7 @@
" maxmem_kb [int]: Maximum memory limit, in kilobytes\n"
" cpu_time [long]: CPU time consumed, in nanoseconds\n"
" shutdown_reason [int]: Numeric code from guest OS, explaining "
- "reason why it shut itself down.\n"
- " vcpu_to_cpu [[int]]: List that maps VCPUS to CPUS\n" },
+ "reason why it shut itself down.\n" },
{ "vcpu_getinfo",
(PyCFunction)pyxc_vcpu_getinfo,
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/xend/XendClient.py
--- a/tools/python/xen/xend/XendClient.py Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/xend/XendClient.py Mon Oct 17 13:07:47 2005
@@ -199,6 +199,9 @@
def xend_list_domains(self):
return self.xendGet(self.domainurl(), {'detail': '1'})
+ def xend_domain_vcpuinfo(self, dom):
+ return self.xendGet(self.domainurl(dom), {'op': 'vcpuinfo'})
+
def xend_domain_create(self, conf):
return self.xendPost(self.domainurl(),
{'op' : 'create',
@@ -286,11 +289,10 @@
'target' : mem_target })
return val
- def xend_domain_vcpu_hotplug(self, id, vcpu, state):
- return self.xendPost(self.domainurl(id),
- {'op' : 'vcpu_hotplug',
- 'vcpu' : vcpu,
- 'state' : state })
+ def xend_domain_set_vcpus(self, dom, vcpus):
+ return self.xendPost(self.domainurl(dom),
+ {'op' : 'set_vcpus',
+ 'vcpus' : vcpus })
def xend_domain_vif_limit(self, id, vif, credit, period):
return self.xendPost(self.domainurl(id),
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/xend/XendDomain.py
--- a/tools/python/xen/xend/XendDomain.py Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/xend/XendDomain.py Mon Oct 17 13:07:47 2005
@@ -129,7 +129,14 @@
def dom0_setup(self):
"""Expects to be protected by the domains_lock."""
dom0 = self.domains[PRIV_DOMAIN]
- dom0.dom0_enforce_vcpus()
+
+ # get max number of vcpus to use for dom0 from config
+ target = int(xroot.get_dom0_vcpus())
+ log.debug("number of vcpus to use is %d", target)
+
+ # target == 0 means use all processors
+ if target > 0:
+ self.setVCpuCount(target)
def _add_domain(self, info):
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/xend/XendDomainInfo.py
--- a/tools/python/xen/xend/XendDomainInfo.py Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/xend/XendDomainInfo.py Mon Oct 17 13:07:47 2005
@@ -133,8 +133,6 @@
# its VCPUs. This is translated to
# <dompath>/cpu/<id>/availability = {online,offline} for use
# by the guest domain.
-# vcpu_to_cpu: the current mapping between virtual CPUs and the physical
-# CPU it is using.
# cpumap: a list of bitmaps, one for each VCPU, giving the physical
# CPUs that that VCPU may use.
# cpu: a configuration setting requesting that VCPU 0 is pinned to
@@ -391,6 +389,8 @@
self.state_updated = threading.Condition()
self.refresh_shutdown_lock = threading.Condition()
+
+ ## private:
def augmentInfo(self):
"""Augment self.info, as given to us through {@link #recreate}, with
@@ -544,24 +544,35 @@
def gatherVm(self, *args):
return xstransact.Gather(self.vmpath, *args)
+
+ ## public:
+
def storeVm(self, *args):
return xstransact.Store(self.vmpath, *args)
+
+ ## private:
+
def readDom(self, *args):
return xstransact.Read(self.dompath, *args)
def writeDom(self, *args):
return xstransact.Write(self.dompath, *args)
+
+ ## public:
+
def removeDom(self, *args):
return xstransact.Remove(self.dompath, *args)
- def gatherDom(self, *args):
- return xstransact.Gather(self.dompath, *args)
+
+ ## private:
def storeDom(self, *args):
return xstransact.Store(self.dompath, *args)
+
+ ## public:
def storeVmDetails(self):
to_store = {
@@ -596,18 +607,26 @@
if v:
to_store[k] = str(v)
+ to_store.update(self.vcpuDomDetails())
+
+ log.debug("Storing domain details: %s", to_store)
+
+ self.writeDom(to_store)
+
+
+ ## private:
+
+ def vcpuDomDetails(self):
def availability(n):
if self.info['vcpu_avail'] & (1 << n):
return 'online'
else:
return 'offline'
+ result = {}
for v in range(0, self.info['vcpus']):
- to_store["cpu/%d/availability" % v] = availability(v)
-
- log.debug("Storing domain details: %s", to_store)
-
- self.writeDom(to_store)
+ result["cpu/%d/availability" % v] = availability(v)
+ return result
def setDomid(self, domid):
@@ -635,8 +654,16 @@
def getUuid(self):
return self.uuid
+
def getVCpuCount(self):
return self.info['vcpus']
+
+
+ def setVCpuCount(self, vcpus):
+ self.info['vcpu_avail'] = (1 << vcpus) - 1
+ self.storeVm('vcpu_avail', self.info['vcpu_avail'])
+ self.writeDom(self.vcpuDomDetails())
+
def getSsidref(self):
return self.info['ssidref']
@@ -872,11 +899,11 @@
return self.getDeviceController(deviceClass).destroyDevice(devid)
- ## private:
-
def getDeviceSxprs(self, deviceClass):
return self.getDeviceController(deviceClass).sxprs()
+
+ ## private:
def getDeviceConfigurations(self, deviceClass):
return self.getDeviceController(deviceClass).configurations()
@@ -932,11 +959,6 @@
if self.infoIsSet('cpu_time'):
sxpr.append(['cpu_time', self.info['cpu_time']/1e9])
sxpr.append(['vcpus', self.info['vcpus']])
- if self.infoIsSet('cpumap'):
- sxpr.append(['cpumap', self.info['cpumap']])
- if self.infoIsSet('vcpu_to_cpu'):
- sxpr.append(['cpu', self.info['vcpu_to_cpu'][0]])
- sxpr.append(['vcpu_to_cpu', self.prettyVCpuMap()])
if self.infoIsSet('start_time'):
up_time = time.time() - self.info['start_time']
@@ -951,12 +973,33 @@
return sxpr
+ def getVCPUInfo(self):
+ try:
+ # We include the domain name and ID, to help xm.
+ sxpr = ['domain',
+ ['domid', self.domid],
+ ['name', self.info['name']],
+ ['vcpu_count', self.info['vcpus']]]
+
+ for i in range(0, self.info['vcpus']):
+ info = xc.vcpu_getinfo(self.domid, i)
+
+ sxpr.append(['vcpu',
+ ['number', i],
+ ['online', info['online']],
+ ['blocked', info['blocked']],
+ ['running', info['running']],
+ ['cpu_time', info['cpu_time'] / 1e9],
+ ['cpu', info['cpu']],
+ ['cpumap', info['cpumap']]])
+
+ return sxpr
+
+ except RuntimeError, exn:
+ raise XendError(str(exn))
+
+
## private:
-
- def prettyVCpuMap(self):
- return '|'.join(map(str,
- self.info['vcpu_to_cpu'][0:self.info['vcpus']]))
-
def check_name(self, name):
"""Check if a vm name is valid. Valid names contain alphabetic
characters,
@@ -1335,22 +1378,6 @@
xc.domain_setmaxmem(self.domid, maxmem_kb = m)
- def vcpu_hotplug(self, vcpu, state):
- """Disable or enable VCPU in domain.
- """
- if vcpu > self.info['vcpus']:
- log.error("Invalid VCPU %d" % vcpu)
- return
- if int(state) == 0:
- self.info['vcpu_avail'] &= ~(1 << vcpu)
- availability = "offline"
- else:
- self.info['vcpu_avail'] &= (1 << vcpu)
- availability = "online"
- self.storeVm('vcpu_avail', self.info['vcpu_avail'])
- self.storeDom("cpu/%d/availability" % vcpu, availability)
-
-
def send_sysrq(self, key):
asserts.isCharConvertible(key)
@@ -1371,24 +1398,6 @@
raise
- def dom0_enforce_vcpus(self):
- dom = 0
- # get max number of vcpus to use for dom0 from config
- target = int(xroot.get_dom0_vcpus())
- log.debug("number of vcpus to use is %d", target)
-
- # target = 0 means use all processors
- if target > 0:
- # count the number of online vcpus (cpu values in v2c map >= 0)
- vcpus_online = dom_get(dom)['vcpus']
- log.debug("found %d vcpus online", vcpus_online)
-
- # disable any extra vcpus that are online over the requested target
- for vcpu in range(target, vcpus_online):
- log.info("enforcement is disabling DOM%d VCPU%d", dom, vcpu)
- self.vcpu_hotplug(vcpu, 0)
-
-
def infoIsSet(self, name):
return name in self.info and self.info[name] is not None
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/xend/server/SrvDomain.py
--- a/tools/python/xen/xend/server/SrvDomain.py Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/xend/server/SrvDomain.py Mon Oct 17 13:07:47 2005
@@ -165,17 +165,25 @@
val = fn(req.args, {'dom': self.dom.domid})
return val
- def op_vcpu_hotplug(self, op, req):
- return self.call(self.dom.vcpu_hotplug,
- [['vcpu', 'int'],
- ['state', 'int']],
- req)
+ def op_set_vcpus(self, op, req):
+ return self.call(self.dom.setVCpuCount,
+ [['vcpus', 'int']],
+ req)
+
+
+ def op_vcpuinfo(self, _1, req):
+ return self.call(self.dom.getVCPUInfo, [], req)
+
def render_POST(self, req):
return self.perform(req)
def render_GET(self, req):
op = req.args.get('op')
+
+ if op and op[0] in ['vcpuinfo']:
+ return self.perform(req)
+
#
# XXX SMH: below may be useful once again if we ever try to get
# the raw 'web' interface to xend working once more. But for now
diff -r 446aa56ca4fe -r 2b92f50b7692 tools/python/xen/xm/main.py
--- a/tools/python/xen/xm/main.py Mon Oct 17 12:50:28 2005
+++ b/tools/python/xen/xm/main.py Mon Oct 17 13:07:47 2005
@@ -71,8 +71,7 @@
xm full list of subcommands:
Domain Commands:
- console <DomId> attach to console of DomId
- cpus-list <DomId> <VCpu> get the list of cpus for a VCPU
+ console <DomId> attach to console of DomId
create <ConfigFile> create a domain
destroy <DomId> terminate a domain immediately
domid <DomName> convert a domain name to a domain id
@@ -88,10 +87,9 @@
shutdown [-w|-a] <DomId> shutdown a domain
sysrq <DomId> <letter> send a sysrq to a domain
unpause <DomId> unpause a paused domain
- vcpu-enable <DomId> <VCPU> enable VCPU in a domain
- vcpu-disable <DomId> <VCPU> disable VCPU in a domain
- vcpu-list <DomId> get the list of VCPUs for a domain
- vcpu-pin <DomId> <VCpu> <CPUS> set which cpus a VCPU can use.
+ set-vcpus <DomId> <VCPUs> enable the specified number of VCPUs in a domain
+ vcpu-list <DomId> list the VCPUs for a domain
+ vcpu-pin <DomId> <VCPU> <CPUs> set which cpus a VCPU can use.
Xen Host Commands:
dmesg [--clear] read or clear Xen's message buffer
@@ -209,6 +207,15 @@
if id is not None:
server.xend_domain_unpause(domid)
+
+def getDomains(domain_names):
+ from xen.xend.XendClient import server
+ if domain_names:
+ return map(server.xend_domain, domain_names)
+ else:
+ return server.xend_list_domains()
+
+
def xm_list(args):
use_long = 0
show_vcpus = 0
@@ -218,80 +225,105 @@
err(opterr)
sys.exit(1)
- n = len(params)
for (k, v) in options:
if k in ['-l', '--long']:
use_long = 1
if k in ['-v', '--vcpus']:
show_vcpus = 1
- from xen.xend.XendClient import server
- if n == 0:
+ if show_vcpus:
+ print >>sys.stderr, (
+ "xm list -v is deprecated. Please use xm vcpu-list.")
+ xm_vcpu_list(params)
+ return
+
+ doms = getDomains(params)
+
+ if use_long:
+ map(PrettyPrint.prettyprint, doms)
+ else:
+ xm_brief_list(doms)
+
+
+def parse_doms_info(info):
+ def get_info(n, t, d):
+ return t(sxp.child_value(info, n, d))
+
+ return {
+ 'dom' : get_info('domid', int, -1),
+ 'name' : get_info('name', str, '??'),
+ 'mem' : get_info('memory', int, 0),
+ 'vcpus' : get_info('vcpus', int, 0),
+ 'state' : get_info('state', str, '??'),
+ 'cpu_time' : get_info('cpu_time', float, 0),
+ 'ssidref' : get_info('ssidref', int, 0),
+ }
+
+
+def xm_brief_list(doms):
+ print 'Name ID Mem(MiB) VCPUs State Time(s)'
+ for dom in doms:
+ d = parse_doms_info(dom)
+ if (d['ssidref'] != 0):
+ d['ssidstr'] = (" s:%04x/p:%04x" %
+ ((d['ssidref'] >> 16) & 0xffff,
+ d['ssidref'] & 0xffff))
+ else:
+ d['ssidstr'] = ""
+ print ("%(name)-32s %(dom)3d %(mem)8d %(vcpus)5d %(state)5s
%(cpu_time)7.1f%(ssidstr)s" % d)
+
+
+def xm_vcpu_list(args):
+ print 'Name ID VCPU CPU State Time(s)
CPU Map'
+
+ from xen.xend.XendClient import server
+ if args:
+ dominfo = map(server.xend_domain_vcpuinfo, args)
+ else:
doms = server.xend_list_domains()
- else:
- doms = map(server.xend_domain, params)
-
- if use_long:
- for dom in doms:
- PrettyPrint.prettyprint(dom)
- else:
- domsinfo = map(parse_doms_info, doms)
-
- if show_vcpus:
- xm_show_vcpus(domsinfo)
- else:
- xm_brief_list(domsinfo)
-
-def parse_doms_info(info):
- dominfo = {}
- dominfo['dom'] = int(sxp.child_value(info, 'domid', '-1'))
- dominfo['name'] = sxp.child_value(info, 'name', '??')
- dominfo['mem'] = int(sxp.child_value(info, 'memory', '0'))
- dominfo['cpu'] = str(sxp.child_value(info, 'cpu', '0'))
- dominfo['vcpus'] = int(sxp.child_value(info, 'vcpus', '0'))
- # if there is more than 1 cpu, the value doesn't mean much
- if dominfo['vcpus'] > 1:
- dominfo['cpu'] = '-'
- dominfo['state'] = sxp.child_value(info, 'state', '??')
- dominfo['cpu_time'] = float(sxp.child_value(info, 'cpu_time', '0'))
- # security identifiers
- if ((int(sxp.child_value(info, 'ssidref', '0'))) != 0):
- dominfo['ssidref1'] = int(sxp.child_value(info, 'ssidref', '0')) &
0xffff
- dominfo['ssidref2'] = (int(sxp.child_value(info, 'ssidref', '0')) >>
16) & 0xffff
- # get out the vcpu information
- dominfo['vcpulist'] = []
- vcpu_to_cpu = sxp.child_value(info, 'vcpu_to_cpu', '-1').split('|')
- cpumap = sxp.child_value(info, 'cpumap', [])
- mask = ((int(sxp.child_value(info, 'vcpus', '0')))**2) - 1
- count = 0
- for cpu in vcpu_to_cpu:
- vcpuinfo = {}
- vcpuinfo['name'] = sxp.child_value(info, 'name', '??')
- vcpuinfo['dom'] = int(sxp.child_value(info, 'domid', '-1'))
- vcpuinfo['vcpu'] = int(count)
- vcpuinfo['cpu'] = int(cpu)
- #vcpuinfo['cpumap'] = int(cpumap[count])&mask
- count = count + 1
- #dominfo['vcpulist'].append(vcpuinfo)
- return dominfo
-
-def xm_brief_list(domsinfo):
- print 'Name ID Mem(MiB) CPU VCPUs State Time(s)'
- for dominfo in domsinfo:
- if dominfo.has_key("ssidref1"):
- print ("%(name)-16s %(dom)3d %(mem)8d %(cpu)3s %(vcpus)5d
%(state)5s %(cpu_time)7.1f s:%(ssidref2)02x/p:%(ssidref1)02x" % dominfo)
- else:
- print ("%(name)-16s %(dom)3d %(mem)8d %(cpu)3s %(vcpus)5d
%(state)5s %(cpu_time)7.1f" % dominfo)
-
-def xm_show_vcpus(domsinfo):
- print 'Name Id VCPU CPU CPUMAP'
- for dominfo in domsinfo:
- for vcpuinfo in dominfo['vcpulist']:
- print ("%(name)-16s %(dom)3d %(vcpu)4d %(cpu)3d 0x%(cpumap)x" %
- vcpuinfo)
-
-def xm_vcpu_list(args):
- xm_list(["-v"] + args)
+ dominfo = map(
+ lambda x: server.xend_domain_vcpuinfo(sxp.child_value(x, 'name')),
+ doms)
+
+ for dom in dominfo:
+ def get_info(n):
+ return sxp.child_value(dom, n)
+
+ name = get_info('name')
+ domid = int(get_info('domid'))
+
+
+ for vcpu in sxp.children(dom, 'vcpu'):
+ def vinfo(n, t):
+ return t(sxp.child_value(vcpu, n))
+
+ number = vinfo('number', int)
+ cpu = vinfo('cpu', int)
+ cpumap = vinfo('cpumap', int)
+ online = vinfo('online', int)
+ cpu_time = vinfo('cpu_time', float)
+ running = vinfo('running', int)
+ blocked = vinfo('blocked', int)
+
+ if online:
+ c = str(cpu)
+ if running:
+ s = 'r'
+ else:
+ s = '-'
+ if blocked:
+ s += 'b'
+ else:
+ s += '-'
+ s += '-'
+ else:
+ c = "-"
+ s = "--p"
+
+ print (
+ "%(name)-32s %(domid)3d %(number)4d %(c)3s %(s)-3s
%(cpu_time)7.1f 0x%(cpumap)x" %
+ locals())
+
def xm_reboot(args):
arg_check(args,1,"reboot")
@@ -338,8 +370,6 @@
return cpumap
def xm_vcpu_pin(args):
- arg_check(args, 3, "vcpu-pin")
-
dom = args[0]
vcpu = int(args[1])
cpumap = cpu_make_map(args[2])
@@ -348,8 +378,6 @@
server.xend_domain_pincpu(dom, vcpu, cpumap)
def xm_mem_max(args):
- arg_check(args, 2, "mem-max")
-
dom = args[0]
mem = int_unit(args[1], 'm')
@@ -357,36 +385,15 @@
server.xend_domain_maxmem_set(dom, mem)
def xm_mem_set(args):
- arg_check(args, 2, "mem-set")
-
dom = args[0]
mem_target = int_unit(args[1], 'm')
from xen.xend.XendClient import server
server.xend_domain_mem_target_set(dom, mem_target)
-# TODO: why does this lookup by name? and what if that fails!?
-def xm_vcpu_enable(args):
- arg_check(args, 2, "vcpu-enable")
-
- name = args[0]
- vcpu = int(args[1])
-
- from xen.xend.XendClient import server
- dom = server.xend_domain(name)
- id = sxp.child_value(dom, 'domid')
- server.xend_domain_vcpu_hotplug(id, vcpu, 1)
-
-def xm_vcpu_disable(args):
- arg_check(args, 2, "vcpu-disable")
-
- name = args[0]
- vcpu = int(args[1])
-
- from xen.xend.XendClient import server
- dom = server.xend_domain(name)
- id = sxp.child_value(dom, 'domid')
- server.xend_domain_vcpu_hotplug(id, vcpu, 0)
+def xm_set_vcpus(args):
+ from xen.xend.XendClient import server
+ server.xend_domain_set_vcpus(args[0], int(args[1]))
def xm_domid(args):
name = args[0]
@@ -586,9 +593,7 @@
"mem-set": xm_mem_set,
# cpu commands
"vcpu-pin": xm_vcpu_pin,
-# "cpus-list": xm_cpus_list,
- "vcpu-enable": xm_vcpu_enable,
- "vcpu-disable": xm_vcpu_disable,
+ "set-vcpus": xm_set_vcpus,
"vcpu-list": xm_vcpu_list,
# special
"pause": xm_pause,
_______________________________________________
Xen-changelog mailing list
Xen-changelog@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-changelog
|
 |
Lists.xenproject.org is hosted with RackSpace, monitoring our |