FileMgr

✏️ /usr/lib/python3/dist-packages/cloudinit/atomic_helper.py

✕ Tutup

# This file is part of cloud-init. See LICENSE file for license information.

import json
import logging
import os
import stat
import tempfile
from base64 import b64decode, b64encode

from cloudinit import performance, util

_DEF_PERMS = 0o644
LOG = logging.getLogger(__name__)

@performance.timed("Base64 decoding")
def b64d(source):
    """base64 decode data

:param source: a bytes or str to decode
    :return: base64 as a decoded str if utf-8 encoded, otherwise bytes
    """
    decoded = b64decode(source)
    try:
        return decoded.decode("utf-8")
    except UnicodeDecodeError:
        return decoded

@performance.timed("Base64 encoding")
def b64e(source):
    """base64 encode data

:param source: a bytes or str to decode
    :return: base64 encoded str
    """
    if not isinstance(source, bytes):
        source = source.encode("utf-8")
    return b64encode(source).decode("utf-8")

def write_file(
    filename, content, mode=_DEF_PERMS, omode="wb", preserve_mode=False
):
    """open filename in mode omode, write content, set permissions to mode"""

with performance.Timed(f"Writing {filename}"):
        return _write_file(filename, content, mode, omode, preserve_mode)

def _write_file(
    filename, content, mode=_DEF_PERMS, omode="wb", preserve_mode=False
):
    if preserve_mode:
        try:
            file_stat = os.stat(filename)
            mode = stat.S_IMODE(file_stat.st_mode)
        except OSError:
            pass

tf = None
    try:
        dirname = os.path.dirname(filename)
        util.ensure_dir(dirname)
        tf = tempfile.NamedTemporaryFile(dir=dirname, delete=False, mode=omode)
        LOG.debug(
            "Atomically writing to file %s (via temporary file %s) - %s: [%o]"
            " %d bytes/chars",
            filename,
            tf.name,
            omode,
            mode,
            len(content),
        )
        tf.write(content)
        tf.close()
        os.chmod(tf.name, mode)
        os.rename(tf.name, filename)
    except Exception as e:
        if tf is not None:
            os.unlink(tf.name)
        raise e

def json_serialize_default(_obj):
    """Handler for types which aren't json serializable."""
    try:
        return "ci-b64:{0}".format(b64e(_obj))
    except AttributeError:
        return "Warning: redacted unserializable type {0}".format(type(_obj))

@performance.timed("Dumping json")
def json_dumps(data):
    """Return data in nicely formatted json."""
    return json.dumps(
        data,
        indent=1,
        sort_keys=True,
        separators=(",", ": "),
        default=json_serialize_default,
    )

def write_json(filename, data, mode=_DEF_PERMS):
    # dump json representation of data to file filename.
    return write_file(
        filename,
        json_dumps(data) + "\n",
        omode="w",
        mode=mode,
    )

Batal

⬅ dist-packages 43 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📁 __pycache__	dir	—	15/06/26 13:46	0755	📂
📁 analyze	dir	—	15/06/26 13:46	0755	📂
📁 cmd	dir	—	15/06/26 13:46	0755	📂
📁 config	dir	—	15/06/26 13:46	0755	📂
📁 distros	dir	—	15/06/26 13:46	0755	📂
📁 filters	dir	—	15/06/26 13:46	0755	📂
📁 handlers	dir	—	15/06/26 13:46	0755	📂
📁 log	dir	—	15/06/26 13:46	0755	📂
📁 mergers	dir	—	15/06/26 13:46	0755	📂
📁 net	dir	—	15/06/26 13:46	0755	📂
📁 reporting	dir	—	15/06/26 13:46	0755	📂
📁 sources	dir	—	15/06/26 13:46	0755	📂
🐍 __init__.py	py	0 B	27/02/26 22:51	0644	✏️ ⬇
🐍 apport.py	py	8.3 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 atomic_helper.py	py	2.8 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 cloud.py	py	3.7 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 dmi.py	py	7.8 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 event.py	py	2 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 features.py	py	5.6 KB	30/03/26 18:55	0644	✏️ ⬇
🐍 gpg.py	py	8 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 helpers.py	py	16.2 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 importer.py	py	2.8 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 lifecycle.py	py	7.8 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 netinfo.py	py	24.1 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 performance.py	py	3.1 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 persistence.py	py	2.5 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 registry.py	py	1022 B	27/02/26 22:51	0644	✏️ ⬇
🐍 safeyaml.py	py	10.1 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 settings.py	py	2.1 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 signal_handler.py	py	3 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 simpletable.py	py	1.9 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 socket.py	py	5.9 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 ssh_util.py	py	22.5 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 stages.py	py	41.5 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 subp.py	py	12.4 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 temp_utils.py	py	2.9 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 templater.py	py	7.7 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 type_utils.py	py	703 B	27/02/26 22:51	0644	✏️ ⬇
🐍 url_helper.py	py	38.2 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 user_data.py	py	14.4 KB	27/02/26 22:51	0644	✏️ ⬇
🐍 util.py	py	90.7 KB	30/03/26 18:55	0644	✏️ ⬇
🐍 version.py	py	831 B	30/03/26 18:55	0644	✏️ ⬇
🐍 warnings.py	py	3.8 KB	27/02/26 22:51	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission