def deploy_daemon(fsid, daemon_type, daemon_id, c, uid, gid,
config, keyring):
- # type: (str, str, Union[int, str], CephContainer, int, int, str, str) -> None
- if daemon_type == 'mon' and not os.path.exists(get_data_dir(fsid, 'mon',
- daemon_id)):
+ # type: (str, str, Union[int, str], CephContainer, int, int, Optional[str], Optional[str]) -> None
+ if daemon_type == 'mon' and not os.path.exists(
+ get_data_dir(fsid, 'mon', daemon_id)):
+ assert config
+ assert keyring
# tmp keyring file
- tmp_keyring = tempfile.NamedTemporaryFile(mode='w')
- os.fchmod(tmp_keyring.fileno(), 0o600)
- os.fchown(tmp_keyring.fileno(), uid, gid)
- tmp_keyring.write(keyring)
- tmp_keyring.flush()
+ tmp_keyring = write_tmp(keyring, uid, gid)
# tmp config file
- tmp_config = tempfile.NamedTemporaryFile(mode='w')
- os.fchmod(tmp_config.fileno(), 0o600)
- os.fchown(tmp_config.fileno(), uid, gid)
- tmp_config.write(config)
- tmp_config.flush()
+ tmp_config = write_tmp(config, uid, gid)
# --mkfs
create_daemon_dirs(fsid, daemon_type, daemon_id, uid, gid)
f.write(config)
mon_c = get_container(fsid, 'mon', mon_id)
- deploy_daemon_units(fsid, uid, gid, 'mon', mon_id, mon_c)
+ deploy_daemon(fsid, 'mon', mon_id, mon_c, uid, gid,
+ config=None, keyring=None)
# client.admin key + config to issue various CLI commands
- tmp_admin_keyring = tempfile.NamedTemporaryFile(mode='w')
- os.fchmod(tmp_admin_keyring.fileno(), 0o600)
- os.fchown(tmp_admin_keyring.fileno(), uid, gid)
- tmp_admin_keyring.write('[client.admin]\n'
- '\tkey = ' + admin_key + '\n')
- tmp_admin_keyring.flush()
-
- tmp_config = tempfile.NamedTemporaryFile(mode='w')
- os.fchmod(tmp_config.fileno(), 0o600)
- os.fchown(tmp_config.fileno(), uid, gid)
- tmp_config.write(config)
- tmp_config.flush()
+ tmp_admin_keyring = write_tmp('[client.admin]\n'
+ '\tkey = ' + admin_key + '\n',
+ uid, gid)
+ tmp_config = write_tmp(config, uid, gid)
# a CLI helper to reduce our typing
def cli(cmd, extra_mounts={}):