Skip to content
This repository has been archived by the owner on Aug 4, 2020. It is now read-only.

Commit

Permalink
Make sure connection count is decremented as we are disposing connect…
Browse files Browse the repository at this point in the history
…ions from pool.

Remove unused var.
  • Loading branch information
edevil committed Aug 2, 2013
1 parent d5b666b commit 33d64b4
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pycassa/pool.py
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -585,10 +585,10 @@ def dispose(self):
conn = self._q.get(False) conn = self._q.get(False)
conn._dispose_wrapper( conn._dispose_wrapper(
reason="Pool %s is being disposed" % id(self)) reason="Pool %s is being disposed" % id(self))
self._decrement_overflow()
except Queue.Empty: except Queue.Empty:
break break


self._overflow = 0 - self.size()
self._notify_on_pool_dispose() self._notify_on_pool_dispose()


def size(self): def size(self):
Expand Down

0 comments on commit 33d64b4

Please sign in to comment.