mercurial/hgweb/protocol.py
changeset 11621 e46a8b2331a6
parent 11618 83070a9cd526
child 11622 1d48681b17a4
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)