mercurial/sshpeer.py

33805:f913e90f15a0

from .i18n import _
from . import (
    error,
    pycompat,
    repository,
    util,
    wireproto,
)

def _serverquote(s):

        return self._main.close()

    def flush(self):
        return self._main.flush()

class sshpeer(wireproto.wirepeer, repository.legacypeer):
    def __init__(self, ui, path, create=False):
        self._url = path
        self._ui = ui
        self._pipeo = self._pipei = self._pipee = None

            res = ui.system(cmd, blockedtag='sshpeer')
            if res != 0:
                self._abort(error.RepoError(_("could not create remote repo")))

        self._validaterepo(sshcmd, args, remotecmd)

        # TODO remove this alias once peerrepository inheritance is removed.
        self._capabilities = self.capabilities

    # Begin of _basepeer interface.

    @util.propertycache
    def ui(self):

33806:dedab036215d

from .i18n import _
from . import (
    error,
    pycompat,
    util,
    wireproto,
)

def _serverquote(s):

        return self._main.close()

    def flush(self):
        return self._main.flush()

class sshpeer(wireproto.wirepeer):
    def __init__(self, ui, path, create=False):
        self._url = path
        self._ui = ui
        self._pipeo = self._pipei = self._pipee = None

            res = ui.system(cmd, blockedtag='sshpeer')
            if res != 0:
                self._abort(error.RepoError(_("could not create remote repo")))

        self._validaterepo(sshcmd, args, remotecmd)

    # Begin of _basepeer interface.

    @util.propertycache
    def ui(self):