ceph
/
ceph-ansible
mirror of https://github.com/ceph/ceph-ansible.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "Initialize rbd pool at pool creation" 

This reverts commit 5a750aa955.

Signed-off-by: Teoman ONAY <tonay@ibm.com>
pull/7385/head
Teoman ONAY 2023-01-18 22:44:01 +01:00 committed by Guillaume Abrioux
parent f33c2ccd34
commit 971171d9e6
13 changed files with 173 additions and 335 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
library/ceph_crush_rule.py
View File

@ -18,12 +18,12 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized, \
exec_command
except ImportError:
from module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized, \
exec_command
import datetime
@ -142,8 +142,8 @@ def create_rule(module, container_image=None):
if profile:
args.append(profile)
cmd = generate_cmd(sub_cmd=['osd', 'crush', 'rule'],
args=args,
cmd = generate_ceph_cmd(['osd', 'crush', 'rule'],
args,
cluster=cluster,
container_image=container_image)
@ -160,8 +160,8 @@ def get_rule(module, container_image=None):
args = ['dump', name, '--format=json']
cmd = generate_cmd(sub_cmd=['osd', 'crush', 'rule'],
args=args,
cmd = generate_ceph_cmd(['osd', 'crush', 'rule'],
args,
cluster=cluster,
container_image=container_image)
@ -178,8 +178,8 @@ def remove_rule(module, container_image=None):
args = ['rm', name]
cmd = generate_cmd(sub_cmd=['osd', 'crush', 'rule'],
args=args,
cmd = generate_ceph_cmd(['osd', 'crush', 'rule'],
args,
cluster=cluster,
container_image=container_image)

14
library/ceph_dashboard_user.py
View File

@ -17,13 +17,13 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import generate_cmd, \
from ansible.module_utils.ca_common import generate_ceph_cmd, \
is_containerized, \
exec_command, \
exit_module, \
fatal
except ImportError:
from module_utils.ca_common import generate_cmd, is_containerized, exec_command, exit_module, fatal # noqa: E501
from module_utils.ca_common import generate_ceph_cmd, is_containerized, exec_command, exit_module, fatal # noqa: E501
import datetime
import json
@ -123,7 +123,7 @@ def create_user(module, container_image=None):
args = ['ac-user-create', '-i', '-', name]
cmd = generate_cmd(sub_cmd=['dashboard'],
cmd = generate_ceph_cmd(sub_cmd=['dashboard'],
args=args,
cluster=cluster,
container_image=container_image,
@ -145,7 +145,7 @@ def set_roles(module, container_image=None):
args.extend(roles)
cmd = generate_cmd(sub_cmd=['dashboard'],
cmd = generate_ceph_cmd(sub_cmd=['dashboard'],
args=args,
cluster=cluster,
container_image=container_image)
@ -163,7 +163,7 @@ def set_password(module, container_image=None):
args = ['ac-user-set-password', '-i', '-', name]
cmd = generate_cmd(sub_cmd=['dashboard'],
cmd = generate_ceph_cmd(sub_cmd=['dashboard'],
args=args,
cluster=cluster,
container_image=container_image,
@ -182,7 +182,7 @@ def get_user(module, container_image=None):
args = ['ac-user-show', name, '--format=json']
cmd = generate_cmd(sub_cmd=['dashboard'],
cmd = generate_ceph_cmd(sub_cmd=['dashboard'],
args=args,
cluster=cluster,
container_image=container_image)
@ -200,7 +200,7 @@ def remove_user(module, container_image=None):
args = ['ac-user-delete', name]
cmd = generate_cmd(sub_cmd=['dashboard'],
cmd = generate_ceph_cmd(sub_cmd=['dashboard'],
args=args,
cluster=cluster,
container_image=container_image)

15
library/ceph_ec_profile.py
View File

@ -18,12 +18,12 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import is_containerized, \
generate_cmd, \
generate_ceph_cmd, \
exec_command, \
exit_module
except ImportError:
from module_utils.ca_common import is_containerized, \
generate_cmd, \
generate_ceph_cmd, \
exec_command, \
exit_module
import datetime
@ -113,7 +113,7 @@ def get_profile(module, name, cluster='ceph', container_image=None):
args = ['get', name, '--format=json']
cmd = generate_cmd(sub_cmd=['osd', 'erasure-code-profile'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'erasure-code-profile'],
args=args,
cluster=cluster,
container_image=container_image)
@ -132,7 +132,7 @@ def create_profile(module, name, k, m, stripe_unit, cluster='ceph', force=False,
if force:
args.append('--force')
cmd = generate_cmd(sub_cmd=['osd', 'erasure-code-profile'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'erasure-code-profile'],
args=args,
cluster=cluster,
container_image=container_image)
@ -147,7 +147,7 @@ def delete_profile(module, name, cluster='ceph', container_image=None):
args = ['rm', name]
cmd = generate_cmd(sub_cmd=['osd', 'erasure-code-profile'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'erasure-code-profile'],
args=args,
cluster=cluster,
container_image=container_image)
@ -205,12 +205,7 @@ def run_module():
current_profile = json.loads(out)
if current_profile['k'] != k or \
current_profile['m'] != m or \
<<<<<<< HEAD
current_profile.get('stripe_unit', stripe_unit) != stripe_unit:
=======
current_profile.get('stripe_unit', stripe_unit) != stripe_unit or \
current_profile.get('crush-device-class', crush_device_class) != crush_device_class: # noqa: E501
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
rc, cmd, out, err = exec_command(module,
create_profile(module,
name,

14
library/ceph_fs.py
View File

@ -19,12 +19,12 @@ from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import is_containerized, \
exec_command, \
generate_cmd, \
generate_ceph_cmd, \
exit_module
except ImportError:
from module_utils.ca_common import is_containerized, \
exec_command, \
generate_cmd, \
generate_ceph_cmd, \
exit_module
import datetime
@ -119,7 +119,7 @@ def create_fs(module, container_image=None):
args = ['new', name, metadata, data]
cmd = generate_cmd(sub_cmd=['fs'],
cmd = generate_ceph_cmd(sub_cmd=['fs'],
args=args,
cluster=cluster,
container_image=container_image)
@ -137,7 +137,7 @@ def get_fs(module, container_image=None):
args = ['get', name, '--format=json']
cmd = generate_cmd(sub_cmd=['fs'],
cmd = generate_ceph_cmd(sub_cmd=['fs'],
args=args,
cluster=cluster,
container_image=container_image)
@ -155,7 +155,7 @@ def remove_fs(module, container_image=None):
args = ['rm', name, '--yes-i-really-mean-it']
cmd = generate_cmd(sub_cmd=['fs'],
cmd = generate_ceph_cmd(sub_cmd=['fs'],
args=args,
cluster=cluster,
container_image=container_image)
@ -173,7 +173,7 @@ def fail_fs(module, container_image=None):
args = ['fail', name]
cmd = generate_cmd(sub_cmd=['fs'],
cmd = generate_ceph_cmd(sub_cmd=['fs'],
args=args,
cluster=cluster,
container_image=container_image)
@ -192,7 +192,7 @@ def set_fs(module, container_image=None):
args = ['set', name, 'max_mds', str(max_mds)]
cmd = generate_cmd(sub_cmd=['fs'],
cmd = generate_ceph_cmd(sub_cmd=['fs'],
args=args,
cluster=cluster,
container_image=container_image)

57
library/ceph_key.py
View File

@ -19,21 +19,9 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
<<<<<<< HEAD
from ansible.module_utils.ca_common import is_containerized, container_exec, fatal
except ImportError:
from module_utils.ca_common import is_containerized, container_exec, fatal
=======
from ansible.module_utils.ca_common import generate_cmd, \
is_containerized, \
container_exec, \
fatal
except ImportError:
from module_utils.ca_common import generate_cmd, \
is_containerized, \
container_exec, \
fatal
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
import datetime
import json
import os
@ -338,17 +326,8 @@ def create_key(module, result, cluster, user, user_key_path, name, secret, caps,
cluster, name, secret, caps, dest, container_image))
if import_key or user != 'client.admin':
<<<<<<< HEAD
cmd_list.append(generate_ceph_cmd(
cluster, args, user, user_key_path, container_image))
=======
cmd_list.append(generate_cmd(sub_cmd=['auth'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image))
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
return cmd_list
@ -365,17 +344,8 @@ def delete_key(cluster, user, user_key_path, name, container_image=None):
name,
]
<<<<<<< HEAD
cmd_list.append(generate_ceph_cmd(
cluster, args, user, user_key_path, container_image))
=======
cmd_list.append(generate_cmd(sub_cmd=['auth'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image))
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
return cmd_list
@ -394,17 +364,8 @@ def get_key(cluster, user, user_key_path, name, dest, container_image=None):
dest,
]
<<<<<<< HEAD
cmd_list.append(generate_ceph_cmd(
cluster, args, user, user_key_path, container_image))
=======
cmd_list.append(generate_cmd(sub_cmd=['auth'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image))
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
return cmd_list
@ -423,17 +384,8 @@ def info_key(cluster, name, user, user_key_path, output_format, container_image=
output_format,
]
<<<<<<< HEAD
cmd_list.append(generate_ceph_cmd(
cluster, args, user, user_key_path, container_image))
=======
cmd_list.append(generate_cmd(sub_cmd=['auth'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image))
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
return cmd_list
@ -451,17 +403,8 @@ def list_keys(cluster, user, user_key_path, container_image=None):
'json',
]
<<<<<<< HEAD
cmd_list.append(generate_ceph_cmd(
cluster, args, user, user_key_path, container_image))
=======
cmd_list.append(generate_cmd(sub_cmd=['auth'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image))
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
return cmd_list

8
library/ceph_mgr_module.py
View File

@ -18,11 +18,11 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized
except ImportError:
from module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized
import datetime
@ -97,8 +97,8 @@ def main():
container_image = is_containerized()
cmd = generate_cmd(sub_cmd=['mgr', 'module'],
args=[state, name],
cmd = generate_ceph_cmd(['mgr', 'module'],
[state, name],
cluster=cluster,
container_image=container_image)

6
library/ceph_osd.py
View File

@ -17,9 +17,9 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import exit_module, generate_cmd, is_containerized # noqa: E501
from ansible.module_utils.ca_common import exit_module, generate_ceph_cmd, is_containerized # noqa: E501
except ImportError:
from module_utils.ca_common import exit_module, generate_cmd, is_containerized # noqa: E501
from module_utils.ca_common import exit_module, generate_ceph_cmd, is_containerized # noqa: E501
import datetime
@ -111,7 +111,7 @@ def main():
container_image = is_containerized()
cmd = generate_cmd(sub_cmd=['osd', state], args=ids, cluster=cluster, container_image=container_image) # noqa: E501
cmd = generate_ceph_cmd(['osd', state], ids, cluster=cluster, container_image=container_image) # noqa: E501
if state in ['destroy', 'purge']:
cmd.append('--yes-i-really-mean-it')

8
library/ceph_osd_flag.py
View File

@ -18,11 +18,11 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized
except ImportError:
from module_utils.ca_common import exit_module, \
generate_cmd, \
generate_ceph_cmd, \
is_containerized
import datetime
@ -99,9 +99,9 @@ def main():
container_image = is_containerized()
if state == 'present':
cmd = generate_cmd(sub_cmd=['osd', 'set'], args=[name], cluster=cluster, container_image=container_image) # noqa: E501
cmd = generate_ceph_cmd(['osd', 'set'], [name], cluster=cluster, container_image=container_image) # noqa: E501
else:
cmd = generate_cmd(sub_cmd=['osd', 'unset'], args=[name], cluster=cluster, container_image=container_image) # noqa: E501
cmd = generate_ceph_cmd(['osd', 'unset'], [name], cluster=cluster, container_image=container_image) # noqa: E501
if module.check_mode:
exit_module(

59
library/ceph_pool.py
View File

@ -19,14 +19,14 @@ __metaclass__ = type
from ansible.module_utils.basic import AnsibleModule
try:
from ansible.module_utils.ca_common import generate_cmd, \
pre_generate_cmd, \
from ansible.module_utils.ca_common import generate_ceph_cmd, \
pre_generate_ceph_cmd, \
is_containerized, \
exec_command, \
exit_module
except ImportError:
from module_utils.ca_common import generate_cmd, \
pre_generate_cmd, \
from module_utils.ca_common import generate_ceph_cmd, \
pre_generate_ceph_cmd, \
is_containerized, \
exec_command, \
exit_module
@ -167,7 +167,7 @@ def check_pool_exist(cluster,
args = ['stats', name, '-f', output_format]
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -182,7 +182,7 @@ def generate_get_config_cmd(param,
user,
user_key,
container_image=None):
_cmd = pre_generate_cmd('ceph', container_image=container_image)
_cmd = pre_generate_ceph_cmd(container_image=container_image)
args = [
'-n',
user,
@ -211,7 +211,7 @@ def get_application_pool(cluster,
args = ['application', 'get', name, '-f', output_format]
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -233,29 +233,7 @@ def enable_application_pool(cluster,
args = ['application', 'enable', name, application]
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
user_key=user_key,
container_image=container_image)
return cmd
def init_rbd_pool(cluster,
name,
user,
user_key,
container_image=None):
'''
Initialize a rbd pool
'''
args = [name]
cmd = generate_cmd(cmd='rbd',
sub_cmd=['pool', 'init'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -278,7 +256,7 @@ def disable_application_pool(cluster,
args = ['application', 'disable', name,
application, '--yes-i-really-mean-it']
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -301,7 +279,7 @@ def get_pool_details(module,
args = ['ls', 'detail', '-f', output_format]
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -390,7 +368,7 @@ def list_pools(cluster,
args.extend(['-f', output_format])
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -401,6 +379,7 @@ def list_pools(cluster,
def create_pool(cluster,
name,
user,
user_key,
user_pool_config,
@ -444,7 +423,7 @@ def create_pool(cluster,
'--autoscale-mode',
user_pool_config['pg_autoscale_mode']['value']])
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -461,7 +440,7 @@ def remove_pool(cluster, name, user, user_key, container_image=None):
args = ['rm', name, name, '--yes-i-really-really-mean-it']
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -486,7 +465,7 @@ def update_pool(module, cluster, name,
delta[key]['cli_set_opt'],
delta[key]['value']]
cmd = generate_cmd(sub_cmd=['osd', 'pool'],
cmd = generate_ceph_cmd(sub_cmd=['osd', 'pool'],
args=args,
cluster=cluster,
user=user,
@ -655,6 +634,7 @@ def run_module():
else:
rc, cmd, out, err = exec_command(module,
create_pool(cluster,
name,
user,
user_key,
user_pool_config=user_pool_config, # noqa: E501
@ -667,13 +647,6 @@ def run_module():
user,
user_key,
container_image=container_image)) # noqa: E501
if rc == 0 and user_pool_config['application']['value'] == 'rbd': # noqa: E501
rc, cmd, out, err = exec_command(module,
init_rbd_pool(cluster,
user_pool_config['pool_name']['value'], # noqa: E501
user,
user_key,
container_image=container_image)) # noqa: E501
if user_pool_config['min_size']['value']:
# not implemented yet
pass

28
module_utils/ca_common.py
View File

@ -2,22 +2,15 @@ import os
import datetime
def generate_cmd(cmd='ceph',
sub_cmd=None,
args=None,
user_key=None,
cluster='ceph',
user='client.admin',
container_image=None,
interactive=False):
def generate_ceph_cmd(sub_cmd, args, user_key=None, cluster='ceph', user='client.admin', container_image=None, interactive=False):
'''
Generate 'ceph' command line to execute
'''
if user_key is None:
if not user_key:
user_key = '/etc/ceph/{}.{}.keyring'.format(cluster, user)
cmd = pre_generate_cmd(cmd, container_image=container_image, interactive=interactive) # noqa: E501
cmd = pre_generate_ceph_cmd(container_image=container_image, interactive=interactive)
base_cmd = [
'-n',
@ -27,11 +20,8 @@ def generate_cmd(cmd='ceph',
'--cluster',
cluster
]
if sub_cmd is not None:
base_cmd.extend(sub_cmd)
cmd.extend(base_cmd) if args is None else cmd.extend(base_cmd + args)
cmd.extend(base_cmd + args)
return cmd
@ -69,14 +59,14 @@ def is_containerized():
return container_image
def pre_generate_cmd(cmd, container_image=None, interactive=False):
def pre_generate_ceph_cmd(container_image=None, interactive=False):
'''
Generate ceph prefix command
Generate ceph prefix comaand
'''
if container_image:
cmd = container_exec(cmd, container_image, interactive=interactive)
cmd = container_exec('ceph', container_image, interactive=interactive)
else:
cmd = [cmd]
cmd = ['ceph']
return cmd
@ -94,7 +84,7 @@ def exec_command(module, cmd, stdin=None):
return rc, cmd, out, err
def exit_module(module, out, rc, cmd, err, startd, changed=False, diff=dict(before="", after="")): # noqa: E501
def exit_module(module, out, rc, cmd, err, startd, changed=False, diff=dict(before="", after="")):
endd = datetime.datetime.now()
delta = endd - startd

19
tests/library/test_ceph_key.py
View File

@ -62,17 +62,8 @@ class TestCephKeyModule(object):
'auth',
'arg'
]
<<<<<<< HEAD
result = ceph_key.generate_ceph_cmd(
fake_cluster, fake_args, fake_user, fake_key)
=======
result = ceph_key.generate_cmd(
sub_cmd=['auth'],
args=fake_args,
cluster=fake_cluster,
user=fake_user,
user_key=fake_user_key)
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
assert result == expected_command_list
def test_generate_ceph_cmd_list_container(self):
@ -98,18 +89,8 @@ class TestCephKeyModule(object):
fake_cluster,
'auth',
'arg']
<<<<<<< HEAD
result = ceph_key.generate_ceph_cmd(
fake_cluster, fake_args, fake_user, fake_user_key, fake_container_image)
=======
result = ceph_key.generate_cmd(
sub_cmd=['auth'],
args=fake_args,
cluster=fake_cluster,
user=fake_user,
user_key=fake_user_key,
container_image=fake_container_image)
>>>>>>> c39bbc3de (Initialize rbd pool at pool creation)
assert result == expected_command_list
def test_generate_ceph_authtool_cmd_non_container_no_auid(self):

52
tests/library/test_ceph_pool.py
View File

@ -2,7 +2,6 @@ import os
import sys
import ceph_pool
from mock.mock import patch
import pytest
sys.path.append('./library')
fake_user = 'client.admin'
@ -283,53 +282,6 @@ class TestCephPoolModule(object):
assert cmd == expected_command
@pytest.mark.parametrize("container_image", [None, fake_container_image_name])
def test_init_rbd_pool(self, container_image):
if container_image:
expected_command = [
'podman',
'run',
'--rm',
'--net=host',
'-v',
'/etc/ceph:/etc/ceph:z',
'-v',
'/var/lib/ceph/:/var/lib/ceph/:z',
'-v',
'/var/log/ceph/:/var/log/ceph/:z',
'--entrypoint=rbd',
fake_container_image_name,
'-n',
fake_user,
'-k',
fake_user_key,
'--cluster',
fake_cluster_name,
'pool',
'init',
self.fake_user_pool_config['pool_name']['value']
]
else:
expected_command = [
'rbd',
'-n',
fake_user,
'-k',
fake_user_key,
'--cluster',
fake_cluster_name,
'pool',
'init',
self.fake_user_pool_config['pool_name']['value']
]
cmd = ceph_pool.init_rbd_pool(fake_cluster_name,
self.fake_user_pool_config['pool_name']['value'],
fake_user, fake_user_key,
container_image)
assert cmd == expected_command
def test_disable_application_pool(self):
expected_command = [
'podman',
@ -490,6 +442,7 @@ class TestCephPoolModule(object):
]
cmd = ceph_pool.create_pool(fake_cluster_name,
self.fake_user_pool_config['pool_name']['value'],
fake_user, fake_user_key, self.fake_user_pool_config,
container_image=fake_container_image_name)
@ -536,6 +489,7 @@ class TestCephPoolModule(object):
]
cmd = ceph_pool.create_pool(fake_cluster_name,
self.fake_user_pool_config['pool_name']['value'],
fake_user, fake_user_key,
self.fake_user_pool_config,
container_image=fake_container_image_name)
@ -581,6 +535,7 @@ class TestCephPoolModule(object):
]
cmd = ceph_pool.create_pool(fake_cluster_name,
self.fake_user_pool_config['pool_name']['value'],
fake_user, fake_user_key, self.fake_user_pool_config,
container_image=fake_container_image_name)
@ -628,6 +583,7 @@ class TestCephPoolModule(object):
]
cmd = ceph_pool.create_pool(fake_cluster_name,
self.fake_user_pool_config['pool_name']['value'],
fake_user, fake_user_key, self.fake_user_pool_config,
container_image=fake_container_image_name)

22
tests/module_utils/test_ca_common.py
View File

@ -38,17 +38,17 @@ class TestCommon(object):
@pytest.mark.parametrize('image', [None, fake_container_image])
@patch.dict(os.environ, {'CEPH_CONTAINER_BINARY': fake_container_binary})
def test_pre_generate_cmd(self, image):
def test_pre_generate_ceph_cmd(self, image):
if image:
expected_cmd = self.fake_container_cmd
else:
expected_cmd = [self.fake_binary]
assert ca_common.pre_generate_cmd(self.fake_binary, image) == expected_cmd # noqa: E501
assert ca_common.pre_generate_ceph_cmd(image) == expected_cmd
@pytest.mark.parametrize('image', [None, fake_container_image])
@patch.dict(os.environ, {'CEPH_CONTAINER_BINARY': fake_container_binary})
def test_generate_cmd(self, image):
def test_generate_ceph_cmd(self, image):
sub_cmd = ['osd', 'pool']
args = ['create', 'foo']
if image:
@ -64,11 +64,11 @@ class TestCommon(object):
'osd', 'pool',
'create', 'foo'
])
assert ca_common.generate_cmd(sub_cmd=sub_cmd, args=args, cluster=self.fake_cluster, container_image=image) == expected_cmd # noqa: E501
assert ca_common.generate_ceph_cmd(sub_cmd, args, cluster=self.fake_cluster, container_image=image) == expected_cmd
@pytest.mark.parametrize('image', [None, fake_container_image])
@patch.dict(os.environ, {'CEPH_CONTAINER_BINARY': fake_container_binary})
def test_generate_cmd_different_cluster_name(self, image):
def test_generate_ceph_cmd_different_cluster_name(self, image):
sub_cmd = ['osd', 'pool']
args = ['create', 'foo']
if image:
@ -84,12 +84,12 @@ class TestCommon(object):
'osd', 'pool',
'create', 'foo'
])
result = ca_common.generate_cmd(sub_cmd=sub_cmd, args=args, cluster='foo', container_image=image) # noqa: E501
result = ca_common.generate_ceph_cmd(sub_cmd, args, cluster='foo', container_image=image)
assert result == expected_cmd
@pytest.mark.parametrize('image', [None, fake_container_image])
@patch.dict(os.environ, {'CEPH_CONTAINER_BINARY': fake_container_binary})
def test_generate_cmd_different_cluster_name_and_user(self, image):
def test_generate_ceph_cmd_different_cluster_name_and_user(self, image):
sub_cmd = ['osd', 'pool']
args = ['create', 'foo']
if image:
@ -105,12 +105,12 @@ class TestCommon(object):
'osd', 'pool',
'create', 'foo'
])
result = ca_common.generate_cmd(sub_cmd=sub_cmd, args=args, cluster='foo', user='client.foo', container_image=image) # noqa: E501
result = ca_common.generate_ceph_cmd(sub_cmd, args, cluster='foo', user='client.foo', container_image=image)
assert result == expected_cmd
@pytest.mark.parametrize('image', [None, fake_container_image])
@patch.dict(os.environ, {'CEPH_CONTAINER_BINARY': fake_container_binary})
def test_generate_cmd_different_user(self, image):
def test_generate_ceph_cmd_different_user(self, image):
sub_cmd = ['osd', 'pool']
args = ['create', 'foo']
if image:
@ -126,7 +126,7 @@ class TestCommon(object):
'osd', 'pool',
'create', 'foo'
])
result = ca_common.generate_cmd(sub_cmd=sub_cmd, args=args, user='client.foo', container_image=image) # noqa: E501
result = ca_common.generate_ceph_cmd(sub_cmd, args, user='client.foo', container_image=image)
assert result == expected_cmd
@pytest.mark.parametrize('stdin', [None, 'foo'])
@ -137,7 +137,7 @@ class TestCommon(object):
stdout = 'ceph version 1.2.3'
fake_module.run_command.return_value = 0, stdout, stderr
expected_cmd = [self.fake_binary, '--version']
_rc, _cmd, _out, _err = ca_common.exec_command(fake_module, expected_cmd, stdin=stdin) # noqa: E501
_rc, _cmd, _out, _err = ca_common.exec_command(fake_module, expected_cmd, stdin=stdin)
assert _rc == rc
assert _cmd == expected_cmd
assert _err == stderr