Do not pass rich objects on servers' delete

Partial-Bug: #1393268
Change-Id: I4034f48f75aad748ac313c385fa4f6b991cd4128
This commit is contained in:
Pavlo Shchelokovskyy 2015-05-29 18:13:40 +03:00
parent 101ba33853
commit 600608c845
8 changed files with 65 additions and 77 deletions

View File

@ -379,40 +379,29 @@ echo -e '%s\tALL=(ALL)\tNOPASSWD: ALL' >> /etc/sudoers
return mime_blob.as_string() return mime_blob.as_string()
def delete_server(self, server): def check_delete_server_complete(self, server_id):
''' """Wait for server to disappear from Nova."""
Deletes a server and waits for it to disappear from Nova. try:
''' server = self.fetch_server(server_id)
except Exception as exc:
self.ignore_not_found(exc)
return True
if not server: if not server:
return return False
try: status = self.get_status(server)
server.delete() if status in ("DELETED", "SOFT_DELETED"):
except Exception as exc: return True
self.ignore_not_found(exc) if status == 'ERROR':
return
while True:
yield
try:
self.refresh_server(server)
except Exception as exc:
self.ignore_not_found(exc)
break
else:
# Some clouds append extra (STATUS) strings to the status
short_server_status = server.status.split('(')[0]
if short_server_status in ("DELETED", "SOFT_DELETED"):
break
if short_server_status == "ERROR":
fault = getattr(server, 'fault', {}) fault = getattr(server, 'fault', {})
message = fault.get('message', 'Unknown') message = fault.get('message', 'Unknown')
code = fault.get('code') code = fault.get('code')
errmsg = (_("Server %(name)s delete failed: (%(code)s) " errmsg = _("Server %(name)s delete failed: (%(code)s) "
"%(message)s")) "%(message)s") % dict(name=server.name,
raise exception.Error(errmsg % {"name": server.name, code=code,
"code": code, message=message)
"message": message}) raise resource.ResourceInError(resource_status=status,
status_reason=errmsg)
return False
@scheduler.wrappertask @scheduler.wrappertask
def resize(self, server, flavor, flavor_id): def resize(self, server, flavor, flavor_id):

View File

@ -765,21 +765,16 @@ class Instance(resource.Resource):
if self.resource_id is None: if self.resource_id is None:
return return
try: try:
server = self.nova().servers.get(self.resource_id) self.client().servers.delete(self.resource_id)
except Exception as e: except Exception as e:
self.client_plugin().ignore_not_found(e) self.client_plugin().ignore_not_found(e)
return return
deleter = scheduler.TaskRunner(self.client_plugin().delete_server, return self.resource_id
server)
deleter.start()
return deleter
def check_delete_complete(self, deleter): def check_delete_complete(self, server_id):
# if the resource was already deleted, deleters will be None if not server_id:
if deleter:
if not deleter.step():
return False
return True return True
return self.client_plugin().check_delete_server_complete(server_id)
def handle_suspend(self): def handle_suspend(self):
''' '''

View File

@ -1341,19 +1341,16 @@ class Server(stack_user.StackUser):
self._delete_temp_url() self._delete_temp_url()
try: try:
server = self.nova().servers.get(self.resource_id) self.client().servers.delete(self.resource_id)
except Exception as e: except Exception as e:
self.client_plugin().ignore_not_found(e) self.client_plugin().ignore_not_found(e)
else: return
deleter = scheduler.TaskRunner(self.client_plugin().delete_server, return self.resource_id
server)
deleter.start()
return deleter
def check_delete_complete(self, deleter): def check_delete_complete(self, server_id):
if deleter is None or deleter.step(): if not server_id:
return True return True
return False return self.client_plugin().check_delete_server_complete(server_id)
def handle_suspend(self): def handle_suspend(self):
''' '''

View File

@ -623,12 +623,23 @@ class InstancesTest(common.HeatTestCase):
def test_instance_create_delete(self): def test_instance_create_delete(self):
self._test_instance_create_delete(vm_delete_status='DELETED') self._test_instance_create_delete(vm_delete_status='DELETED')
def test_instance_create_error_delete_notfound(self): def test_instance_create_notfound_on_delete(self):
self._test_instance_create_delete(vm_status='ERROR') return_server = self.fc.servers.list()[1]
instance = self._create_test_instance(return_server,
'in_cr_del')
instance.resource_id = '1234'
def test_instance_create_error_delete(self): # this makes sure the auto increment worked on instance creation
self._test_instance_create_delete( self.assertTrue(instance.id > 0)
vm_status='ERROR', vm_delete_status='DELETED')
self.m.StubOutWithMock(self.fc.client, 'delete_servers_1234')
self.fc.client.delete_servers_1234().AndRaise(
fakes_nova.fake_exception())
self.m.ReplayAll()
scheduler.TaskRunner(instance.delete)()
self.assertEqual((instance.DELETE, instance.COMPLETE), instance.state)
self.m.VerifyAll()
def test_instance_update_metadata(self): def test_instance_update_metadata(self):
return_server = self.fc.servers.list()[1] return_server = self.fc.servers.list()[1]

