mercurial/sshpeer.py

37613:96d735601ca1

    pycompat,
    util,
    wireproto,
    wireprotoserver,
    wireprototypes,
)
from .utils import (
    procutil,
)

    # Flush any output on stderr before proceeding.
    _forwardoutput(ui, stderr)

    return protoname, caps

class sshv1peer(wireproto.wirepeer):
    def __init__(self, ui, url, proc, stdin, stdout, stderr, caps,
                 autoreadstderr=True):
        """Create a peer from an existing SSH connection.

        ``proc`` is a handle on the underlying SSH process.

                              protoname)

def instance(ui, path, create):
    """Create an SSH peer.

    The returned object conforms to the ``wireproto.wirepeer`` interface.
    """
    u = util.url(path, parsequery=False, parsefragment=False)
    if u.scheme != 'ssh' or not u.host or u.path is None:
        raise error.RepoError(_("couldn't parse location %s") % path)

37614:a81d02ea65db

    pycompat,
    util,
    wireproto,
    wireprotoserver,
    wireprototypes,
    wireprotov1peer,
)
from .utils import (
    procutil,
)

    # Flush any output on stderr before proceeding.
    _forwardoutput(ui, stderr)

    return protoname, caps

class sshv1peer(wireprotov1peer.wirepeer):
    def __init__(self, ui, url, proc, stdin, stdout, stderr, caps,
                 autoreadstderr=True):
        """Create a peer from an existing SSH connection.

        ``proc`` is a handle on the underlying SSH process.

                              protoname)

def instance(ui, path, create):
    """Create an SSH peer.

    The returned object conforms to the ``wireprotov1peer.wirepeer`` interface.
    """
    u = util.url(path, parsequery=False, parsefragment=False)
    if u.scheme != 'ssh' or not u.host or u.path is None:
        raise error.RepoError(_("couldn't parse location %s") % path)