Semaphore management during connection failure. PYTHON-580

2013-10-07 15:26:54 -04:00 · 2013-10-07 15:26:54 -04:00 · bddee65ed8
commit bddee65ed8
parent 3db63c45a6
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()