Mercurial > public > mercurial-scm > hg-stable

comparison mercurial/hgweb/protocol.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
26 star[key] = self.req.form[key][0] 26 star[key] = self.req.form[key][0]
27 data['*'] = star 27 data['*'] = star
28 else: 28 else:
29 data[k] = self.req.form[k][0] 29 data[k] = self.req.form[k][0]
30 return [data[k] for k in keys] 30 return [data[k] for k in keys]
31 def getfile(self, fp):
32 length = int(self.req.env['CONTENT_LENGTH'])
33 for s in util.filechunkiter(self.req, limit=length):
34 fp.write(s)
35 def redirect(self):
36 self.oldio = sys.stdout, sys.stderr
37 sys.stderr = sys.stdout = cStringIO.StringIO()
38 def respond(self, s):
39 self.req.respond(HTTP_OK, HGTYPE, length=len(s))
40 self.response = s
31 def sendchangegroup(self, cg): 41 def sendchangegroup(self, cg):
32 self.req.respond(HTTP_OK, HGTYPE) 42 self.req.respond(HTTP_OK, HGTYPE)
33 z = zlib.compressobj() 43 z = zlib.compressobj()
34 while 1: 44 while 1:
35 chunk = cg.read(4096) 45 chunk = cg.read(4096)
39 self.req.write(z.flush()) 49 self.req.write(z.flush())
40 def sendstream(self, source): 50 def sendstream(self, source):
41 self.req.respond(HTTP_OK, HGTYPE) 51 self.req.respond(HTTP_OK, HGTYPE)
42 for chunk in source: 52 for chunk in source:
43 self.req.write(chunk) 53 self.req.write(chunk)
44 def respond(self, s):
45 self.req.respond(HTTP_OK, HGTYPE, length=len(s))
46 self.response = s
47 def getfile(self, fp):
48 length = int(self.req.env['CONTENT_LENGTH'])
49 for s in util.filechunkiter(self.req, limit=length):
50 fp.write(s)
51 def redirect(self):
52 self.oldio = sys.stdout, sys.stderr
53 sys.stderr = sys.stdout = cStringIO.StringIO()
54 def respondpush(self, ret): 54 def respondpush(self, ret):
55 val = sys.stdout.getvalue() 55 val = sys.stdout.getvalue()
56 sys.stdout, sys.stderr = self.oldio 56 sys.stdout, sys.stderr = self.oldio
57 self.req.respond(HTTP_OK, HGTYPE) 57 self.req.respond(HTTP_OK, HGTYPE)
58 self.response = '%d\n%s' % (ret, val) 58 self.response = '%d\n%s' % (ret, val)