valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 17:33:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

zpool.online slipped through the cleanup cracks

Browse Source
This commit is contained in:
Jorge Schrauwen 2015-12-22 11:30:58 +00:00
parent c41637593d
commit 9204b3c626
1 changed files with 12 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
salt/modules/zpool.py
View File

@ -781,6 +781,7 @@ def add(zpool, *vdevs, **kwargs):
else:
ret[zpool] = {}
for device in dlist:
if device not in ['mirror', 'log', 'cache', 'raidz1', 'raidz2', 'raidz3', 'spare']:
ret[zpool][device] = 'added'
return ret
@ -1182,19 +1183,15 @@ def online(zpool, *vdevs, **kwargs):
ret[zpool] = {}
for vdev in vdevs:
if not os.path.exists(vdev):
if 'devices' not in ret[zpool]:
ret[zpool]['devices'] = {}
ret[zpool]['devices'][vdev] = 'not present on filesystem'
ret[zpool][vdev] = 'not present on filesystem'
continue
mode = os.stat(vdev).st_mode
if not stat.S_ISBLK(mode) and not stat.S_ISREG(mode):
if 'devices' not in ret[zpool]:
ret[zpool]['devices'] = {}
ret[zpool]['devices'][vdev] = 'not a block device, a file vdev or character special device'
ret[zpool][vdev] = 'not a block device, a file vdev or character special device'
continue
dlist.append(vdev)
if 'devices' in ret[zpool]:
if len(ret[zpool]) > 0:
return ret
devs = ' '.join(dlist)
@ -1212,6 +1209,7 @@ def online(zpool, *vdevs, **kwargs):
else:
ret[zpool] = {}
for device in dlist:
if device not in ['mirror', 'log', 'cache', 'raidz1', 'raidz2', 'raidz3', 'spare']:
ret[zpool][device] = 'onlined'
return ret
@ -1242,21 +1240,20 @@ def offline(zpool, *vdevs, **kwargs):
salt '*' zpool.offline myzpool /path/to/vdev1 [...] [temporary=True|False]
'''
ret = {}
dlist = []
# Check if the pool_name exists
if not exists(zpool):
ret[zpool] = 'storage pool does not exist'
return ret
if not vdevs:
if not vdevs or len(vdevs) <= 0:
ret[zpool] = 'no devices specified'
return ret
# note: we don't check if the device exists
# a device can be offlined until a replacement is available
ret[zpool] = {}
devs = ' '.join(dlist)
devs = ' '.join(vdevs)
zpool_cmd = _check_zpool()
cmd = '{zpool_cmd} offline {temp}{zpool} {devs}'.format(
zpool_cmd=zpool_cmd,
@ -1270,7 +1267,8 @@ def offline(zpool, *vdevs, **kwargs):
ret[zpool] = res['stderr'] if 'stderr' in res else res['stdout']
else:
ret[zpool] = {}
for device in dlist:
for device in vdevs:
if device not in ['mirror', 'log', 'cache', 'raidz1', 'raidz2', 'raidz3', 'spare']:
ret[zpool][device] = 'offlined'
return ret