Semaphore management during connection failure. PYTHON-580

2013-10-07 15:26:54 -04:00 · 2013-10-07 15:26:54 -04:00 · cd4b609b7c
commit cd4b609b7c
parent 7d8f4cbb7d
1 changed files with 2 additions and 1 deletions
--- a/pymongo/pool.py
+++ b/pymongo/pool.py
@ -349,7 +349,8 @@ class Pool:
                # request until end_request.
                self._set_request_state(sock_info)
        except:
-            self._socket_semaphore.release()
+            if not forced:
+                self._socket_semaphore.release()
            raise

        sock_info.last_checkout = time.time()