|
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-changelog] [xen-unstable] [XEND] Proper support for devices with UUID. Removing old workaround
# HG changeset patch
# User Alastair Tse <atse@xxxxxxxxxxxxx>
# Node ID c88a78f8bed98c705aa2300d6d4ded13479e6986
# Parent c0d9f8b9c0e592c58b36762a5cae8a4a54fe8ad5
[XEND] Proper support for devices with UUID. Removing old workaround
with augmented VM UUIDs with devids.
Signed-off-by: Alastair Tse <atse@xxxxxxxxxxxxx>
---
tools/python/xen/xend/XendAPI.py | 36 ++++++-
tools/python/xen/xend/XendConfig.py | 6 +
tools/python/xen/xend/XendDomain.py | 48 ++++------
tools/python/xen/xend/XendDomainInfo.py | 119 +++++++++++++++-----------
tools/python/xen/xend/server/DevController.py | 7 +
5 files changed, 132 insertions(+), 84 deletions(-)
diff -r c0d9f8b9c0e5 -r c88a78f8bed9 tools/python/xen/xend/XendAPI.py
--- a/tools/python/xen/xend/XendAPI.py Fri Oct 06 12:46:46 2006 +0100
+++ b/tools/python/xen/xend/XendAPI.py Fri Oct 06 16:27:06 2006 +0100
@@ -948,9 +948,14 @@ class XendAPI:
# object methods
def vbd_get_record(self, session, vbd_ref):
xendom = XendDomain.instance()
- return xen_api_success(xendom.get_dev_by_uuid('vbd', vbd_ref,
- 'driver'))
-
+ vm = xendom.get_vm_with_dev_uuid('vbd', vbd_ref)
+ if not vm:
+ return xen_api_error(XEND_ERROR_VIF_INVALID)
+ cfg = vm.get_dev_xenapi_config('vbd', vbd_ref)
+ if not cfg:
+ return xen_api_error(XEND_ERROR_UNKNOWN)
+ return xen_api_success(cfg)
+
# class methods
def vbd_create(self, session, vbd_struct):
xendom = XendDomain.instance()
@@ -968,20 +973,20 @@ class XendAPI:
# attributes (rw)
def vbd_get_vm(self, session, vbd_ref):
xendom = XendDomain.instance()
- return xen_api_success(xendom.get_dev_by_uuid('vbd', vbd_ref, 'VM'))
+ return xen_api_success(xendom.get_dev_property('vbd', vbd_ref, 'VM'))
def vbd_get_vdi(self, session, vbd_ref):
return xen_api_error(XEND_ERROR_UNSUPPORTED)
def vbd_get_device(self, session, vbd_ref):
xendom = XendDomain.instance()
- return xen_api_success(xendom.get_dev_by_uuid('vbd', vbd_ref,
+ return xen_api_success(xendom.get_dev_property('vbd', vbd_ref,
'device'))
def vbd_get_mode(self, session, vbd_ref):
xendom = XendDomain.instance()
- return xen_api_success(xendom.get_dev_by_uuid('vbd', vbd_ref,
+ return xen_api_success(xendom.get_dev_property('vbd', vbd_ref,
'mode'))
def vbd_get_driver(self, session, vbd_ref):
xendom = XendDomain.instance()
- return xen_api_success(xendom.get_dev_by_uuid('vbd', vbd_ref,
+ return xen_api_success(xendom.get_dev_property('vbd', vbd_ref,
'driver'))
# Xen API: Class VIF
@@ -1001,6 +1006,23 @@ class XendAPI:
VIF_attr_inst = VIF_attr_rw
+ # object methods
+ def vif_get_record(self, session, vif_ref):
+ xendom = XendDomain.instance()
+ vm = xendom.get_vm_with_dev_uuid('vif', vif_ref)
+ if not vm:
+ return xen_api_error(XEND_ERROR_VIF_INVALID)
+ cfg = vm.get_dev_xenapi_config('vif', vif_ref)
+ if not cfg:
+ return xen_api_error(XEND_ERROR_UNKNOWN)
+ valid_vif_keys = self.VIF_attr_ro + self.VIF_attr_rw + \
+ self.Base_attr_ro + self.Base_attr_rw
+ for k in cfg.keys():
+ if k not in valid_vif_keys:
+ del cfg[k]
+
+ return xen_api_success(cfg)
+
# class methods
def vif_create(self, session, vif_struct):
xendom = XendDomain.instance()
diff -r c0d9f8b9c0e5 -r c88a78f8bed9 tools/python/xen/xend/XendConfig.py
--- a/tools/python/xen/xend/XendConfig.py Fri Oct 06 12:46:46 2006 +0100
+++ b/tools/python/xen/xend/XendConfig.py Fri Oct 06 16:27:06 2006 +0100
@@ -717,6 +717,12 @@ class XendConfig(dict):
raise XendConfigError('Invalid restart event: %s = %s' % \
(event, str(self[event])))
+ # Verify that {vif,vbd}_refs are here too
+ if 'vif_refs' not in self:
+ self['vif_refs'] = []
+ if 'vbd_refs' not in self:
+ self['vbd_refs'] = []
+
def device_add(self, dev_type, cfg_sxp = None, cfg_xenapi = None):
if dev_type not in XendDevices.valid_devices():
raise XendConfigError("XendConfig: %s not a valid device type" %
diff -r c0d9f8b9c0e5 -r c88a78f8bed9 tools/python/xen/xend/XendDomain.py
--- a/tools/python/xen/xend/XendDomain.py Fri Oct 06 12:46:46 2006 +0100
+++ b/tools/python/xen/xend/XendDomain.py Fri Oct 06 16:27:06 2006 +0100
@@ -563,22 +563,25 @@ class XendDomain:
finally:
self.domains_lock.release()
- def get_dev_by_uuid(self, klass, dev_uuid, field):
- parts = dev_uuid.split('-%s-' % klass, 1)
- try:
- if len(parts) > 1:
- dom = self.get_vm_by_uuid(parts[0])
- if not dom:
- return None
-
- if field == 'VM':
- return dom.get_uuid()
- if field == 'uuid':
- return dev_uuid
-
- devid = int(parts[1])
- value = dom.get_device_property(klass, devid, field)
- return value
+ def get_vm_with_dev_uuid(self, klass, dev_uuid):
+ self.domains_lock.acquire()
+ try:
+ for dom in self.domains.values():
+ if dom.has_device(klass, dev_uuid):
+ return dom
+ return None
+ finally:
+ self.domains_lock.release()
+
+ def get_dev_property_by_uuid(self, klass, dev_uuid, field):
+ self.domains_lock.acquire()
+ try:
+ dom = self.get_vm_with_dev_uuid(klass, dev_uuid)
+ if not dom:
+ return None
+
+ value = dom.get_device_property(klass, devid, field)
+ return value
except ValueError, e:
pass
@@ -588,18 +591,7 @@ class XendDomain:
return (self.get_vm_by_uuid(vm_ref) != None)
def is_valid_dev(self, klass, dev_uuid):
- parts = dev_uuid.split('-%s-' % klass, 1)
- try:
- if len(parts) > 1:
- dom = self.get_vm_by_uuid(parts[0])
- if not dom:
- return False
- devid = int(parts[1])
- return dom.isDeviceValid(klass, devid)
- except ValueError, e:
- pass
-
- return False
+ return (self.get_vm_with_dev_uuid(klass, dev_uuid) != None)
def do_legacy_api_with_uuid(self, fn, vm_uuid, *args):
self.domains_lock.acquire()
diff -r c0d9f8b9c0e5 -r c88a78f8bed9 tools/python/xen/xend/XendDomainInfo.py
--- a/tools/python/xen/xend/XendDomainInfo.py Fri Oct 06 12:46:46 2006 +0100
+++ b/tools/python/xen/xend/XendDomainInfo.py Fri Oct 06 16:27:06 2006 +0100
@@ -1709,54 +1709,73 @@ class XendDomainInfo:
return XEN_API_ON_CRASH_BEHAVIOUR.index(self.info['on_crash'])
except ValueError, e:
return XEN_API_ON_CRASH_BEHAVIOUR.index('destroy')
-
-
- def get_device_property(self, devclass, devid, field):
- controller = self.getDeviceController(devclass)
-
- if devclass == 'vif':
- if field in ('name', 'MAC', 'type'):
- config = controller.getDeviceConfiguration(devid)
- if field == 'name':
- return config['vifname']
- if field == 'mac':
- return config['mac']
- if field == 'type':
- return config['type']
- if field == 'device':
- return 'eth%s' % devid
- if field == 'network':
- return None # TODO
- if field == 'VM':
- return self.get_uuid()
- if field == 'MTU':
- return 0 # TODO
- # TODO: network bandwidth values
- return 0.0
-
- if devclass == 'vbd':
- if field == 'VM':
- return self.get_uuid()
- if field == 'VDI':
- return '' # TODO
- if field in ('device', 'mode', 'driver'):
- config = controller.getDeviceConfiguration(devid)
- if field == 'device':
- return config['dev'] # TODO
- if field == 'mode':
- return config['mode']
- if field == 'driver':
- return config['uname'] # TODO
-
- # TODO network bandwidth values
- return 0.0
-
- raise XendError("Unrecognised dev class or property")
-
-
- def is_device_valid(self, devclass, devid):
- controller = self.getDeviceController(devclass)
- return (devid in controller.deviceIDs())
+
+ def get_dev_config_by_uuid(self, dev_class, dev_uuid):
+ """ Get's a device configuration either from XendConfig or
+ from the DevController."""
+ if self.get_power_state() not in ('Halted',):
+ dev = self.info['device'].get(dev_uuid)
+ if dev:
+ return dev[1].copy()
+ return None
+ else:
+ controller = self.getDeviceController(dev_class)
+ if not controller:
+ return None
+ all_configs = controller.getAllDeviceConfigurations()
+ if not all_configs:
+ return None
+ for _devid, _devcfg in all_configs.items():
+ if _devcfg.get('uuid') == dev_uuid:
+ devcfg = _devcfg.copy()
+ devcfg['id'] = _devid
+ return devcfg
+
+ return None
+
+ def get_dev_xenapi_config(self, dev_class, dev_uuid):
+ config = self.get_dev_config_by_uuid(dev_class, dev_uuid)
+ if not config:
+ return {}
+
+ config['VM'] = self.get_uuid()
+
+ if dev_class == 'vif':
+ if not config.has_key('name'):
+ config['name'] = config.get('vifname', '')
+ if not config.has_key('MAC'):
+ config['MAC'] = config.get('mac', '')
+ if not config.has_key('type'):
+ config['type'] = 'paravirtualised'
+ if not config.has_key('device'):
+ devid = config.get('id')
+ if devid != None:
+ config['device'] = 'eth%d' % devid
+ else:
+ config['device'] = ''
+
+ config['network'] = '' # Invalid for Xend
+ config['MTU'] = 1500 # TODO
+ config['network_read_kbs'] = 0.0
+ config['network_write_kbs'] = 0.0
+ config['IO_bandwidth_incoming_kbs'] = 0.0
+ config['IO_bandwidth_outgoing_kbs'] = 0.0
+
+ if dev_class == 'vbd':
+ config['VDI'] = '' # TODO
+ config['device'] = config.get('dev', '')
+ config['driver'] = config.get('uname', '')
+ config['IO_bandwidth_incoming_kbs'] = 0.0
+ config['IO_bandwidth_outgoing_kbs'] = 0.0
+
+ return config
+
+ def get_dev_property(self, dev_class, dev_uuid, field):
+ config = self.get_dev_xenapi_config(dev_class, dev_uuid)
+ try:
+ return config[field]
+ except KeyError:
+ raise XendError('Invalid property for device: %s' % field)
def get_vcpus_util(self):
# TODO: this returns the total accum cpu time, rather than util
@@ -1806,7 +1825,9 @@ class XendDomainInfo:
raise XendError("Device creation failed")
return dev_uuid
-
+
+ def has_device(self, dev_class, dev_uuid):
+ return (dev_uuid in self.info['%s_refs' % dev_class])
"""
def stateChar(name):
diff -r c0d9f8b9c0e5 -r c88a78f8bed9
tools/python/xen/xend/server/DevController.py
--- a/tools/python/xen/xend/server/DevController.py Fri Oct 06 12:46:46
2006 +0100
+++ b/tools/python/xen/xend/server/DevController.py Fri Oct 06 16:27:06
2006 +0100
@@ -255,6 +255,13 @@ class DevController:
raise VmError("Device %s not connected" % devid)
return {'backend': int(backdomid)}
+
+ def getAllDeviceConfigurations(self):
+ all_configs = {}
+ for devid in self.deviceIDs():
+ config_dict = self.getDeviceConfiguration(devid)
+ all_configs[devid] = config_dict
+ return all_configs
## protected:
_______________________________________________
Xen-changelog mailing list
Xen-changelog@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-changelog
|
 |
Lists.xenproject.org is hosted with RackSpace, monitoring our |