3fd7857a36
This patch adds the volume retype operation, which allows a user to change a given volume's type. When retyping, the scheduler checks if the volume's current host can accept the new type (i.e., it checks if the host passes the filters when using the new type). If the current host is suitable, its manager is called which calls upon the driver to change the volume's type. There are two cases where a retype operation may require migrating the volume: 1. The volume's current host cannot accept the new type 2. The volume's driver cannot perform the retype operation In case of a migration, a volume with the new type is created, and the data is migrated to it. Volume migrations resulting from retype can be controlled by passing a policy, which can be either: 1. 'never': Never migrate (the retype fails if migration is required) (default) 2. 'on-demand': Migrate when necessary This version will cause retype operations to fail if the current and new volume types have different: 1. QoS settings that are enforced by the front-end for in-use volumes. 2. encryption settings. Subsequent patches can address these cases. DocImpact Change-Id: I2dc99b4fa64d611d2bb936fc3890ca334e08bb55 Implements: blueprint volume-retype
65 lines
2.6 KiB
Python
65 lines
2.6 KiB
Python
# Copyright 2013 OpenStack Foundation
|
|
# All Rights Reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
from cinder import exception
|
|
from cinder.openstack.common import log as logging
|
|
from cinder import quota
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
QUOTAS = quota.QUOTAS
|
|
|
|
|
|
def get_volume_type_reservation(ctxt, volume, type_id):
|
|
# Reserve quotas for the given volume type
|
|
try:
|
|
reserve_opts = {'volumes': 1, 'gigabytes': volume['size']}
|
|
QUOTAS.add_volume_type_opts(ctxt,
|
|
reserve_opts,
|
|
type_id)
|
|
reservations = QUOTAS.reserve(ctxt, **reserve_opts)
|
|
except exception.OverQuota as e:
|
|
overs = e.kwargs['overs']
|
|
usages = e.kwargs['usages']
|
|
quotas = e.kwargs['quotas']
|
|
|
|
def _consumed(name):
|
|
return (usages[name]['reserved'] + usages[name]['in_use'])
|
|
|
|
for over in overs:
|
|
if 'gigabytes' in over:
|
|
s_size = volume['size']
|
|
d_quota = quotas[over]
|
|
d_consumed = _consumed(over)
|
|
msg = _("Quota exceeded for %(s_pid)s, tried to create "
|
|
"%(s_size)sG volume - (%(d_consumed)dG of "
|
|
"%(d_quota)dG already consumed)")
|
|
LOG.warn(msg % {'s_pid': ctxt.project_id,
|
|
's_size': s_size,
|
|
'd_consumed': d_consumed,
|
|
'd_quota': d_quota})
|
|
raise exception.VolumeSizeExceedsAvailableQuota(
|
|
requested=s_size, quota=d_quota, consumed=d_consumed)
|
|
elif 'volumes' in over:
|
|
msg = _("Quota exceeded for %(s_pid)s, tried to create "
|
|
"volume (%(d_consumed)d volumes "
|
|
"already consumed)")
|
|
|
|
LOG.warn(msg % {'s_pid': ctxt.project_id,
|
|
'd_consumed': _consumed(over)})
|
|
raise exception.VolumeLimitExceeded(
|
|
allowed=quotas[over])
|
|
return reservations
|