Send application name to ceph-mon

Send application name to ceph-mon as ceph-mon cannot derive it from
CMR relations.

Change-Id: I2bd1062b6aa05eab4eb3bd8d602a2d02f085f531
This commit is contained in:
Liam Young 2020-06-19 09:29:42 +00:00
parent c7e104257f
commit bc273a59e1
4 changed files with 28 additions and 5 deletions

View File

@ -41,6 +41,7 @@ from subprocess import (
)
from charmhelpers import deprecate
from charmhelpers.core.hookenv import (
application_name,
config,
service_name,
local_unit,
@ -162,6 +163,17 @@ def get_osd_settings(relation_name):
return _order_dict_by_key(osd_settings)
def send_application_name(relid=None):
"""Send the application name down the relation.
:param relid: Relation id to set application name in.
:type relid: str
"""
relation_set(
relation_id=relid,
relation_settings={'application-name': application_name()})
def send_osd_settings():
"""Pass on requested OSD settings to osd units."""
try:
@ -1074,7 +1086,10 @@ def create_erasure_profile(service, profile_name,
erasure_plugin_technique=None):
"""Create a new erasure code profile if one does not already exist for it.
Updates the profile if it exists. Please refer to [0] for more details.
Profiles are considered immutable so will not be updated if the named
profile already exists.
Please refer to [0] for more details.
0: http://docs.ceph.com/docs/master/rados/operations/erasure-code-profile/
@ -1110,6 +1125,11 @@ def create_erasure_profile(service, profile_name,
:type erasure_plugin_technique: str
:return: None. Can raise CalledProcessError, ValueError or AssertionError
"""
if erasure_profile_exists(service, profile_name):
log('EC profile {} exists, skipping update'.format(profile_name),
level=WARNING)
return
plugin_techniques = {
'jerasure': [
'reed_sol_van',
@ -1209,9 +1229,6 @@ def create_erasure_profile(service, profile_name,
if scalar_mds:
cmd.append('scalar-mds={}'.format(scalar_mds))
if erasure_profile_exists(service, profile_name):
cmd.append('--force')
check_call(cmd)
@ -2198,6 +2215,7 @@ def send_request_if_needed(request, relation='ceph'):
for rid in relation_ids(relation):
log('Sending request {}'.format(request.request_id), level=DEBUG)
relation_set(relation_id=rid, broker_req=request.request)
relation_set(relation_id=rid, relation_settings={'unit-name': local_unit()})
def has_broker_rsp(rid=None, unit=None):

View File

@ -25,7 +25,8 @@ UBUNTU_RELEASES = (
'cosmic',
'disco',
'eoan',
'focal'
'focal',
'groovy'
)

View File

@ -109,6 +109,7 @@ from charmhelpers.contrib.openstack.utils import (
is_db_maintenance_mode,
)
from charmhelpers.contrib.storage.linux.ceph import (
send_application_name,
send_request_if_needed,
is_request_complete,
ensure_ceph_keyring,
@ -299,6 +300,7 @@ def object_store_joined():
@hooks.hook('ceph-relation-joined')
def ceph_joined():
apt_install(['ceph-common'])
send_application_name()
def get_ceph_request():

View File

@ -107,6 +107,7 @@ TO_PATCH = [
'delete_keyring',
'get_relation_ip',
'is_db_maintenance_mode',
'send_application_name',
]
@ -312,6 +313,7 @@ class GlanceRelationTests(CharmTestCase):
def test_ceph_joined(self):
relations.ceph_joined()
self.apt_install.assert_called_with(['ceph-common'])
self.send_application_name.assert_called_with()
@patch.object(relations, 'CONFIGS')
def test_ceph_changed_missing_relation_data(self, configs):