fix request body handling - fixes #3301

Author: oallenj

gunicorn/http/parser.py

@@ -25,17 +25,19 @@ def __init__(self, cfg, source, source_addr):
     def __iter__(self):
         return self
 
-    def __next__(self):
-        # Stop if HTTP dictates a stop.
-        if self.mesg and self.mesg.should_close():
-            raise StopIteration()
-
+    def finish_body(self):
         # Discard any unread body of the previous message
         if self.mesg:
             data = self.mesg.body.read(8192)
             while data:
                 data = self.mesg.body.read(8192)
 
+    def __next__(self):
+        # Stop if HTTP dictates a stop.
+        if self.mesg and self.mesg.should_close():
+            raise StopIteration()
+        self.finish_body()
+
         # Parse the next request
         self.req_count += 1
         self.mesg = self.mesg_class(self.cfg, self.unreader, self.source_addr, self.req_count)

gunicorn/workers/gthread.py

@@ -280,6 +280,7 @@ def handle(self, conn):
             # handle the request
             keepalive = self.handle_request(req, conn)
             if keepalive:
+                conn.parser.finish_body()
                 return (keepalive, conn)
         except http.errors.NoMoreData as e:
             self.log.debug("Ignored premature client disconnection. %s", e)