import argparse
import configobj
import contextlib
-import errno
import logging
import os
import json
import uuid
import yaml
-import six
-import toml
-from io import BytesIO
-from six import StringIO
+from io import BytesIO, StringIO
from tarfile import ReadError
from tasks.ceph_manager import CephManager
from teuthology import misc as teuthology
# these items we use from ceph.py should probably eventually move elsewhere
from tasks.ceph import get_mons, healthy
+from tasks.vip import subst_vip
CEPH_ROLE_TYPES = ['mon', 'mgr', 'osd', 'mds', 'rgw', 'prometheus']
def _shell(ctx, cluster_name, remote, args, extra_cephadm_args=[], **kwargs):
- testdir = teuthology.get_testdir(ctx)
+ teuthology.get_testdir(ctx)
return remote.run(
args=[
'sudo',
return conf
+def update_archive_setting(ctx, key, value):
+ """
+ Add logs directory to job's info log file
+ """
+ with open(os.path.join(ctx.archive, 'info.yaml'), 'r+') as info_file:
+ info_yaml = yaml.safe_load(info_file)
+ info_file.seek(0)
+ if 'archive' in info_yaml:
+ info_yaml['archive'][key] = value
+ else:
+ info_yaml['archive'] = {key: value}
+ yaml.safe_dump(info_yaml, info_file, default_flow_style=False)
+
@contextlib.contextmanager
def normalize_hostnames(ctx):
"""
if config.get('cephadm_mode') != 'cephadm-package':
ref = config.get('cephadm_branch', ref)
- git_url = teuth_config.get_ceph_git_url()
+ git_url = config.get('cephadm_git_url', teuth_config.get_ceph_git_url())
log.info('Downloading cephadm (repo %s ref %s)...' % (git_url, ref))
if git_url.startswith('https://github.com/'):
# git archive doesn't like https:// URLs, which we use with github.
cluster_name = config['cluster']
fsid = ctx.ceph[cluster_name].fsid
- # Add logs directory to job's info log file
- with open(os.path.join(ctx.archive, 'info.yaml'), 'r+') as info_file:
- info_yaml = yaml.safe_load(info_file)
- info_file.seek(0)
- if 'archive' not in info_yaml:
- info_yaml['archive'] = {'log': '/var/log/ceph'}
- else:
- info_yaml['archive']['log'] = '/var/log/ceph'
- yaml.safe_dump(info_yaml, info_file, default_flow_style=False)
+ update_archive_setting(ctx, 'log', '/var/log/ceph')
+
try:
yield
cluster_name = config['cluster']
fsid = ctx.ceph[cluster_name].fsid
- # Add logs directory to job's info log file
- with open(os.path.join(ctx.archive, 'info.yaml'), 'r+') as info_file:
- info_yaml = yaml.safe_load(info_file)
- info_file.seek(0)
- if 'archive' not in info_yaml:
- info_yaml['archive'] = {'crash': '/var/lib/ceph/%s/crash' % fsid}
- else:
- info_yaml['archive']['crash'] = '/var/lib/ceph/%s/crash' % fsid
- yaml.safe_dump(info_yaml, info_file, default_flow_style=False)
+ update_archive_setting(ctx, 'crash', '/var/lib/ceph/crash')
try:
yield
pass
@contextlib.contextmanager
-def ceph_bootstrap(ctx, config, registry):
+def ceph_bootstrap(ctx, config):
"""
- Bootstrap ceph cluster, setup containers' registry mirror before
- the bootstrap if the registry is provided.
+ Bootstrap ceph cluster.
:param ctx: the argparse.Namespace object
:param config: the config dict
- :param registry: url to containers' mirror registry
"""
cluster_name = config['cluster']
testdir = teuthology.get_testdir(ctx)
ctx.cluster.run(args=[
'sudo', 'chmod', '777', '/etc/ceph',
]);
- if registry:
- add_mirror_to_cluster(ctx, registry)
try:
# write seed config
log.info('Writing seed config...')
conf_fp = BytesIO()
seed_config = build_initial_config(ctx, config)
seed_config.write(conf_fp)
- teuthology.write_file(
- remote=bootstrap_remote,
+ bootstrap_remote.write_file(
path='{}/seed.{}.conf'.format(testdir, cluster_name),
data=conf_fp.getvalue())
log.debug('Final config:\n' + conf_fp.getvalue().decode())
cmd += ['--mon-ip', mons[first_mon_role]]
if config.get('skip_dashboard'):
cmd += ['--skip-dashboard']
+ if config.get('skip_monitoring_stack'):
+ cmd += ['--skip-monitoring-stack']
# bootstrap makes the keyring root 0600, so +r it for our purposes
cmd += [
run.Raw('&&'),
# fetch keys and configs
log.info('Fetching config...')
- ctx.ceph[cluster_name].config_file = teuthology.get_file(
- remote=bootstrap_remote,
- path='/etc/ceph/{}.conf'.format(cluster_name))
+ ctx.ceph[cluster_name].config_file = \
+ bootstrap_remote.read_file(f'/etc/ceph/{cluster_name}.conf')
log.info('Fetching client.admin keyring...')
- ctx.ceph[cluster_name].admin_keyring = teuthology.get_file(
- remote=bootstrap_remote,
- path='/etc/ceph/{}.client.admin.keyring'.format(cluster_name))
+ ctx.ceph[cluster_name].admin_keyring = \
+ bootstrap_remote.read_file(f'/etc/ceph/{cluster_name}.client.admin.keyring')
log.info('Fetching mon keyring...')
- ctx.ceph[cluster_name].mon_keyring = teuthology.get_file(
- remote=bootstrap_remote,
- path='/var/lib/ceph/%s/mon.%s/keyring' % (fsid, first_mon),
- sudo=True)
+ ctx.ceph[cluster_name].mon_keyring = \
+ bootstrap_remote.read_file(f'/var/lib/ceph/{fsid}/mon.{first_mon}/keyring', sudo=True)
# fetch ssh key, distribute to additional nodes
log.info('Fetching pub ssh key...')
- ssh_pub_key = teuthology.get_file(
- remote=bootstrap_remote,
- path='{}/{}.pub'.format(testdir, cluster_name)
- ).decode('ascii').strip()
+ ssh_pub_key = bootstrap_remote.read_file(
+ f'{testdir}/{cluster_name}.pub').decode('ascii').strip()
log.info('Installing pub ssh key for root users...')
ctx.cluster.run(args=[
])
# set options
- _shell(ctx, cluster_name, bootstrap_remote,
- ['ceph', 'config', 'set', 'mgr', 'mgr/cephadm/allow_ptrace', 'true'])
+ if config.get('allow_ptrace', True):
+ _shell(ctx, cluster_name, bootstrap_remote,
+ ['ceph', 'config', 'set', 'mgr', 'mgr/cephadm/allow_ptrace', 'true'])
# add other hosts
for remote in ctx.cluster.remotes.keys():
if remote == bootstrap_remote:
continue
log.info('Writing (initial) conf and keyring to %s' % remote.shortname)
- teuthology.write_file(
- remote=remote,
+ remote.write_file(
path='/etc/ceph/{}.conf'.format(cluster_name),
data=ctx.ceph[cluster_name].config_file)
- teuthology.write_file(
- remote=remote,
+ remote.write_file(
path='/etc/ceph/{}.client.admin.keyring'.format(cluster_name),
data=ctx.ceph[cluster_name].admin_keyring)
# this doesn't block until they are all stopped...
#ctx.cluster.run(args=['sudo', 'systemctl', 'stop', 'ceph.target'])
- # so, stop them individually
+ # stop the daemons we know
for role in ctx.daemons.resolve_role_list(None, CEPH_ROLE_TYPES, True):
cluster, type_, id_ = teuthology.split_role(role)
try:
ctx.daemons.get_daemon(type_, id_, cluster).stop()
except Exception:
- log.exception('Failed to stop "{role}"'.format(role=role))
+ log.exception(f'Failed to stop "{role}"')
raise
+ # tear down anything left (but leave the logs behind)
+ ctx.cluster.run(
+ args=[
+ 'sudo',
+ ctx.cephadm,
+ 'rm-cluster',
+ '--fsid', fsid,
+ '--force',
+ '--keep-logs',
+ ],
+ check_status=False, # may fail if upgrading from old cephadm
+ )
+
# clean up /etc/ceph
ctx.cluster.run(args=[
'sudo', 'rm', '-f',
"""
cluster_name = config['cluster']
fsid = ctx.ceph[cluster_name].fsid
- num_mons = 1
try:
- for remote, roles in ctx.cluster.remotes.items():
- for mon in [r for r in roles
- if teuthology.is_type('mon', cluster_name)(r)]:
- c_, _, id_ = teuthology.split_role(mon)
- if c_ == cluster_name and id_ == ctx.ceph[cluster_name].first_mon:
- continue
- log.info('Adding %s on %s' % (mon, remote.shortname))
- num_mons += 1
- _shell(ctx, cluster_name, remote, [
- 'ceph', 'orch', 'daemon', 'add', 'mon',
- remote.shortname + ':' + ctx.ceph[cluster_name].mons[mon] + '=' + id_,
- ])
+ daemons = {}
+ if config.get('add_mons_via_daemon_add'):
+ # This is the old way of adding mons that works with the (early) octopus
+ # cephadm scheduler.
+ num_mons = 1
+ for remote, roles in ctx.cluster.remotes.items():
+ for mon in [r for r in roles
+ if teuthology.is_type('mon', cluster_name)(r)]:
+ c_, _, id_ = teuthology.split_role(mon)
+ if c_ == cluster_name and id_ == ctx.ceph[cluster_name].first_mon:
+ continue
+ log.info('Adding %s on %s' % (mon, remote.shortname))
+ num_mons += 1
+ _shell(ctx, cluster_name, remote, [
+ 'ceph', 'orch', 'daemon', 'add', 'mon',
+ remote.shortname + ':' + ctx.ceph[cluster_name].mons[mon] + '=' + id_,
+ ])
+ ctx.daemons.register_daemon(
+ remote, 'mon', id_,
+ cluster=cluster_name,
+ fsid=fsid,
+ logger=log.getChild(mon),
+ wait=False,
+ started=True,
+ )
+ daemons[mon] = (remote, id_)
+
+ with contextutil.safe_while(sleep=1, tries=180) as proceed:
+ while proceed():
+ log.info('Waiting for %d mons in monmap...' % (num_mons))
+ r = _shell(
+ ctx=ctx,
+ cluster_name=cluster_name,
+ remote=remote,
+ args=[
+ 'ceph', 'mon', 'dump', '-f', 'json',
+ ],
+ stdout=StringIO(),
+ )
+ j = json.loads(r.stdout.getvalue())
+ if len(j['mons']) == num_mons:
+ break
+ else:
+ nodes = []
+ for remote, roles in ctx.cluster.remotes.items():
+ for mon in [r for r in roles
+ if teuthology.is_type('mon', cluster_name)(r)]:
+ c_, _, id_ = teuthology.split_role(mon)
+ log.info('Adding %s on %s' % (mon, remote.shortname))
+ nodes.append(remote.shortname
+ + ':' + ctx.ceph[cluster_name].mons[mon]
+ + '=' + id_)
+ if c_ == cluster_name and id_ == ctx.ceph[cluster_name].first_mon:
+ continue
+ daemons[mon] = (remote, id_)
+
+ _shell(ctx, cluster_name, remote, [
+ 'ceph', 'orch', 'apply', 'mon',
+ str(len(nodes)) + ';' + ';'.join(nodes)]
+ )
+ for mgr, i in daemons.items():
+ remote, id_ = i
ctx.daemons.register_daemon(
remote, 'mon', id_,
cluster=cluster_name,
started=True,
)
- with contextutil.safe_while(sleep=1, tries=180) as proceed:
- while proceed():
- log.info('Waiting for %d mons in monmap...' % (num_mons))
- r = _shell(
- ctx=ctx,
- cluster_name=cluster_name,
- remote=remote,
- args=[
- 'ceph', 'mon', 'dump', '-f', 'json',
- ],
- stdout=StringIO(),
- )
- j = json.loads(r.stdout.getvalue())
- if len(j['mons']) == num_mons:
- break
+ with contextutil.safe_while(sleep=1, tries=180) as proceed:
+ while proceed():
+ log.info('Waiting for %d mons in monmap...' % (len(nodes)))
+ r = _shell(
+ ctx=ctx,
+ cluster_name=cluster_name,
+ remote=remote,
+ args=[
+ 'ceph', 'mon', 'dump', '-f', 'json',
+ ],
+ stdout=StringIO(),
+ )
+ j = json.loads(r.stdout.getvalue())
+ if len(j['mons']) == len(nodes):
+ break
# refresh our (final) ceph.conf file
bootstrap_remote = ctx.ceph[cluster_name].bootstrap_remote
for mgr in [r for r in roles
if teuthology.is_type('mgr', cluster_name)(r)]:
c_, _, id_ = teuthology.split_role(mgr)
- if c_ == cluster_name and id_ == ctx.ceph[cluster_name].first_mgr:
- continue
log.info('Adding %s on %s' % (mgr, remote.shortname))
nodes.append(remote.shortname + '=' + id_)
+ if c_ == cluster_name and id_ == ctx.ceph[cluster_name].first_mgr:
+ continue
daemons[mgr] = (remote, id_)
if nodes:
_shell(ctx, cluster_name, remote, [
'ceph', 'orch', 'apply', 'mgr',
- str(len(nodes) + 1) + ';' + ';'.join(nodes)]
+ str(len(nodes)) + ';' + ';'.join(nodes)]
)
for mgr, i in daemons.items():
remote, id_ = i
if teuthology.is_type('rgw', cluster_name)(r)]:
c_, _, id_ = teuthology.split_role(role)
log.info('Adding %s on %s' % (role, remote.shortname))
- realmzone = '.'.join(id_.split('.')[0:2])
- if realmzone not in nodes:
- nodes[realmzone] = []
- nodes[realmzone].append(remote.shortname + '=' + id_)
+ svc = '.'.join(id_.split('.')[0:2])
+ if svc not in nodes:
+ nodes[svc] = []
+ nodes[svc].append(remote.shortname + '=' + id_)
daemons[role] = (remote, id_)
- for realmzone in nodes.keys():
- (realm, zone) = realmzone.split('.', 1)
-
- # TODO: those should be moved to mgr/cephadm
- _shell(ctx, cluster_name, remote,
- ['radosgw-admin', 'realm', 'create', '--rgw-realm', realm, '--default']
- )
- _shell(ctx, cluster_name, remote,
- ['radosgw-admin', 'zonegroup', 'create', '--rgw-zonegroup=default', '--master', '--default']
- )
- _shell(ctx, cluster_name, remote,
- ['radosgw-admin', 'zone', 'create', '--rgw-zonegroup=default', '--rgw-zone', zone, '--master', '--default']
- )
-
- for realmzone, nodes in nodes.items():
- (realm, zone) = realmzone.split('.', 1)
+ for svc, nodes in nodes.items():
_shell(ctx, cluster_name, remote, [
- 'ceph', 'orch', 'apply', 'rgw', realm, zone,
+ 'ceph', 'orch', 'apply', 'rgw', svc,
'--placement',
str(len(nodes)) + ';' + ';'.join(nodes)]
)
@contextlib.contextmanager
def ceph_clients(ctx, config):
cluster_name = config['cluster']
- testdir = teuthology.get_testdir(ctx)
log.info('Setting up client nodes...')
clients = ctx.cluster.only(teuthology.is_type('client', cluster_name))
- testdir = teuthology.get_testdir(ctx)
- coverage_dir = '{tdir}/archive/coverage'.format(tdir=testdir)
for remote, roles_for_host in clients.remotes.items():
for role in teuthology.cluster_roles_of_type(roles_for_host, 'client',
cluster_name):
stdout=StringIO(),
)
keyring = r.stdout.getvalue()
- teuthology.sudo_write_file(
- remote=remote,
- path=client_keyring,
- data=keyring,
- perms='0644'
- )
+ remote.sudo_write_file(client_keyring, keyring, mode='0644')
yield
@contextlib.contextmanager
env.extend(['-e', k + '=' + ctx.config.get(k, '')])
del config['env']
- if 'all' in config and len(config) == 1:
- a = config['all']
+ if 'all-roles' in config and len(config) == 1:
+ a = config['all-roles']
roles = teuthology.all_roles(ctx.cluster)
- config = dict((id_, a) for id_ in roles)
+ config = dict((id_, a) for id_ in roles if not id_.startswith('host.'))
+ elif 'all-hosts' in config and len(config) == 1:
+ a = config['all-hosts']
+ roles = teuthology.all_roles(ctx.cluster)
+ config = dict((id_, a) for id_ in roles if id_.startswith('host.'))
- for role, ls in config.items():
+ for role, cmd in config.items():
(remote,) = ctx.cluster.only(role).remotes.keys()
log.info('Running commands on role %s host %s', role, remote.name)
- for c in ls:
+ if isinstance(cmd, list):
+ for c in cmd:
+ _shell(ctx, cluster_name, remote,
+ ['bash', '-c', subst_vip(ctx, c)],
+ extra_cephadm_args=env)
+ else:
+ assert isinstance(cmd, str)
_shell(ctx, cluster_name, remote,
- ['bash', '-c', c],
+ ['bash', '-ex', '-c', subst_vip(ctx, cmd)],
extra_cephadm_args=env)
+
+def apply(ctx, config):
+ """
+ Apply spec
+
+ tasks:
+ - cephadm.apply:
+ specs:
+ - service_type: rgw
+ service_id: foo
+ spec:
+ rgw_frontend_port: 8000
+ - service_type: rgw
+ service_id: bar
+ spec:
+ rgw_frontend_port: 9000
+ zone: bar
+ realm: asdf
+
+ """
+ cluster_name = config.get('cluster', 'ceph')
+
+ specs = config.get('specs', [])
+ y = subst_vip(ctx, yaml.dump_all(specs))
+
+ log.info(f'Applying spec(s):\n{y}')
+ _shell(
+ ctx, cluster_name, ctx.ceph[cluster_name].bootstrap_remote,
+ ['ceph', 'orch', 'apply', '-i', '-'],
+ stdin=y,
+ )
+
+
+def wait_for_service(ctx, config):
+ """
+ Wait for a service to be fully started
+
+ tasks:
+ - cephadm.wait_for_service:
+ service: rgw.foo
+ timeout: 60 # defaults to 300
+
+ """
+ cluster_name = config.get('cluster', 'ceph')
+ timeout = config.get('timeout', 300)
+ service = config.get('service')
+ assert service
+
+ log.info(
+ f'Waiting for {cluster_name} service {service} to start (timeout {timeout})...'
+ )
+ with contextutil.safe_while(sleep=1, tries=timeout) as proceed:
+ while proceed():
+ r = _shell(
+ ctx=ctx,
+ cluster_name=cluster_name,
+ remote=ctx.ceph[cluster_name].bootstrap_remote,
+ args=[
+ 'ceph', 'orch', 'ls', '-f', 'json',
+ ],
+ stdout=StringIO(),
+ )
+ j = json.loads(r.stdout.getvalue())
+ svc = None
+ for s in j:
+ if s['service_name'] == service:
+ svc = s
+ break
+ if svc:
+ log.info(
+ f"{service} has {s['status']['running']}/{s['status']['size']}"
+ )
+ if s['status']['running'] == s['status']['size']:
+ break
+
+
@contextlib.contextmanager
def tweaked_option(ctx, config):
"""
cluster_name = config['cluster']
log.info('Distributing (final) config and client.admin keyring...')
for remote, roles in ctx.cluster.remotes.items():
- teuthology.sudo_write_file(
- remote=remote,
- path='/etc/ceph/{}.conf'.format(cluster_name),
- data=ctx.ceph[cluster_name].config_file)
- teuthology.sudo_write_file(
- remote=remote,
+ remote.write_file(
+ '/etc/ceph/{}.conf'.format(cluster_name),
+ ctx.ceph[cluster_name].config_file,
+ sudo=True)
+ remote.write_file(
path='/etc/ceph/{}.client.admin.keyring'.format(cluster_name),
- data=ctx.ceph[cluster_name].admin_keyring)
+ data=ctx.ceph[cluster_name].admin_keyring,
+ sudo=True)
try:
yield
finally:
args=['ceph', 'osd', 'crush', 'tunables', profile])
yield
+@contextlib.contextmanager
+def create_rbd_pool(ctx, config):
+ if config.get('create_rbd_pool', False):
+ cluster_name = config['cluster']
+ log.info('Waiting for OSDs to come up')
+ teuthology.wait_until_osds_up(
+ ctx,
+ cluster=ctx.cluster,
+ remote=ctx.ceph[cluster_name].bootstrap_remote,
+ ceph_cluster=cluster_name,
+ )
+ log.info('Creating RBD pool')
+ _shell(ctx, cluster_name, ctx.ceph[cluster_name].bootstrap_remote,
+ args=['sudo', 'ceph', '--cluster', cluster_name,
+ 'osd', 'pool', 'create', 'rbd', '8'])
+ _shell(ctx, cluster_name, ctx.ceph[cluster_name].bootstrap_remote,
+ args=['sudo', 'ceph', '--cluster', cluster_name,
+ 'osd', 'pool', 'application', 'enable',
+ 'rbd', 'rbd', '--yes-i-really-mean-it'
+ ])
+ yield
+
@contextlib.contextmanager
def _bypass():
yield
"""
Deploy ceph cluster using cephadm
- Setup containers' mirrors before the bootstrap, if corresponding
- config provided in teuthology server config yaml file.
-
For example, teuthology.yaml can contain the 'defaults' section:
defaults:
cephadm:
containers:
- registry_mirrors:
- docker.io: 'registry.mirror.example.com:5000'
image: 'quay.io/ceph-ci/ceph'
Using overrides makes it possible to customize it per run.
overrides:
cephadm:
containers:
- registry_mirrors:
- docker.io: 'registry.mirror.example.com:5000'
image: 'quay.io/ceph-ci/ceph'
:param ctx: the argparse.Namespace object
teuthology.deep_merge(config, overrides.get('cephadm', {}))
log.info('Config: ' + str(config))
- testdir = teuthology.get_testdir(ctx)
-
# set up cluster context
if not hasattr(ctx, 'ceph'):
ctx.ceph = {}
teuth_defaults = teuth_config.get('defaults', {})
cephadm_defaults = teuth_defaults.get('cephadm', {})
containers_defaults = cephadm_defaults.get('containers', {})
- mirrors_defaults = containers_defaults.get('registry_mirrors', {})
- container_registry_mirror = mirrors_defaults.get('docker.io', None)
container_image_name = containers_defaults.get('image', None)
containers = config.get('containers', {})
- mirrors = containers.get('registry_mirrors', {})
container_image_name = containers.get('image', container_image_name)
- container_registry_mirror = mirrors.get('docker.io',
- container_registry_mirror)
if not hasattr(ctx.ceph[cluster_name], 'image'):
lambda: ceph_log(ctx=ctx, config=config),
lambda: ceph_crash(ctx=ctx, config=config),
lambda: _bypass() if (ctx.ceph[cluster_name].bootstrapped)\
- else ceph_bootstrap(ctx, config,
- container_registry_mirror),
+ else ceph_bootstrap(ctx, config),
lambda: crush_setup(ctx=ctx, config=config),
lambda: ceph_mons(ctx=ctx, config=config),
lambda: distribute_config_and_admin_keyring(ctx=ctx, config=config),
lambda: ceph_monitoring('alertmanager', ctx=ctx, config=config),
lambda: ceph_monitoring('grafana', ctx=ctx, config=config),
lambda: ceph_clients(ctx=ctx, config=config),
+ lambda: create_rbd_pool(ctx=ctx, config=config),
):
ctx.managers[cluster_name] = CephManager(
ctx.ceph[cluster_name].bootstrap_remote,
finally:
log.info('Teardown begin')
-
-def registries_add_mirror_to_docker_io(conf, mirror):
- config = toml.loads(conf)
- is_v1 = 'registries' in config
- if is_v1:
- search = config.get('registries', {}).get('search', {}).get('registries', [])
- insecure = config.get('registries', {}).get('search', {}).get('insecure', [])
- # v2: MutableMapping[str, Any] = { needs Python 3
- v2 = {
- 'unqualified-search-registries': search,
- 'registry': [
- {
- 'prefix': reg,
- 'location': reg,
- 'insecure': reg in insecure,
- 'blocked': False,
- } for reg in search
- ]
- }
- else:
- v2 = config # type: ignore
- dockers = [
- r for r in v2['registry'] if
- r.get('prefix') == 'docker.io' or r.get('location') == 'docker.io'
- ]
- if dockers:
- docker = dockers[0]
- if 'mirror' not in docker:
- docker['mirror'] = [{
- "location": mirror,
- "insecure": True,
- }]
- return v2
-
-
-def add_mirror_to_cluster(ctx, mirror):
- log.info('Adding local image mirror %s' % mirror)
-
- registries_conf = '/etc/containers/registries.conf'
-
- for remote in ctx.cluster.remotes.keys():
- try:
- config = teuthology.get_file(
- remote=remote,
- path=registries_conf
- )
- new_config = toml.dumps(registries_add_mirror_to_docker_io(config.decode('utf-8'), mirror))
-
- teuthology.sudo_write_file(
- remote=remote,
- path=registries_conf,
- data=six.ensure_str(new_config),
- )
- except IOError as e: # py3: use FileNotFoundError instead.
- if e.errno != errno.ENOENT:
- raise
-
- # Docker doesn't ship a registries.conf
- log.info('Failed to add mirror: %s' % str(e))
projects / ceph.git / blobdiff