merge with upstream
authorBenoit Boissinot <benoit.boissinot@ens-lyon.org>
Sat, 10 Jun 2006 11:28:40 +0200
changeset 2423 f328e8aeff8b
parent 2422 6aa75e77cafe (current diff)
parent 2421 a1cfe679192c (diff)
child 2424 092039246d73
merge with upstream
--- a/mercurial/sshrepo.py	Fri Jun 09 12:05:17 2006 -0700
+++ b/mercurial/sshrepo.py	Sat Jun 10 11:28:40 2006 +0200
@@ -37,24 +37,31 @@
         self.pipeo, self.pipei, self.pipee = os.popen3(cmd, 'b')
 
         # skip any noise generated by remote shell
+        self.do_cmd("hello")
         r = self.do_cmd("between", pairs=("%s-%s" % ("0"*40, "0"*40)))
-        l1 = ""
-        l2 = "dummy"
+        lines = ["", "dummy"]
         max_noise = 500
-        while l2 and max_noise:
-            l2 = r.readline()
+        while lines[-1] and max_noise:
+            l = r.readline()
             self.readerr()
-            if l1 == "1\n" and l2 == "\n":
+            if lines[-1] == "1\n" and l == "\n":
                 break
-            if l1:
-                ui.debug(_("remote: "), l1)
-            l1 = l2
+            if l:
+                ui.debug(_("remote: "), l)
+            lines.append(l)
             max_noise -= 1
         else:
             if l1:
                 ui.debug(_("remote: "), l1)
             raise hg.RepoError(_("no response from remote hg"))
 
+        self.capabilities = ()
+        lines.reverse()
+        for l in lines:
+            if l.startswith("capabilities:"):
+                self.capabilities = l[:-1].split(":")[1].split()
+                break
+
     def readerr(self):
         while 1:
             size = util.fstat(self.pipee).st_size
--- a/mercurial/sshserver.py	Fri Jun 09 12:05:17 2006 -0700
+++ b/mercurial/sshserver.py	Sat Jun 10 11:28:40 2006 +0200
@@ -51,6 +51,18 @@
         h = self.repo.heads()
         self.respond(" ".join(map(hex, h)) + "\n")
 
+    def do_hello(self):
+        '''the hello command returns a set of lines describing various
+        interesting things about the server, in an RFC822-like format.
+        Currently the only one defined is "capabilities", which
+        consists of a line in the form:
+
+        capabilities: space separated list of tokens
+        '''
+
+        r = "capabilities:\n"
+        self.respond(r)
+
     def do_lock(self):
         self.lock = self.repo.lock()
         self.respond("")