Function salt_proxy

salt/scripts.py:391–458

Start a proxy minion.

()

def salt_proxy():
    """
    Start a proxy minion.
    """
    _pin_multiprocessing_fork()

    import multiprocessing

    import salt.cli.daemons
    import salt.utils.platform

    if "" in sys.path:
        sys.path.remove("")

    if salt.utils.platform.is_windows():
        proxyminion = salt.cli.daemons.ProxyMinion()
        proxyminion.start()
        return

    if "--disable-keepalive" in sys.argv:
        proxyminion = salt.cli.daemons.ProxyMinion()
        proxyminion.start()
        return

    # keep one minion subprocess running
    supervisor_privileges_dropped = False
    while True:
        try:
            queue = multiprocessing.Queue()
        except Exception:  # pylint: disable=broad-except
            # This breaks in containers
            proxyminion = salt.cli.daemons.ProxyMinion()
            proxyminion.start()
            return
        process = multiprocessing.Process(
            target=proxy_minion_process, args=(queue,), name="ProxyMinion"
        )
        process.start()
        # See the matching note in salt_minion(); the supervisor only
        # needs root for the first fork's verify_env/pidfile setup, and
        # leaving it as root afterwards is the bug described in #68115.
        if not supervisor_privileges_dropped:
            import salt.config

            _supervisor_drop_privileges(salt.config.proxy_config, "proxy")
            supervisor_privileges_dropped = True
        try:
            process.join()
            try:
                restart_delay = queue.get(block=False)
            except Exception:  # pylint: disable=broad-except
                if process.exitcode == 0:
                    # Minion process ended naturally, Ctrl+C or --version
                    break
                restart_delay = 60
            if restart_delay == 0:
                # Minion process ended naturally, Ctrl+C, --version, etc.
                sys.exit(process.exitcode)