comparison mercurial/sshserver.py @ 11369:02a4373ca5cd

pushkey: add ssh support

11368:b9eb005c54ad

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from i18n import _
from node import bin, hex
import streamclone, util, hook
import os, sys, tempfile, urllib, copy

class sshserver(object):

    caps = 'unbundle lookup changegroupsubset branchmap'.split()

    def __init__(self, ui, repo):
        self.ui = ui
        self.repo = repo
        self.lock = None

                self.fout.write(chunk)
            self.fout.flush()
        except streamclone.StreamException, inst:
            self.fout.write(str(inst))
            self.fout.flush()

11369:02a4373ca5cd

# This software may be used and distributed according to the terms of the
# GNU General Public License version 2 or any later version.

from i18n import _
from node import bin, hex
import streamclone, util, hook, pushkey
import os, sys, tempfile, urllib, copy

class sshserver(object):

    caps = 'unbundle lookup changegroupsubset branchmap pushkey'.split()

    def __init__(self, ui, repo):
        self.ui = ui
        self.repo = repo
        self.lock = None

                self.fout.write(chunk)
            self.fout.flush()
        except streamclone.StreamException, inst:
            self.fout.write(str(inst))
            self.fout.flush()

    def do_pushkey(self):
        arg, key = self.getarg()
        arg, namespace = self.getarg()
        arg, new = self.getarg()
        arg, old = self.getarg()
        r = pushkey.push(self.repo, namespace, key, old, new)
        self.respond('%s\n' % int(r))

    def do_listkeys(self):
        arg, namespace = self.getarg()
        d = pushkey.list(self.repo, namespace).items()
        t = '\n'.join(['%s\t%s' % (k.encode('string-escape'),
                                   v.encode('string-escape')) for k, v in d])
        self.respond(t)