mercurial/sshpeer.py

50480:afb27fc92717

        # We add our own stack trace, because the stacktrace when called
        # from __del__ is useless.
        ui.develwarn(b'missing close on SSH connection created at:\n%s' % warn)


def _makeconnection(ui, sshcmd, args, remotecmd, path, sshenv=None):
    """Create an SSH connection to a server.

    Returns a tuple of (process, stdin, stdout, stderr) for the
    spawned process.
    """
    cmd = b'%s %s %s' % (
        sshcmd,
        args,
        procutil.shellquote(
            b'%s -R %s serve --stdio'
            % (_serverquote(remotecmd), _serverquote(path))
        ),
    )

    ui.debug(b'running %s\n' % cmd)

        ``caps`` is a set of capabilities supported by the remote.
        ``autoreadstderr`` denotes whether to automatically read from
        stderr and to forward its output.
        """
        super().__init__(ui, path=path, remotehidden=remotehidden)
        if remotehidden:
            msg = _(
                b"ignoring `--remote-hidden` request\n"
                b"(access to hidden changeset for ssh peers not supported "
                b"yet)\n"
            )
            ui.warn(msg)
        # self._subprocess is unused. Keeping a handle on the process
        # holds a reference and prevents it from being garbage collected.
        self._subprocess = proc

        # And we hook up our "doublepipe" wrapper to allow querying

        self._pipei = stdout
        self._pipee = stderr
        self._caps = caps
        self._autoreadstderr = autoreadstderr
        self._initstack = b''.join(util.getstackframes(1))

    # Commands that have a "framed" response where the first line of the
    # response contains the length of that response.
    _FRAMED_COMMANDS = {
        b'batch',

        res = ui.system(cmd, blockedtag=b'sshpeer', environ=sshenv)
        if res != 0:
            raise error.RepoError(_(b'could not create remote repo'))

    proc, stdin, stdout, stderr = _makeconnection(
        ui, sshcmd, args, remotecmd, remotepath, sshenv
    )

    peer = _make_peer(
        ui, path, proc, stdin, stdout, stderr, remotehidden=remotehidden
    )

50481:45c7bada5200

        # We add our own stack trace, because the stacktrace when called
        # from __del__ is useless.
        ui.develwarn(b'missing close on SSH connection created at:\n%s' % warn)


def _makeconnection(
    ui, sshcmd, args, remotecmd, path, sshenv=None, remotehidden=False
):
    """Create an SSH connection to a server.

    Returns a tuple of (process, stdin, stdout, stderr) for the
    spawned process.
    """
    cmd = b'%s %s %s' % (
        sshcmd,
        args,
        procutil.shellquote(
            b'%s -R %s serve --stdio%s'
            % (
                _serverquote(remotecmd),
                _serverquote(path),
                b' --hidden' if remotehidden else b'',
            )
        ),
    )

    ui.debug(b'running %s\n' % cmd)

        ``caps`` is a set of capabilities supported by the remote.
        ``autoreadstderr`` denotes whether to automatically read from
        stderr and to forward its output.
        """
        super().__init__(ui, path=path, remotehidden=remotehidden)
        # self._subprocess is unused. Keeping a handle on the process
        # holds a reference and prevents it from being garbage collected.
        self._subprocess = proc

        # And we hook up our "doublepipe" wrapper to allow querying

        self._pipei = stdout
        self._pipee = stderr
        self._caps = caps
        self._autoreadstderr = autoreadstderr
        self._initstack = b''.join(util.getstackframes(1))
        self._remotehidden = remotehidden

    # Commands that have a "framed" response where the first line of the
    # response contains the length of that response.
    _FRAMED_COMMANDS = {
        b'batch',

        res = ui.system(cmd, blockedtag=b'sshpeer', environ=sshenv)
        if res != 0:
            raise error.RepoError(_(b'could not create remote repo'))

    proc, stdin, stdout, stderr = _makeconnection(
        ui,
        sshcmd,
        args,
        remotecmd,
        remotepath,
        sshenv,
        remotehidden=remotehidden,
    )

    peer = _make_peer(
        ui, path, proc, stdin, stdout, stderr, remotehidden=remotehidden
    )