View File

@ -133,11 +133,10 @@ class SqlAlchemyTest(common.HeatTestCase):
def _mock_delete(self, mocks): def _mock_delete(self, mocks):
fc = fakes_nova.FakeClient() fc = fakes_nova.FakeClient()
mocks.StubOutWithMock(instances.Instance, 'nova') mocks.StubOutWithMock(instances.Instance, 'client')
instances.Instance.nova().MultipleTimes().AndReturn(fc) instances.Instance.client().MultipleTimes().AndReturn(fc)
mocks.StubOutWithMock(fc.client, 'get_servers_9999') self.patchobject(fc.servers, 'delete',
get = fc.client.get_servers_9999 side_effect=fakes_nova.fake_exception())
get().MultipleTimes().AndRaise(fakes_nova.fake_exception())
@mock.patch.object(db_api, '_paginate_query') @mock.patch.object(db_api, '_paginate_query')
def test_filter_and_page_query_paginates_query(self, mock_paginate_query): def test_filter_and_page_query_paginates_query(self, mock_paginate_query):

View File

@ -172,11 +172,11 @@ def clean_up_stack(stack, delete_res=True):
if delete_res: if delete_res:
m = mox.Mox() m = mox.Mox()
fc = fakes_nova.FakeClient() fc = fakes_nova.FakeClient()
m.StubOutWithMock(instances.Instance, 'nova') m.StubOutWithMock(instances.Instance, 'client')
instances.Instance.nova().MultipleTimes().AndReturn(fc) instances.Instance.client().MultipleTimes().AndReturn(fc)
m.StubOutWithMock(fc.client, 'get_servers_9999') m.StubOutWithMock(fc.servers, 'delete')
get = fc.client.get_servers_9999 fc.servers.delete(mox.IgnoreArg()).AndRaise(
get().AndRaise(fakes_nova.fake_exception()) fakes_nova.fake_exception())
m.ReplayAll() m.ReplayAll()
stack.delete() stack.delete()
if delete_res: if delete_res:

View File

@ -553,10 +553,8 @@ class StackCreateTest(common.HeatTestCase):
self.assertIsNotNone(stack['WebServer']) self.assertIsNotNone(stack['WebServer'])
self.assertTrue(stack['WebServer'].resource_id > 0) self.assertTrue(stack['WebServer'].resource_id > 0)
self.m.StubOutWithMock(fc.client, 'get_servers_9999') self.patchobject(fc.servers, 'delete',
get = fc.client.get_servers_9999 side_effect=fakes_nova.fake_exception())
get().AndRaise(fakes_nova.fake_exception())
mox.Replay(get)
stack.delete() stack.delete()
rsrc = stack['WebServer'] rsrc = stack['WebServer']
@ -1489,9 +1487,8 @@ class StackServiceAuthorizeTest(common.HeatTestCase):
stack = tools.get_stack(stack_name, self.ctx, user_policy_template) stack = tools.get_stack(stack_name, self.ctx, user_policy_template)
self.stack = stack self.stack = stack
fc = tools.setup_mocks(self.m, stack) fc = tools.setup_mocks(self.m, stack)
self.m.StubOutWithMock(fc.client, 'get_servers_9999') self.patchobject(fc.servers, 'delete',
get = fc.client.get_servers_9999 side_effect=fakes_nova.fake_exception())
get().AndRaise(fakes_nova.fake_exception())
self.m.ReplayAll() self.m.ReplayAll()
stack.store() stack.store()

View File

@ -1254,10 +1254,10 @@ class ServersTest(common.HeatTestCase):
# this makes sure the auto increment worked on server creation # this makes sure the auto increment worked on server creation
self.assertTrue(server.id > 0) self.assertTrue(server.id > 0)
self.m.StubOutWithMock(self.fc.client, 'get_servers_1234') self.m.StubOutWithMock(self.fc.client, 'delete_servers_1234')
get = self.fc.client.get_servers_1234 self.fc.client.delete_servers_1234().AndRaise(
get().AndRaise(fakes_nova.fake_exception()) fakes_nova.fake_exception())
mox.Replay(get) self.m.ReplayAll()
scheduler.TaskRunner(server.delete)() scheduler.TaskRunner(server.delete)()
self.assertEqual((server.DELETE, server.COMPLETE), server.state) self.assertEqual((server.DELETE, server.COMPLETE), server.state)