attachments = []

attached_servers = []

for attachment in info['attachments']:

attachments.append(attachment['attachment_id'])

attached_servers.append(attachment['server_id'])

info.pop('attachments', None)

info['attachment_ids'] = attachments

info['attached_servers'] = attached_servers

"""Lists all volumes."""

# NOTE(thingee): Backwards-compatibility with v1 args

if args.display_name is not None:

args.name = args.display_name

all_tenants = 1 if args.tenant else \

int(os.environ.get("ALL_TENANTS", args.all_tenants))

search_opts = {

'all_tenants': all_tenants,

'project_id': args.tenant,

'name': args.name,

'status': args.status,

'bootable': args.bootable,

'migration_status': args.migration_status,

'metadata': (shell_utils.extract_metadata(args) if args.metadata

else None),

}

# If unavailable/non-existent fields are specified, these fields will

# be removed from key_list at the print_list() during key validation.

field_titles = []

if args.fields:

for field_title in args.fields.split(','):

field_titles.append(field_title)

volumes = cs.volumes.list(search_opts=search_opts, marker=args.marker,

limit=args.limit, sort=args.sort)

shell_utils.translate_volume_keys(volumes)

# Create a list of servers to which the volume is attached

for vol in volumes:

servers = [s.get('server_id') for s in vol.attachments]

setattr(vol, 'attached_to', ','.join(map(str, servers)))

if field_titles:

# Remove duplicate fields

key_list = ['ID']

unique_titles = [k for k in collections.OrderedDict.fromkeys(

[x.title().strip() for x in field_titles]) if k != 'Id']

key_list.extend(unique_titles)

else:

key_list = ['ID', 'Status', 'Name', 'Size', 'Volume Type',

'Bootable', 'Attached to']

# If all_tenants is specified, print

# Tenant ID as well.

if search_opts['all_tenants']:

key_list.insert(1, 'Tenant ID')

if args.sort:

sortby_index = None

else:

sortby_index = 0

