jingrow/gunicorn
1
0
Fork 0
mirror of https://github.com/frappe/gunicorn.git synced 2026-01-14 11:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

make sure we write at the end. fix 002-test-request.test_011 . spotted

Browse Source 
by jbergstroem on irc. thanks!
This commit is contained in:
benoitc 2010-02-27 18:01:05 +01:00
parent 49d340ce2b
commit 87d3c4b3e7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
gunicorn/http/tee.py
View File

@ -44,6 +44,7 @@ class TeeInput(object):
if self._is_socket: if self._is_socket:
pos = self.tmp.tell() pos = self.tmp.tell()
while True: while True:
self.tmp.seek(self._tmp_size())
if not self._tee(CHUNK_SIZE): if not self._tee(CHUNK_SIZE):
break break
self.tmp.seek(pos) self.tmp.seek(pos)
@ -54,6 +55,7 @@ class TeeInput(object):
if self._is_socket: if self._is_socket:
pos = self.tmp.tell() pos = self.tmp.tell()
while True: while True:
self.tmp.seek(self._tmp_size())
if not self._tee(CHUNK_SIZE): if not self._tee(CHUNK_SIZE):
break break
self.tmp.seek(pos) self.tmp.seek(pos)
@ -137,6 +139,9 @@ class TeeInput(object):
if chunk: if chunk:
self.tmp.write(chunk) self.tmp.write(chunk)
self.tmp.seek(0, os.SEEK_END) self.tmp.seek(0, os.SEEK_END)
self.tmp.flush()
if hasattr(self.tmp, 'fileno'):
os.fsync(self.tmp.fileno())
return chunk return chunk
if self.parser.body_eof(): if self.parser.body_eof():