d625ec79c2
A backend in manila can have multiple storage pools and capabilities for each pool are considered to create configuration for tempest tests. These capabilities however may overlap with each other, so we need some de-duplication. Change-Id: I108615ab197b8959fe944e21ae7c1a36125ca531
72 lines
2.4 KiB
Python
72 lines
2.4 KiB
Python
# Copyright 2018 Red Hat, Inc.
|
|
# 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.
|
|
|
|
import json
|
|
|
|
from config_tempest import constants as C
|
|
from config_tempest.services.base import VersionedService
|
|
|
|
from tempest.lib import exceptions
|
|
|
|
|
|
class ShareService(VersionedService):
|
|
|
|
def get_share_pools(self, detail=False):
|
|
url = self.service_url + '/scheduler-stats/pools'
|
|
if detail:
|
|
url += '/detail'
|
|
body = self.do_get(url)
|
|
body = json.loads(body)
|
|
return body
|
|
|
|
def set_default_tempest_options(self, conf):
|
|
if 'v2' in self.service_url:
|
|
m_vs = self.filter_api_microversions()
|
|
conf.set('share', 'min_api_microversion', m_vs['min_microversion'])
|
|
conf.set('share', 'max_api_microversion', m_vs['max_microversion'])
|
|
|
|
try:
|
|
pools = self.get_share_pools(detail=True)['pools']
|
|
except exceptions.Forbidden:
|
|
C.LOG.warning("User has no permissions to list back-end storage "
|
|
"pools - storage back-ends can't be discovered.")
|
|
return
|
|
if pools:
|
|
backends = set()
|
|
enable_protocols = set()
|
|
for pool in pools:
|
|
backends.add(pool['backend'])
|
|
protocol = pool['capabilities']['storage_protocol'].lower()
|
|
enable_protocols.update(protocol.split('_'))
|
|
|
|
conf.set('share', 'backend_names', ','.join(backends))
|
|
conf.set('share', 'enable_protocols', ','.join(enable_protocols))
|
|
if len(backends) > 1:
|
|
conf.set('share', 'multi_backend', 'True')
|
|
|
|
def get_unversioned_service_type(self):
|
|
return 'share'
|
|
|
|
@staticmethod
|
|
def get_codename():
|
|
return 'manila'
|
|
|
|
def get_feature_name(self):
|
|
return 'share'
|
|
|
|
@staticmethod
|
|
def get_service_type():
|
|
return ['share', 'sharev2']
|