shell_utils.print_list(volumes, key_list, exclude_unavailable=True,

"""Shows volume details."""

info = dict()

volume = utils.find_volume(cs, args.volume)

info.update(volume._info)

if 'readonly' in info['metadata']:

info['readonly'] = info['metadata']['readonly']

info.pop('links', None)

info = _translate_attachments(info)

shell_utils.print_dict(info,

formatters=['metadata', 'volume_image_metadata',

def __call__(self, parser, args, values, option_string=None):

if ((args.snapshot_id or args.source_volid)

is None and values is None):

if not hasattr(args, 'backup_id') or args.backup_id is None:

parser.error('Size is a required parameter if snapshot '

'or source volume or backup is not specified.')

"""Creates a volume."""

# NOTE(thingee): Backwards-compatibility with v1 args

if args.display_name is not None:

args.name = args.display_name

if args.display_description is not None:

args.description = args.display_description

volume_metadata = None

if args.metadata is not None:

volume_metadata = shell_utils.extract_metadata(args)

# NOTE(N.S.): take this piece from novaclient

hints = {}

if args.scheduler_hints:

for hint in args.scheduler_hints:

key, _sep, value = hint.partition('=')

# NOTE(vish): multiple copies of same hint will

# result in a list of values

if key in hints:

if isinstance(hints[key], str):

hints[key] = [hints[key]]

hints[key] += [value]

else:

hints[key] = value

# NOTE(N.S.): end of taken piece

# Keep backward compatibility with image_id, favoring explicit ID

image_ref = args.image_id or args.image or args.image_ref

volume = cs.volumes.create(args.size,

args.consisgroup_id,

args.snapshot_id,

args.source_volid,

args.name,

args.description,

args.volume_type,

availability_zone=args.availability_zone,

imageRef=image_ref,

metadata=volume_metadata,

scheduler_hints=hints)

info = dict()

volume = cs.volumes.get(volume.id)

info.update(volume._info)

if 'readonly' in info['metadata']:

info['readonly'] = info['metadata']['readonly']

info.pop('links', None)

info = _translate_attachments(info)

"""Removes one or more volumes."""

failure_count = 0

for volume in args.volume:

try:

utils.find_volume(cs, volume).delete(cascade=args.cascade)

print("Request to delete volume %s has been accepted." % (volume))

except Exception as e:

failure_count += 1

print("Delete for volume %s failed: %s" % (volume, e))

if failure_count == len(args.volume):

raise exceptions.CommandError("Unable to delete any of the specified "

"""Attempts force-delete of volume, regardless of state."""

failure_count = 0

for volume in args.volume:

try:

utils.find_volume(cs, volume).force_delete()

except Exception as e:

failure_count += 1

print("Delete for volume %s failed: %s" % (volume, e))

if failure_count == len(args.volume):

raise exceptions.CommandError("Unable to force delete any of the "

"""Explicitly updates the volume state in the Cinder database.

failure_flag = False

migration_status = 'none' if args.reset_migration_status else None

if not (args.state or args.attach_status or migration_status):

# Nothing specified, default to resetting state

args.state = 'available'

for volume in args.volume:

try:

utils.find_volume(cs, volume).reset_state(args.state,

args.attach_status,

migration_status)

except Exception as e:

failure_flag = True

msg = "Reset state for volume %s failed: %s" % (volume, e)

print(msg)

if failure_flag:

msg = "Unable to reset the state for the specified volume(s)."

"""Renames a volume."""

kwargs = {}

if args.name is not None:

kwargs['name'] = args.name

if args.display_description is not None:

kwargs['description'] = args.display_description

elif args.description is not None:

kwargs['description'] = args.description

if not any(kwargs):

msg = 'Must supply either name or description.'

raise exceptions.ClientException(code=1, message=msg)

"""Sets or deletes volume metadata."""

volume = utils.find_volume(cs, args.volume)

metadata = shell_utils.extract_metadata(args)

if args.action == 'set':

cs.volumes.set_metadata(volume, metadata)

elif args.action == 'unset':

# NOTE(zul): Make sure py2/py3 sorting is the same

cs.volumes.delete_metadata(volume, sorted(metadata.keys(),

"""Sets or deletes volume image metadata."""

volume = utils.find_volume(cs, args.volume)

metadata = shell_utils.extract_metadata(args)

if args.action == 'set':

cs.volumes.set_image_metadata(volume, metadata)

elif args.action == 'unset':

cs.volumes.delete_image_metadata(volume, sorted(metadata.keys(),

"""Lists all snapshots."""

all_tenants = (1 if args.tenant else

int(os.environ.get("ALL_TENANTS", args.all_tenants)))

if args.display_name is not None:

args.name = args.display_name

search_opts = {

'all_tenants': all_tenants,

'name': args.name,

'status': args.status,

'volume_id': args.volume_id,

'project_id': args.tenant,

}

snapshots = cs.volume_snapshots.list(search_opts=search_opts,

marker=args.marker,

limit=args.limit,

sort=args.sort)

shell_utils.translate_volume_snapshot_keys(snapshots)

if args.sort:

sortby_index = None

else:

sortby_index = 0

shell_utils.print_list(snapshots,

['ID', 'Volume ID', 'Status', 'Name', 'Size'],

"""Removes one or more snapshots."""

failure_count = 0

for snapshot in args.snapshot:

try:

shell_utils.find_volume_snapshot(cs, snapshot).delete(args.force)

except Exception as e:

failure_count += 1

print("Delete for snapshot %s failed: %s" % (snapshot, e))

if failure_count == len(args.snapshot):

raise exceptions.CommandError("Unable to delete any of the specified "

"""Renames a snapshot."""

kwargs = {}

if args.name is not None:

kwargs['name'] = args.name

if args.description is not None:

kwargs['description'] = args.description

elif args.display_description is not None:

kwargs['description'] = args.display_description

if not any(kwargs):

msg = 'Must supply either name or description.'

raise exceptions.ClientException(code=1, message=msg)

shell_utils.find_volume_snapshot(cs, args.snapshot).update(**kwargs)

print("Request to rename snapshot '%s' has been accepted." % (

"""Explicitly updates the snapshot state."""

failure_count = 0

single = (len(args.snapshot) == 1)

for snapshot in args.snapshot:

try:

shell_utils.find_volume_snapshot(

cs, snapshot).reset_state(args.state)

except Exception as e:

failure_count += 1

msg = "Reset state for snapshot %s failed: %s" % (snapshot, e)

if not single:

print(msg)

if failure_count == len(args.snapshot):

if not single:

msg = ("Unable to reset the state for any of the specified "

"snapshots.")

"""Lists available 'volume types'.

vtypes = cs.volume_types.list()

"""List the default volume type.

vtype = cs.volume_types.default()

"""Show volume type details."""

vtype = shell_utils.find_vtype(cs, args.volume_type)

info = dict()

info.update(vtype._info)

info.pop('links', None)

"""Updates volume type name, description, and/or is_public."""

is_public = args.is_public

if args.name is None and args.description is None and is_public is None:

raise exceptions.CommandError('Specify a new type name, description, '

'is_public or a combination thereof.')

if is_public is not None:

is_public = strutils.bool_from_string(args.is_public, strict=True)

vtype = cs.volume_types.update(args.id, args.name, args.description,

is_public)

"""Creates a volume type."""

is_public = strutils.bool_from_string(args.is_public, strict=True)

vtype = cs.volume_types.create(args.name, args.description, is_public)

"""Deletes volume type or types."""

failure_count = 0

for vol_type in args.vol_type:

try:

vtype = shell_utils.find_volume_type(cs, vol_type)

cs.volume_types.delete(vtype)

print("Request to delete volume type %s has been accepted."

% (vol_type))

except Exception as e:

failure_count += 1

print("Delete for volume type %s failed: %s" % (vol_type, e))

if failure_count == len(args.vol_type):

raise exceptions.CommandError("Unable to delete any of the "

"""Sets or unsets extra_spec for a volume type."""

vtype = shell_utils.find_volume_type(cs, args.vtype)

keypair = shell_utils.extract_metadata(args)

if args.action == 'set':

vtype.set_keys(keypair)

elif args.action == 'unset':

"""Print access information about the given volume type."""

volume_type = shell_utils.find_volume_type(cs, args.volume_type)

if volume_type.is_public:

raise exceptions.CommandError("Failed to get access list "

"for public volume type.")

access_list = cs.volume_type_access.list(volume_type)

columns = ['Volume_type_ID', 'Project_ID']

"""Removes volume type access for the given project."""

vtype = shell_utils.find_volume_type(cs, args.volume_type)

cs.volume_type_access.remove_project_access(

"""Lists absolute limits for a user."""

limits = cs.limits.get(args.tenant).absolute

columns = ['Name', 'Value']

"""Lists rate limits for a user."""

limits = cs.limits.get(args.tenant).rate

columns = ['Verb', 'URI', 'Value', 'Remain', 'Unit', 'Next_Available']