mirror of
https://github.com/ceph/ceph
synced 2024-12-28 06:23:08 +00:00
112 lines
3.3 KiB
Python
112 lines
3.3 KiB
Python
"""
|
|
Mount/unmount a ``kernel`` client.
|
|
"""
|
|
import contextlib
|
|
import logging
|
|
import os
|
|
|
|
from teuthology import misc as teuthology
|
|
|
|
log = logging.getLogger(__name__)
|
|
|
|
@contextlib.contextmanager
|
|
def task(ctx, config):
|
|
"""
|
|
Mount/unmount a ``kernel`` client.
|
|
|
|
The config is optional and defaults to mounting on all clients. If
|
|
a config is given, it is expected to be a list of clients to do
|
|
this operation on. This lets you e.g. set up one client with
|
|
``ceph-fuse`` and another with ``kclient``.
|
|
|
|
Example that mounts all clients::
|
|
|
|
tasks:
|
|
- ceph:
|
|
- kclient:
|
|
- interactive:
|
|
|
|
Example that uses both ``kclient` and ``ceph-fuse``::
|
|
|
|
tasks:
|
|
- ceph:
|
|
- ceph-fuse: [client.0]
|
|
- kclient: [client.1]
|
|
- interactive:
|
|
|
|
:param ctx: Context
|
|
:param config: Configuration
|
|
"""
|
|
log.info('Mounting kernel clients...')
|
|
assert config is None or isinstance(config, list), \
|
|
"task kclient got invalid config"
|
|
|
|
if config is None:
|
|
config = ['client.{id}'.format(id=id_)
|
|
for id_ in teuthology.all_roles_of_type(ctx.cluster, 'client')]
|
|
clients = list(teuthology.get_clients(ctx=ctx, roles=config))
|
|
|
|
testdir = teuthology.get_testdir(ctx)
|
|
|
|
for id_, remote in clients:
|
|
mnt = os.path.join(testdir, 'mnt.{id}'.format(id=id_))
|
|
log.info('Mounting kclient client.{id} at {remote} {mnt}...'.format(
|
|
id=id_, remote=remote, mnt=mnt))
|
|
|
|
# figure mon ips
|
|
remotes_and_roles = ctx.cluster.remotes.items()
|
|
roles = [roles for (remote_, roles) in remotes_and_roles]
|
|
ips = [host for (host, port) in (remote_.ssh.get_transport().getpeername() for (remote_, roles) in remotes_and_roles)]
|
|
mons = teuthology.get_mons(roles, ips).values()
|
|
|
|
keyring = '/etc/ceph/ceph.client.{id}.keyring'.format(id=id_)
|
|
secret = '{tdir}/data/client.{id}.secret'.format(tdir=testdir, id=id_)
|
|
teuthology.write_secret_file(ctx, remote, 'client.{id}'.format(id=id_),
|
|
keyring, secret)
|
|
|
|
remote.run(
|
|
args=[
|
|
'mkdir',
|
|
'--',
|
|
mnt,
|
|
],
|
|
)
|
|
|
|
remote.run(
|
|
args=[
|
|
'sudo',
|
|
'adjust-ulimits',
|
|
'ceph-coverage',
|
|
'{tdir}/archive/coverage'.format(tdir=testdir),
|
|
'/sbin/mount.ceph',
|
|
'{mons}:/'.format(mons=','.join(mons)),
|
|
mnt,
|
|
'-v',
|
|
'-o',
|
|
'name={id},secretfile={secret}'.format(id=id_,
|
|
secret=secret),
|
|
],
|
|
)
|
|
|
|
try:
|
|
yield
|
|
finally:
|
|
log.info('Unmounting kernel clients...')
|
|
for id_, remote in clients:
|
|
log.debug('Unmounting client client.{id}...'.format(id=id_))
|
|
mnt = os.path.join(testdir, 'mnt.{id}'.format(id=id_))
|
|
remote.run(
|
|
args=[
|
|
'sudo',
|
|
'umount',
|
|
mnt,
|
|
],
|
|
)
|
|
remote.run(
|
|
args=[
|
|
'rmdir',
|
|
'--',
|
|
mnt,
|
|
],
|
|
)
|