Source code for heat.engine.resources.volume_base

#    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
#    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 oslo_config import cfg

from heat.common import exception
from heat.common.i18n import _
from heat.engine.clients import progress
from heat.engine import resource
from heat.engine import rsrc_defn

[docs]class BaseVolume(resource.Resource): """Base Volume Manager.""" default_client_name = 'cinder' def _create_arguments(self): return {}
[docs] def handle_create(self): backup_id = cinder = self.client() if backup_id is not None: vol_id = cinder.restores.restore(backup_id).volume_id vol = cinder.volumes.get(vol_id) kwargs = self._fetch_name_and_description() cinder.volumes.update(vol_id, **kwargs) else: kwargs = self._create_arguments() kwargs.update(self._fetch_name_and_description()) vol = cinder.volumes.create(**kwargs) self.resource_id_set( return
[docs] def check_create_complete(self, vol_id): vol = self.client().volumes.get(vol_id) if vol.status == 'available': return True if vol.status in self._volume_creating_status: return False if vol.status == 'error': raise exception.ResourceInError( resource_status=vol.status) else: raise exception.ResourceUnknownStatus( resource_status=vol.status, result=_('Volume create failed'))
def _name(self): return self.physical_resource_name() def _description(self): return self.physical_resource_name() def _fetch_name_and_description(self, name=None, description=None): return {'name': name or self._name(), 'description': description or self._description()}
[docs] def handle_check(self): vol = self.client().volumes.get(self.resource_id) statuses = ['available', 'in-use'] checks = [ {'attr': 'status', 'expected': statuses, 'current': vol.status}, ] self._verify_check_conditions(checks)
[docs] def handle_snapshot_delete(self, state): backup = state not in ((self.CREATE, self.FAILED), (self.UPDATE, self.FAILED)) prg = progress.VolumeDeleteProgress() prg.backup['called'] = not backup prg.backup['complete'] = not backup return prg
[docs] def handle_delete(self): if self.resource_id is None: return progress.VolumeDeleteProgress(True) prg = progress.VolumeDeleteProgress() prg.backup['called'] = True prg.backup['complete'] = True return prg
def _create_backup(self): backup = self.client().backups.create(self.resource_id) return def _check_create_backup_complete(self, prg): backup = self.client().backups.get(prg.backup_id) if backup.status == 'creating': return False if backup.status == 'available': return True else: raise exception.ResourceUnknownStatus( resource_status=backup.status, result=_('Volume backup failed')) def _delete_volume(self): """Call the volume delete API. Returns False if further checking of volume status is required, True otherwise. """ try: cinder = self.client() vol = cinder.volumes.get(self.resource_id) if vol.status == 'in-use': raise exception.Error(_('Volume in use')) # if the volume is already in deleting status, # just wait for the deletion to complete if vol.status != 'deleting': cinder.volumes.delete(self.resource_id) return False except Exception as ex: self.client_plugin().ignore_not_found(ex) return True
[docs] def check_delete_complete(self, prg): if not prg.backup['called']: prg.backup_id = self._create_backup() prg.backup['called'] = True return False if not prg.backup['complete']: prg.backup['complete'] = self._check_create_backup_complete(prg) return False if not prg.delete['called']: prg.delete['complete'] = self._delete_volume() prg.delete['called'] = True return False if not prg.delete['complete']: try: vol = self.client().volumes.get(self.resource_id) except Exception as ex: self.client_plugin().ignore_not_found(ex) prg.delete['complete'] = True return True if vol.status.lower() == 'error_deleting': raise exception.ResourceInError(status_reason='delete', resource_status=vol.status) else: return False return True
[docs] @classmethod def validate_deletion_policy(cls, policy): res = super(BaseVolume, cls).validate_deletion_policy(policy) if res: return res if (policy == rsrc_defn.ResourceDefinition.SNAPSHOT and not cfg.CONF.volumes.backups_enabled): msg = _('"%s" deletion policy not supported - ' 'volume backup service is not enabled.') % policy raise exception.StackValidationFailed(message=msg)
[docs]class BaseVolumeAttachment(resource.Resource): """Base Volume Attachment Manager.""" default_client_name = 'cinder'
[docs] def handle_create(self): server_id =[self.INSTANCE_ID] volume_id =[self.VOLUME_ID] dev = ([self.DEVICE] if[self.DEVICE] else None) attach_id = self.client_plugin('nova').attach_volume( server_id, volume_id, dev) self.resource_id_set(attach_id) return volume_id
[docs] def check_create_complete(self, volume_id): return self.client_plugin().check_attach_volume_complete(volume_id)
[docs] def handle_delete(self): prg = None if self.resource_id: server_id =[self.INSTANCE_ID] vol_id =[self.VOLUME_ID] self.client_plugin('nova').detach_volume(server_id, self.resource_id) prg = progress.VolumeDetachProgress( server_id, vol_id, self.resource_id) prg.called = True return prg
[docs] def check_delete_complete(self, prg): if prg is None: return True if not prg.cinder_complete: prg.cinder_complete = self.client_plugin( ).check_detach_volume_complete(prg.vol_id, prg.srv_id) return False if not prg.nova_complete: prg.nova_complete = self.client_plugin( 'nova').check_detach_volume_complete(prg.srv_id, prg.attach_id) return prg.nova_complete return True