# Path: sshuttle/helpers.py
# def debug1(s):
#     if verbose >= 1:
#         log(s)


import socket
import os
from sshuttle.helpers import debug1
For details, see:
https://www.freedesktop.org/software/systemd/man/sd_notify.html
"""




def _notify(message):
    """Send a notification message to systemd."""
    addr = os.environ.get("NOTIFY_SOCKET", None)

    if not addr or len(addr) == 1 or addr[0] not in ('/', '@'):
        return False

    addr = '\0' + addr[1:] if addr[0] == '@' else addr

    try:
        sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
    except (OSError, IOError) as e:
        debug1("Error creating socket to notify systemd: %s" % e)
        return False

    if not message:
        return False

    assert isinstance(message, bytes)

    try:
        return (sock.sendto(message, addr) > 0)
    except (OSError, IOError) as e:

# Path: sshuttle/helpers.py
# def debug1(s):
#     if verbose >= 1:
#         log(s)


# Path: sshuttle/sdnotify.py
import socket
import os
from sshuttle.helpers import debug1

For details, see:
https://www.freedesktop.org/software/systemd/man/sd_notify.html
"""




def _notify(message):
    """Send a notification message to systemd."""
    addr = os.environ.get("NOTIFY_SOCKET", None)

    if not addr or len(addr) == 1 or addr[0] not in ('/', '@'):
        return False

    addr = '\0' + addr[1:] if addr[0] == '@' else addr

    try:
        sock = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM)
    except (OSError, IOError) as e:
        debug1("Error creating socket to notify systemd: %s" % e)
        return False

    if not message:
        return False

    assert isinstance(message, bytes)

    try:
        return (sock.sendto(message, addr) > 0)
    except (OSError, IOError) as e:

        debug1("Error notifying systemd: %s" % e)