fix race connection. also close #105

make sure we are releasing the socket and eventually read the rest of
the body.

restkit/client.py

@@ -386,7 +386,7 @@ def perform(self, request):
 
             except NoMoreData, e:
                 if conn is not None:
-                    conn.close()
+                    conn.release(True)
 
                 request.maybe_rewind(msg=str(e))
                 if tries >= self.max_tries:

restkit/wrappers.py

@@ -151,6 +151,8 @@ def __init__(self, resp, connection):
         self.resp = resp
         self.body = resp._body
         self.connection = connection
+        self._closed = False
+        self.eof = False
 
     def __enter__(self):
         return self
@@ -160,7 +162,14 @@ def __exit__(self, exc_type, exc_val, traceback):
 
     def close(self):
         """ release connection """
+        if self._closed:
+            return
+
+        if not self.eof:
+            self.body.read()
+
         self.connection.release(self.resp.should_close)
+        self._closed = True
 
     def __iter__(self):
         return self
@@ -169,24 +178,28 @@ def next(self):
         try:
             return self.body.next()
         except StopIteration:
+            self.eof = True
             self.close()
             raise
 
     def read(self, n=-1):
         data = self.body.read(n)
         if not data:
+            self.eof = True
             self.close()
         return data
 
     def readline(self, limit=-1):
         line = self.body.readline(limit)
         if not line:
+            self.eof = True
             self.close()
         return line
 
     def readlines(self, hint=None):
         lines = self.body.readlines(hint)
         if self.body.close:
+            self.eof = True
             self.close()
         return lines
 

setup.py

@@ -64,8 +64,8 @@ def main():
                     'couchdb_proxy = restkit.contrib.wsgi_proxy:make_couchdb_proxy',
                 ]},
             install_requires = [
-                'http-parser>=0.7.5',
-                'socketpool>=0.4.2',
+                'http-parser>=0.7.7',
+                'socketpool>=0.5.0',
                 'nose',
                 'webob'],
             test_suite = 'nose.collector'