12:30 p.m.
The initial propose was to extend this task to network pools, but, they
already check if guests or templates are linked before deleting.
Signed-off-by: Ramon Medeiros <ramonn(a)linux.vnet.ibm.com>
---
i18n.py | 1 +
model/storagepools.py | 21 +++++++++++++++++++++
2 files changed, 22 insertions(+)
diff --git a/i18n.py b/i18n.py
index 7625469..f1db243 100644
--- a/i18n.py
+++ b/i18n.py
@@ -225,6 +225,7 @@ messages = {
"KCHPOOL0036E": _("A volume group named '%(name)s' already
exists. Please, choose another name to create the logical pool."),
"KCHPOOL0037E": _("Unable to update database with deep scan
information due error: %(err)s"),
"KCHPOOL0038E": _("No volume group '%(name)s' found. Please,
specify an existing volume group to create the logical pool from."),
+ "KCHPOOL0039E": _("Unable to delete pool %(name)s as it is associated
with guests: %(vms)s"),
"KCHVOL0001E": _("Storage volume %(name)s already exists"),
"KCHVOL0002E": _("Storage volume %(name)s does not exist in storage
pool %(pool)s"),
diff --git a/model/storagepools.py b/model/storagepools.py
index a2dbaec..f8c1fe4 100644
--- a/model/storagepools.py
+++ b/model/storagepools.py
@@ -471,6 +471,11 @@ class StoragePoolModel(object):
if self._pool_used_by_template(name):
raise InvalidOperation('KCHPOOL0035E', {'name': name})
+ vms = self._get_vms_attach_to_storagepool(name)
+ if len(vms) > 0:
+ raise InvalidOperation('KCHPOOL0039E', {'name': name,
+ 'vms':
",".join(vms)})
+
pool = self.get_storagepool(name, self.conn)
if pool.isActive():
raise InvalidOperation("KCHPOOL0005E", {'name': name})
@@ -480,6 +485,22 @@ class StoragePoolModel(object):
raise OperationFailed("KCHPOOL0011E",
{'name': name, 'err':
e.get_error_message()})
+ def _get_vms_attach_to_storagepool(self, storagepool):
+ conn = self.conn.get()
+
+ # get storage pool path
+ stpool = self.get_storagepool(storagepool, self.conn)
+ path = "".join(xpath_get_text(stpool.XMLDesc(),
"/pool/target/path"))
+
+ vms = []
+ for dom in conn.listAllDomains(0):
+ xml = dom.XMLDesc(0)
+ files = "/domain/devices/disk/source/@file"
+ for file in xpath_get_text(xml, files):
+ if file.startswith(path):
+ vms.append(dom.name())
+ return vms
+
class IsoPoolModel(object):
def __init__(self, **kargs):
--
2.5.5