← Back to branch summary

~james-page/charm-helpers/neutron-packages

« back to all changes in this revision

Viewing changes to charmhelpers/contrib/openstack/utils.py

  • Committer: James Page
  • Date: 2013-10-28 11:23:15 UTC
  • mfrom: (59.2.2 openstack_storage_utils)
  • Revision ID: james.page@canonical.com-20131028112315-l1y1hl63ozho5epw
[gandelman-a] contrib.openstack.utils: Add ensure_block_device() + clean_storage()

Show diffs side-by-side

added added

removed removed

Lines of Context:
charmhelpers/contrib/openstack/utils.py
13
13
    config,
14
14
    log as juju_log,
15
15
    charm_dir,
16
 
)
17
 
 
18
 
from charmhelpers.core.host import (
19
 
    lsb_release,
20
 
)
21
 
 
22
 
from charmhelpers.fetch import (
23
 
    apt_install,
24
 
)
 
16
    ERROR,
 
17
    INFO
 
18
)
 
19
 
 
20
from charmhelpers.contrib.storage.linux.lvm import (
 
21
    deactivate_lvm_volume_group,
 
22
    is_lvm_physical_volume,
 
23
    remove_lvm_physical_volume,
 
24
)
 
25
 
 
26
from charmhelpers.core.host import lsb_release, mounts, umount
 
27
from charmhelpers.fetch import apt_install
 
28
from charmhelpers.contrib.storage.linux.utils import is_block_device, zap_disk
 
29
from charmhelpers.contrib.storage.linux.loopback import ensure_loopback_device
25
30
 
26
31
CLOUD_ARCHIVE_URL = "http://ubuntu-cloud.archive.canonical.com/ubuntu"
27
32
CLOUD_ARCHIVE_KEY_ID = '5EDB1B62EC4926EA'
61
66
    ('1.9.0', 'havana'),
62
67
])
63
68
 
 
69
DEFAULT_LOOPBACK_SIZE = '5G'
 
70
 
64
71
 
65
72
def error_out(msg):
66
73
    juju_log("FATAL ERROR: %s" % msg, level='ERROR')
307
314
    return apt.version_compare(available_vers, cur_vers) == 1
308
315
 
309
316
 
 
317
def ensure_block_device(block_device):
 
318
    '''
 
319
    Confirm block_device, create as loopback if necessary.
 
320
 
 
321
    :param block_device: str: Full path of block device to ensure.
 
322
 
 
323
    :returns: str: Full path of ensured block device.
 
324
    '''
 
325
    _none = ['None', 'none', None]
 
326
    if (block_device in _none):
 
327
        error_out('prepare_storage(): Missing required input: '
 
328
                  'block_device=%s.' % block_device, level=ERROR)
 
329
 
 
330
    if block_device.startswith('/dev/'):
 
331
        bdev = block_device
 
332
    elif block_device.startswith('/'):
 
333
        _bd = block_device.split('|')
 
334
        if len(_bd) == 2:
 
335
            bdev, size = _bd
 
336
        else:
 
337
            bdev = block_device
 
338
            size = DEFAULT_LOOPBACK_SIZE
 
339
        bdev = ensure_loopback_device(bdev, size)
 
340
    else:
 
341
        bdev = '/dev/%s' % block_device
 
342
 
 
343
    if not is_block_device(bdev):
 
344
        error_out('Failed to locate valid block device at %s' % bdev,
 
345
                  level=ERROR)
 
346
 
 
347
    return bdev
 
348
 
 
349
 
 
350
def clean_storage(block_device):
 
351
    '''
 
352
    Ensures a block device is clean.  That is:
 
353
        - unmounted
 
354
        - any lvm volume groups are deactivated
 
355
        - any lvm physical device signatures removed
 
356
        - partition table wiped
 
357
 
 
358
    :param block_device: str: Full path to block device to clean.
 
359
    '''
 
360
    for mp, d in mounts():
 
361
        if d == block_device:
 
362
            juju_log('clean_storage(): %s is mounted @ %s, unmounting.' %
 
363
                     (d, mp), level=INFO)
 
364
            umount(mp, persist=True)
 
365
 
 
366
    if is_lvm_physical_volume(block_device):
 
367
        deactivate_lvm_volume_group(block_device)
 
368
        remove_lvm_physical_volume(block_device)
 
369
    else:
 
370
        zap_disk(block_device)
 
371
 
 
372
 
310
373
def is_ip(address):
311
374
    """
312
375
    Returns True if address is a valid IP address.