spdkcli: Add try-except section to delete_all commands

Call delete method for all objects in delete_all commands

Change-Id: Ib7eb05334b88aba214f1d28897e7e107f14c7cb8
Signed-off-by: Pawel Kaminski <pawelx.kaminski@intel.com>
Reviewed-on: https://review.gerrithub.io/c/444293 (master)
Reviewed-on: https://review.gerrithub.io/c/spdk/spdk/+/447604
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: Ben Walker <benjamin.walker@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
Reviewed-by: Darek Stojaczyk <dariusz.stojaczyk@intel.com>
This commit is contained in:
Pawel Kaminski 2019-02-12 16:32:22 -05:00 committed by Jim Harris
parent c2ed724e3b
commit 83bbb8bb4b
3 changed files with 52 additions and 13 deletions

View File

@ -119,7 +119,10 @@ class UILvolStores(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
for lvs in self._children: for lvs in self._children:
self.delete(None, lvs.lvs.uuid) try:
self.delete(None, lvs.lvs.uuid)
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Lvol stores: %s" % len(self.children), None return "Lvol stores: %s" % len(self.children), None
@ -142,7 +145,10 @@ class UIBdev(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all bdevs from this tree node.""" """Delete all bdevs from this tree node."""
for bdev in self._children: for bdev in self._children:
self.delete(bdev.name) try:
self.delete(bdev.name)
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Bdevs: %d" % len(self.children), None return "Bdevs: %d" % len(self.children), None
@ -288,7 +294,10 @@ class UINvmeBdev(UIBdev):
ctrlrs = [x.rsplit("n", 1)[0] for x in ctrlrs] ctrlrs = [x.rsplit("n", 1)[0] for x in ctrlrs]
ctrlrs = set(ctrlrs) ctrlrs = set(ctrlrs)
for ctrlr in ctrlrs: for ctrlr in ctrlrs:
self.delete(ctrlr) try:
self.delete(ctrlr)
except JSONRPCException as e:
self.shell.log.error(e.message)
def ui_command_delete(self, name): def ui_command_delete(self, name):
""" """

View File

@ -126,7 +126,10 @@ class UIISCSIDevices(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all target nodes""" """Delete all target nodes"""
for device in self.scsi_devices: for device in self.scsi_devices:
self.delete(device.device_name) try:
self.delete(device.device_name)
except JSONRPCException as e:
self.shell.log.error(e.message)
def ui_command_add_lun(self, name, bdev_name, lun_id=None): def ui_command_add_lun(self, name, bdev_name, lun_id=None):
"""Add lun to the target node. """Add lun to the target node.
@ -315,13 +318,19 @@ class UIPortalGroups(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all portal groups""" """Delete all portal groups"""
for pg in self.pgs: for pg in self.pgs:
self.delete(pg.tag) try:
self.delete(pg.tag)
except JSONRPCException as e:
self.shell.log.error(e.message)
def refresh(self): def refresh(self):
self._children = set([]) self._children = set([])
self.pgs = list(self.get_root().get_portal_groups()) self.pgs = list(self.get_root().get_portal_groups())
for pg in self.pgs: for pg in self.pgs:
UIPortalGroup(pg, self) try:
UIPortalGroup(pg, self)
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Portal groups: %d" % len(self.pgs), None return "Portal groups: %d" % len(self.pgs), None
@ -384,7 +393,10 @@ class UIInitiatorGroups(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all initiator groups""" """Delete all initiator groups"""
for ig in self.igs: for ig in self.igs:
self.delete(ig.tag) try:
self.delete(ig.tag)
except JSONRPCException as e:
self.shell.log.error(e.message)
def ui_command_add_initiator(self, tag, initiators, netmasks): def ui_command_add_initiator(self, tag, initiators, netmasks):
"""Add initiators to an existing initiator group. """Add initiators to an existing initiator group.
@ -531,7 +543,10 @@ class UIISCSIAuthGroups(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all authentication groups.""" """Delete all authentication groups."""
for iscsi_auth_group in self.iscsi_auth_groups: for iscsi_auth_group in self.iscsi_auth_groups:
self.delete(iscsi_auth_group['tag']) try:
self.delete(iscsi_auth_group['tag'])
except JSONRPCException as e:
self.shell.log.error(e.message)
def ui_command_add_secret(self, tag, user, secret, def ui_command_add_secret(self, tag, user, secret,
muser=None, msecret=None): muser=None, msecret=None):
@ -570,7 +585,10 @@ class UIISCSIAuthGroups(UINode):
for ag in self.iscsi_auth_groups: for ag in self.iscsi_auth_groups:
if ag['tag'] == tag: if ag['tag'] == tag:
for secret in ag['secrets']: for secret in ag['secrets']:
self.delete_secret(tag, secret['user']) try:
self.delete_secret(tag, secret['user'])
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Groups: %s" % len(self.iscsi_auth_groups), None return "Groups: %s" % len(self.iscsi_auth_groups), None

View File

@ -103,7 +103,10 @@ class UINVMfSubsystems(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all subsystems""" """Delete all subsystems"""
for child in self._children: for child in self._children:
self.delete(child.subsystem.nqn) try:
self.delete(child.subsystem.nqn)
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Subsystems: %s" % len(self.children), None return "Subsystems: %s" % len(self.children), None
@ -204,7 +207,10 @@ class UINVMfSubsystemListeners(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Remove all address listeners from subsystem.""" """Remove all address listeners from subsystem."""
for la in self.listen_addresses: for la in self.listen_addresses:
self.delete(la['trtype'], la['traddr'], la['trsvcid'], la['adrfam']) try:
self.delete(la['trtype'], la['traddr'], la['trsvcid'], la['adrfam'])
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Addresses: %s" % len(self.listen_addresses), None return "Addresses: %s" % len(self.listen_addresses), None
@ -261,7 +267,10 @@ class UINVMfSubsystemHosts(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete host from subsystem""" """Delete host from subsystem"""
for host in self.hosts: for host in self.hosts:
self.delete(host['nqn']) try:
self.delete(host['nqn'])
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Hosts: %s" % len(self.hosts), None return "Hosts: %s" % len(self.hosts), None
@ -323,7 +332,10 @@ class UINVMfSubsystemNamespaces(UINode):
def ui_command_delete_all(self): def ui_command_delete_all(self):
"""Delete all namespaces from subsystem.""" """Delete all namespaces from subsystem."""
for namespace in self.namespaces: for namespace in self.namespaces:
self.delete(namespace['nsid']) try:
self.delete(namespace['nsid'])
except JSONRPCException as e:
self.shell.log.error(e.message)
def summary(self): def summary(self):
return "Namespaces: %s" % len(self.namespaces), None return "Namespaces: %s" % len(self.namespaces), None