Mercurial > public > mercurial-scm > hg-stable

comparison mercurial/sshserver.py @ 11621:e46a8b2331a6

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
protocol: shuffle server methods to group send methods
author Dirkjan Ochtman <dirkjan@ochtman.nl>
date Fri, 16 Jul 2010 18:16:15 +0200
parents 83070a9cd526
children 1d48681b17a4
comparison
equal deleted inserted replaced
11620:86b49e0083a7 11621:e46a8b2331a6
47 return [data[k] for k in keys] 47 return [data[k] for k in keys]
48 48
49 def getarg(self, name): 49 def getarg(self, name):
50 return self.getargs(name)[0] 50 return self.getargs(name)[0]
51 51
52 def getfile(self, fpout):
53 self.respond('')
54 count = int(self.fin.readline())
55 while count:
56 fpout.write(self.fin.read(count))
57 count = int(self.fin.readline())
58
59 def redirect(self):
60 pass
61
52 def respond(self, v): 62 def respond(self, v):
53 self.fout.write("%d\n" % len(v)) 63 self.fout.write("%d\n" % len(v))
54 self.fout.write(v) 64 self.fout.write(v)
55 self.fout.flush() 65 self.fout.flush()
56 66
65 75
66 def sendstream(self, source): 76 def sendstream(self, source):
67 for chunk in source: 77 for chunk in source:
68 self.fout.write(chunk) 78 self.fout.write(chunk)
69 self.fout.flush() 79 self.fout.flush()
70
71 def getfile(self, fpout):
72 self.respond('')
73 count = int(self.fin.readline())
74 while count:
75 fpout.write(self.fin.read(count))
76 count = int(self.fin.readline())
77
78 def redirect(self):
79 pass
80 80
81 def respondpush(self, ret): 81 def respondpush(self, ret):
82 self.respond('') 82 self.respond('')
83 self.respond(str(ret)) 83 self.respond(str(ret))
84 84