1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
|
# Copyright (c) 2012 Rackspace Hosting
# All Rights Reserved.
#
# 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.
"""Configuration support for all drivers. from openstack/cyborg"""
from oslo_config import cfg
CONF = cfg.CONF
SHARED_CONF_GROUP = 'backend_defaults'
class DefaultGroupConfiguration(object):
"""Get config options from only DEFAULT."""
def __init__(self):
# set the local conf so that __call__'s know what to use
self.local_conf = CONF
def _ensure_config_values(self, accelerator_opts):
CONF.register_opts(accelerator_opts, group=None)
def append_config_values(self, accelerator_opts):
self._ensure_config_values(accelerator_opts)
def safe_get(self, value):
"""get default group value from CONF
:param value: value.
:return: get default group value from CONF.
"""
try:
return self.__getattr__(value)
except cfg.NoSuchOptError:
return None
def __getattr__(self, value):
"""Don't use self.local_conf to avoid reentrant call to __getattr__()
:param value: value.
:return: getattr(local_conf, value).
"""
local_conf = object.__getattribute__(self, 'local_conf')
return getattr(local_conf, value)
class BackendGroupConfiguration(object):
def __init__(self, accelerator_opts, config_group=None):
"""Initialize configuration.
This takes care of grafting the implementation's config
values into the config group and shared defaults. We will try to
pull values from the specified 'config_group', but fall back to
defaults from the SHARED_CONF_GROUP.
"""
self.config_group = config_group
# set the local conf so that __call__'s know what to use
self._ensure_config_values(accelerator_opts)
self.backend_conf = CONF._get(self.config_group)
self.shared_backend_conf = CONF._get(SHARED_CONF_GROUP)
def _safe_register(self, opt, group):
try:
CONF.register_opt(opt, group=group)
except cfg.DuplicateOptError:
pass # If it's already registered ignore it
def _ensure_config_values(self, accelerator_opts):
"""Register the options in the shared group.
When we go to get a config option we will try the backend specific
group first and fall back to the shared group. We override the default
from all the config options for the backend group so we can know if it
was set or not.
"""
for opt in accelerator_opts:
self._safe_register(opt, SHARED_CONF_GROUP)
# Assuming they aren't the same groups, graft on the options into
# the backend group and override its default value.
if self.config_group != SHARED_CONF_GROUP:
self._safe_register(opt, self.config_group)
CONF.set_default(opt.name, None, group=self.config_group)
def append_config_values(self, accelerator_opts):
self._ensure_config_values(accelerator_opts)
def set_default(self, opt_name, default):
CONF.set_default(opt_name, default, group=SHARED_CONF_GROUP)
def get(self, key, default=None):
return getattr(self, key, default)
def safe_get(self, value):
"""get config_group value from CONF
:param value: value.
:return: get config_group value from CONF.
"""
try:
return self.__getattr__(value)
except cfg.NoSuchOptError:
return None
def __getattr__(self, opt_name):
"""Don't use self.X to avoid reentrant call to __getattr__()
:param opt_name: opt_name.
:return: opt_value.
"""
backend_conf = object.__getattribute__(self, 'backend_conf')
opt_value = getattr(backend_conf, opt_name)
if opt_value is None:
shared_conf = object.__getattribute__(self, 'shared_backend_conf')
opt_value = getattr(shared_conf, opt_name)
return opt_value
class Configuration(object):
def __init__(self, accelerator_opts, config_group=None):
"""Initialize configuration.
This shim will allow for compatibility with the DEFAULT
style of backend configuration which is used by some of the users
of this configuration helper, or by the volume drivers that have
all been forced over to the config_group style.
"""
self.config_group = config_group
if config_group:
self.conf = BackendGroupConfiguration(accelerator_opts,
config_group)
else:
self.conf = DefaultGroupConfiguration()
def append_config_values(self, accelerator_opts):
self.conf.append_config_values(accelerator_opts)
def safe_get(self, value):
"""get value from CONF
:param value: value.
:return: get value from CONF.
"""
return self.conf.safe_get(value)
def __getattr__(self, value):
"""Don't use self.conf to avoid reentrant call to __getattr__()
:param value: value.
:return: getattr(conf, value).
"""
conf = object.__getattribute__(self, 'conf')
return getattr(conf, value)
|
