Mercurial > public > mercurial-scm > hg-stable
diff mercurial/sshserver.py @ 11623:31d0a6d50ee2
protocol: extract compression from streaming mechanics
author | Dirkjan Ochtman <dirkjan@ochtman.nl> |
---|---|
date | Fri, 16 Jul 2010 22:20:10 +0200 |
parents | 1d48681b17a4 |
children | cdeb861335d5 |
line wrap: on
line diff
--- a/mercurial/sshserver.py Fri Jul 16 18:18:35 2010 +0200 +++ b/mercurial/sshserver.py Fri Jul 16 22:20:10 2010 +0200 @@ -59,18 +59,16 @@ def redirect(self): pass - def sendresponse(self, v): - self.fout.write("%d\n" % len(v)) - self.fout.write(v) - self.fout.flush() - - def sendchangegroup(self, changegroup): + def groupchunks(self, changegroup): while True: d = changegroup.read(4096) if not d: break - self.fout.write(d) + yield d + def sendresponse(self, v): + self.fout.write("%d\n" % len(v)) + self.fout.write(v) self.fout.flush() def sendstream(self, source):