f85e0ffa91
Notes on enabling consistency groups in devstack: http://docs.openstack.org/admin-guide/blockstorage-consistency-groups.html You'll also need to modify the local cinder policy file. Though that's not actually enough to make it work since devstack only provides the LVM volume type and CGs don't work with LVM. You can attempt to create CGs, but they will error. Change-Id: I0ab541c81570cd5f67bb7d04c01bc92bc5cc3ab5 Implements: blueprint reorganise-volumes
321 lines
13 KiB
Python
321 lines
13 KiB
Python
# 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 django.core.urlresolvers import reverse
|
|
from django import http
|
|
from django.utils.http import urlunquote
|
|
from mox3.mox import IsA # noqa
|
|
|
|
from openstack_dashboard.api import cinder
|
|
from openstack_dashboard.test import helpers as test
|
|
|
|
|
|
INDEX_URL = reverse('horizon:project:cgroups:index')
|
|
VOLUME_CGROUPS_SNAP_TAB_URL = urlunquote(reverse(
|
|
'horizon:project:volumes:cg_snapshots_tab'))
|
|
|
|
|
|
class ConsistencyGroupTests(test.TestCase):
|
|
@test.create_stubs({cinder: ('extension_supported',
|
|
'availability_zone_list',
|
|
'volume_type_list',
|
|
'volume_type_list_with_qos_associations',
|
|
'volume_cgroup_list',
|
|
'volume_cgroup_create')})
|
|
def test_create_cgroup(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
volume_types = self.cinder_volume_types.list()
|
|
volume_type_id = self.cinder_volume_types.first().id
|
|
az = self.cinder_availability_zones.first().zoneName
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG',
|
|
'description': 'test desc',
|
|
'availability_zone': az,
|
|
'add_vtypes_to_cgroup_role_member': [volume_type_id]}
|
|
|
|
cinder.extension_supported(IsA(http.HttpRequest), 'AvailabilityZones')\
|
|
.AndReturn(True)
|
|
cinder.availability_zone_list(IsA(http.HttpRequest)).AndReturn(
|
|
self.cinder_availability_zones.list())
|
|
cinder.volume_type_list(IsA(http.HttpRequest)).AndReturn(volume_types)
|
|
cinder.volume_type_list_with_qos_associations(IsA(http.HttpRequest)).\
|
|
AndReturn(volume_types)
|
|
cinder.volume_cgroup_list(IsA(http.HttpRequest)).\
|
|
AndReturn(self.cinder_consistencygroups.list())
|
|
cinder.volume_cgroup_create(
|
|
IsA(http.HttpRequest),
|
|
formData['volume_types'],
|
|
formData['name'],
|
|
formData['description'],
|
|
availability_zone=formData['availability_zone'])\
|
|
.AndReturn(cgroup)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:create')
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('extension_supported',
|
|
'availability_zone_list',
|
|
'volume_type_list',
|
|
'volume_type_list_with_qos_associations',
|
|
'volume_cgroup_list',
|
|
'volume_cgroup_create')})
|
|
def test_create_cgroup_exception(self):
|
|
volume_types = self.cinder_volume_types.list()
|
|
volume_type_id = self.cinder_volume_types.first().id
|
|
az = self.cinder_availability_zones.first().zoneName
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG',
|
|
'description': 'test desc',
|
|
'availability_zone': az,
|
|
'add_vtypes_to_cgroup_role_member': [volume_type_id]}
|
|
|
|
cinder.extension_supported(IsA(http.HttpRequest), 'AvailabilityZones')\
|
|
.AndReturn(True)
|
|
cinder.availability_zone_list(IsA(http.HttpRequest)).AndReturn(
|
|
self.cinder_availability_zones.list())
|
|
cinder.volume_type_list(IsA(http.HttpRequest)).AndReturn(volume_types)
|
|
cinder.volume_type_list_with_qos_associations(IsA(http.HttpRequest)).\
|
|
AndReturn(volume_types)
|
|
cinder.volume_cgroup_list(IsA(http.HttpRequest)).\
|
|
AndReturn(self.cinder_consistencygroups.list())
|
|
cinder.volume_cgroup_create(
|
|
IsA(http.HttpRequest),
|
|
formData['volume_types'],
|
|
formData['name'],
|
|
formData['description'],
|
|
availability_zone=formData['availability_zone'])\
|
|
.AndRaise(self.exceptions.cinder)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:create')
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
self.assertIn("Unable to create consistency group.",
|
|
res.cookies.output())
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_get',
|
|
'volume_cgroup_delete')})
|
|
def test_delete_cgroup(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
|
|
cinder.volume_cgroup_get(IsA(http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_delete(IsA(http.HttpRequest), cgroup.id,
|
|
force=False)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:delete',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_get',
|
|
'volume_cgroup_delete')})
|
|
def test_delete_cgroup_force_flag(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
formData = {'delete_volumes': True}
|
|
|
|
cinder.volume_cgroup_get(IsA(http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_delete(IsA(http.HttpRequest), cgroup.id,
|
|
force=True)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:delete',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_get',
|
|
'volume_cgroup_delete')})
|
|
def test_delete_cgroup_exception(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
formData = {'delete_volumes': False}
|
|
|
|
cinder.volume_cgroup_get(IsA(http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_delete(IsA(http.HttpRequest),
|
|
cgroup.id,
|
|
force=False).\
|
|
AndRaise(self.exceptions.cinder)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:delete',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_update',
|
|
'volume_cgroup_get')})
|
|
def test_update_cgroup_add_vol(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
volume = self.cinder_volumes.first()
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG',
|
|
'description': 'test desc'}
|
|
|
|
cinder.volume_cgroup_get(IsA(
|
|
http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_update(
|
|
IsA(http.HttpRequest),
|
|
formData['name'],
|
|
formData['description'],
|
|
add_vols=volume)\
|
|
.AndReturn(cgroup)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:update',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_update',
|
|
'volume_cgroup_get')})
|
|
def test_update_cgroup_remove_vol(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
volume = self.cinder_volumes.first()
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG',
|
|
'description': 'test desc'}
|
|
|
|
cinder.volume_cgroup_get(IsA(
|
|
http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_update(
|
|
IsA(http.HttpRequest),
|
|
formData['name'],
|
|
formData['description'],
|
|
remove_vols=volume)\
|
|
.AndReturn(cgroup)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:update',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_update',
|
|
'volume_cgroup_get')})
|
|
def test_update_cgroup_name_and_description(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG-new',
|
|
'description': 'test desc-new'}
|
|
|
|
cinder.volume_cgroup_get(IsA(
|
|
http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_update(
|
|
IsA(http.HttpRequest),
|
|
formData['name'],
|
|
formData['description'])\
|
|
.AndReturn(cgroup)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:update',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_update',
|
|
'volume_cgroup_get')})
|
|
def test_update_cgroup_with_exception(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
formData = {'volume_types': '1',
|
|
'name': 'test CG-new',
|
|
'description': 'test desc-new'}
|
|
|
|
cinder.volume_cgroup_get(IsA(
|
|
http.HttpRequest), cgroup.id).\
|
|
AndReturn(cgroup)
|
|
cinder.volume_cgroup_update(
|
|
IsA(http.HttpRequest),
|
|
formData['name'],
|
|
formData['description'])\
|
|
.AndRaise(self.exceptions.cinder)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:update',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_get',)})
|
|
def test_detail_view_with_exception(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
|
|
cinder.volume_cgroup_get(IsA(http.HttpRequest), cgroup.id).\
|
|
AndRaise(self.exceptions.cinder)
|
|
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:detail',
|
|
args=[cgroup.id])
|
|
res = self.client.get(url)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cg_snapshot_create',)})
|
|
def test_create_snapshot(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
cg_snapshot = self.cinder_cg_snapshots.first()
|
|
formData = {'cgroup_id': cgroup.id,
|
|
'name': 'test CG Snapshot',
|
|
'description': 'test desc'}
|
|
|
|
cinder.volume_cg_snapshot_create(
|
|
IsA(http.HttpRequest),
|
|
formData['cgroup_id'],
|
|
formData['name'],
|
|
formData['description'])\
|
|
.AndReturn(cg_snapshot)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:create_snapshot',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, VOLUME_CGROUPS_SNAP_TAB_URL)
|
|
|
|
@test.create_stubs({cinder: ('volume_cgroup_get',
|
|
'volume_cgroup_create_from_source',)})
|
|
def test_create_clone(self):
|
|
cgroup = self.cinder_consistencygroups.first()
|
|
formData = {'cgroup_id': cgroup.id,
|
|
'name': 'test CG Clone',
|
|
'description': 'test desc'}
|
|
cinder.volume_cgroup_create_from_source(
|
|
IsA(http.HttpRequest),
|
|
formData['name'],
|
|
source_cgroup_id=formData['cgroup_id'],
|
|
description=formData['description'])\
|
|
.AndReturn(cgroup)
|
|
self.mox.ReplayAll()
|
|
|
|
url = reverse('horizon:project:cgroups:clone_cgroup',
|
|
args=[cgroup.id])
|
|
res = self.client.post(url, formData)
|
|
self.assertNoFormErrors(res)
|
|
self.assertRedirectsNoFollow(res, INDEX_URL)
|