+
+ if respheaders.has_key('content-length'):
+ max_chunk_size = 10*1024*1024
+ size_remaining = int(respheaders["content-length"])
+ while size_remaining:
+ chunk_size = min(size_remaining, max_chunk_size)
+ data = (yield p.ss.read(chunk_size))
+ print "reading from proxy expecting", size_remaining, repr(data)
+ yield self.client.writeMessage(data)
+ size_remaining -= len(data)
+ else:
+ while True:
+ #data = p.read()
+ try:
+ data = (yield p.ss.read(1024))
+ except httpd.ConnectionClosed:
+ break
+ print "reading from proxy", repr(data)
+ if data == '':
+ break
+ yield self.client.writeMessage(data)
+
+