Merge "Fix check_service_status"
This commit is contained in:
commit
529480a7bf
@ -72,17 +72,19 @@ class ObjectStorageService(Service):
|
|||||||
'object-storage-feature-enabled',
|
'object-storage-feature-enabled',
|
||||||
'discoverability')):
|
'discoverability')):
|
||||||
return False
|
return False
|
||||||
|
return True
|
||||||
except configparser.NoSectionError:
|
except configparser.NoSectionError:
|
||||||
|
# discoverability wasn't set by python-tempestconf,
|
||||||
|
# let's discover it
|
||||||
# Turning http://.../v1/foobar into http://.../
|
# Turning http://.../v1/foobar into http://.../
|
||||||
self.client.accounts.skip_path()
|
self.client.accounts.skip_path()
|
||||||
resp, _ = self.client.accounts.get("healthcheck", {})
|
resp, _ = self.client.accounts.get("healthcheck", {})
|
||||||
return resp['status'] == '200'
|
return resp['status'] == '200'
|
||||||
except Exception:
|
|
||||||
return False
|
|
||||||
|
|
||||||
def set_default_tempest_options(self, conf):
|
def set_default_tempest_options(self, conf):
|
||||||
"""Set default values for swift
|
"""Set default values for swift
|
||||||
|
|
||||||
|
:type conf: TempestConf object
|
||||||
"""
|
"""
|
||||||
swift_status = self.check_service_status(conf)
|
swift_status = self.check_service_status(conf)
|
||||||
# Set roles based on service status
|
# Set roles based on service status
|
||||||
|
@ -59,11 +59,25 @@ class TestObjectStorageService(BaseServiceTest):
|
|||||||
'admin')
|
'admin')
|
||||||
self.assertTrue(client.create_role.called)
|
self.assertTrue(client.create_role.called)
|
||||||
|
|
||||||
def test_check_service_status(self):
|
def test_check_service_status_discover(self):
|
||||||
self.Service.client = mock.Mock()
|
self.Service.client = mock.Mock()
|
||||||
self.Service.client.accounts = mock.Mock()
|
self.Service.client.accounts = mock.Mock()
|
||||||
return_mock = mock.Mock(return_value=self.FAKE_ACCOUNTS)
|
return_mock = mock.Mock(return_value=self.FAKE_ACCOUNTS)
|
||||||
self.Service.client.accounts.skip_check = mock.Mock()
|
self.Service.client.accounts.skip_check = mock.Mock()
|
||||||
self.Service.client.accounts.get = return_mock
|
self.Service.client.accounts.get = return_mock
|
||||||
self.Service.check_service_status(self.Service.conf)
|
resp = self.Service.check_service_status(self.Service.conf)
|
||||||
self.assertTrue(self.Service.check_service_status)
|
self.assertTrue(resp)
|
||||||
|
|
||||||
|
def test_check_service_status(self):
|
||||||
|
# discoverability set to False (e.g. via overrides)
|
||||||
|
self.Service.conf.set('object-storage-feature-enabled',
|
||||||
|
'discoverability',
|
||||||
|
str(False))
|
||||||
|
resp = self.Service.check_service_status(self.Service.conf)
|
||||||
|
self.assertFalse(resp)
|
||||||
|
# discoverability set to True (e.g. via overrides)
|
||||||
|
self.Service.conf.set('object-storage-feature-enabled',
|
||||||
|
'discoverability',
|
||||||
|
str(True))
|
||||||
|
resp = self.Service.check_service_status(self.Service.conf)
|
||||||
|
self.assertTrue(resp)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user