mirror of
https://github.com/ceph/ceph
synced 2025-01-24 12:05:46 +00:00
214 lines
8.1 KiB
Python
214 lines
8.1 KiB
Python
from __future__ import absolute_import
|
|
|
|
import time
|
|
|
|
from .helper import DashboardTestCase
|
|
|
|
|
|
class ClusterConfigurationTest(DashboardTestCase):
|
|
|
|
def test_list(self):
|
|
data = self._get('/api/cluster_conf')
|
|
self.assertStatus(200)
|
|
self.assertIsInstance(data, list)
|
|
self.assertGreater(len(data), 1000)
|
|
for conf in data:
|
|
self._validate_single(conf)
|
|
|
|
def test_get(self):
|
|
data = self._get('/api/cluster_conf/admin_socket')
|
|
self.assertStatus(200)
|
|
self._validate_single(data)
|
|
self.assertIn('enum_values', data)
|
|
|
|
data = self._get('/api/cluster_conf/fantasy_name')
|
|
self.assertStatus(404)
|
|
|
|
def test_get_specific_db_config_option(self):
|
|
config_name = 'mon_allow_pool_delete'
|
|
|
|
orig_value = self._get_config_by_name(config_name)
|
|
|
|
self._ceph_cmd(['config', 'set', 'mon', config_name, 'true'])
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
[{'section': 'mon', 'value': 'true'}])
|
|
self.assertEqual(result, [{'section': 'mon', 'value': 'true'}])
|
|
|
|
self._ceph_cmd(['config', 'set', 'mon', config_name, 'false'])
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
[{'section': 'mon', 'value': 'false'}])
|
|
self.assertEqual(result, [{'section': 'mon', 'value': 'false'}])
|
|
|
|
# restore value
|
|
if orig_value:
|
|
self._ceph_cmd(['config', 'set', 'mon', config_name, orig_value[0]['value']])
|
|
|
|
def test_create(self):
|
|
config_name = 'debug_ms'
|
|
orig_value = self._get_config_by_name(config_name)
|
|
|
|
# remove all existing settings for equal preconditions
|
|
self._clear_all_values_for_config_option(config_name)
|
|
|
|
expected_result = [{'section': 'mon', 'value': '0/3'}]
|
|
|
|
self._post('/api/cluster_conf', {
|
|
'name': config_name,
|
|
'value': expected_result
|
|
})
|
|
self.assertStatus(201)
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
expected_result)
|
|
self.assertEqual(result, expected_result)
|
|
|
|
# reset original value
|
|
self._clear_all_values_for_config_option(config_name)
|
|
self._reset_original_values(config_name, orig_value)
|
|
|
|
def test_create_two_values(self):
|
|
config_name = 'debug_ms'
|
|
orig_value = self._get_config_by_name(config_name)
|
|
|
|
# remove all existing settings for equal preconditions
|
|
self._clear_all_values_for_config_option(config_name)
|
|
|
|
expected_result = [{'section': 'mon', 'value': '0/3'},
|
|
{'section': 'osd', 'value': '0/5'}]
|
|
|
|
self._post('/api/cluster_conf', {
|
|
'name': config_name,
|
|
'value': expected_result
|
|
})
|
|
self.assertStatus(201)
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
expected_result)
|
|
self.assertEqual(result, expected_result)
|
|
|
|
# reset original value
|
|
self._clear_all_values_for_config_option(config_name)
|
|
self._reset_original_values(config_name, orig_value)
|
|
|
|
def test_create_can_handle_none_values(self):
|
|
config_name = 'debug_ms'
|
|
orig_value = self._get_config_by_name(config_name)
|
|
|
|
# remove all existing settings for equal preconditions
|
|
self._clear_all_values_for_config_option(config_name)
|
|
|
|
self._post('/api/cluster_conf', {
|
|
'name': config_name,
|
|
'value': [{'section': 'mon', 'value': '0/3'},
|
|
{'section': 'osd', 'value': None}]
|
|
})
|
|
self.assertStatus(201)
|
|
|
|
expected_result = [{'section': 'mon', 'value': '0/3'}]
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
expected_result)
|
|
self.assertEqual(result, expected_result)
|
|
|
|
# reset original value
|
|
self._clear_all_values_for_config_option(config_name)
|
|
self._reset_original_values(config_name, orig_value)
|
|
|
|
def test_create_can_handle_boolean_values(self):
|
|
config_name = 'mon_allow_pool_delete'
|
|
orig_value = self._get_config_by_name(config_name)
|
|
|
|
# remove all existing settings for equal preconditions
|
|
self._clear_all_values_for_config_option(config_name)
|
|
|
|
expected_result = [{'section': 'mon', 'value': 'true'}]
|
|
|
|
self._post('/api/cluster_conf', {
|
|
'name': config_name,
|
|
'value': [{'section': 'mon', 'value': True}]})
|
|
self.assertStatus(201)
|
|
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
expected_result)
|
|
self.assertEqual(result, expected_result)
|
|
|
|
# reset original value
|
|
self._clear_all_values_for_config_option(config_name)
|
|
self._reset_original_values(config_name, orig_value)
|
|
|
|
def test_bulk_set(self):
|
|
expected_result = {
|
|
'osd_max_backfills': {'section': 'osd', 'value': '1'},
|
|
'osd_recovery_max_active': {'section': 'osd', 'value': '3'},
|
|
'osd_recovery_max_single_start': {'section': 'osd', 'value': '1'},
|
|
'osd_recovery_sleep': {'section': 'osd', 'value': '2.000000'}
|
|
}
|
|
orig_values = dict()
|
|
|
|
for config_name in expected_result:
|
|
orig_values[config_name] = self._get_config_by_name(config_name)
|
|
|
|
# remove all existing settings for equal preconditions
|
|
self._clear_all_values_for_config_option(config_name)
|
|
|
|
self._put('/api/cluster_conf', {'options': expected_result})
|
|
self.assertStatus(200)
|
|
|
|
for config_name, value in expected_result.items():
|
|
result = self._wait_for_expected_get_result(self._get_config_by_name, config_name,
|
|
[value])
|
|
self.assertEqual(result, [value])
|
|
|
|
# reset original value
|
|
self._clear_all_values_for_config_option(config_name)
|
|
self._reset_original_values(config_name, orig_values[config_name])
|
|
|
|
def _validate_single(self, data):
|
|
self.assertIn('name', data)
|
|
self.assertIn('daemon_default', data)
|
|
self.assertIn('long_desc', data)
|
|
self.assertIn('level', data)
|
|
self.assertIn('default', data)
|
|
self.assertIn('see_also', data)
|
|
self.assertIn('tags', data)
|
|
self.assertIn('min', data)
|
|
self.assertIn('max', data)
|
|
self.assertIn('services', data)
|
|
self.assertIn('type', data)
|
|
self.assertIn('desc', data)
|
|
|
|
if 'value' in data:
|
|
self.assertIn('source', data)
|
|
self.assertIsInstance(data['value'], list)
|
|
|
|
for entry in data['value']:
|
|
self.assertIsInstance(entry, dict)
|
|
self.assertIn('section', entry)
|
|
self.assertIn('value', entry)
|
|
|
|
def _wait_for_expected_get_result(self, get_func, get_params, expected_result, max_attempts=30,
|
|
sleep_time=1):
|
|
attempts = 0
|
|
while attempts < max_attempts:
|
|
get_result = get_func(get_params)
|
|
if get_result == expected_result:
|
|
self.assertStatus(200)
|
|
return get_result
|
|
|
|
time.sleep(sleep_time)
|
|
attempts += 1
|
|
|
|
def _get_config_by_name(self, conf_name):
|
|
data = self._get('/api/cluster_conf/{}'.format(conf_name))
|
|
if 'value' in data:
|
|
return data['value']
|
|
return None
|
|
|
|
def _clear_all_values_for_config_option(self, config_name):
|
|
values = self._get_config_by_name(config_name)
|
|
if values:
|
|
for value in values:
|
|
self._ceph_cmd(['config', 'rm', value['section'], config_name])
|
|
|
|
def _reset_original_values(self, config_name, orig_values):
|
|
if orig_values:
|
|
for value in orig_values:
|
|
self._ceph_cmd(['config', 'set', value['section'], config_name, value['value']])
|