Close conns in trash on shutdown

2014-01-09 10:52:48 -06:00
parent e0b5e6522a
commit cea2d5b5e9
1 changed files with 3 additions and 0 deletions
--- a/cassandra/pool.py
+++ b/cassandra/pool.py
@@ -509,6 +509,9 @@ class HostConnectionPool(object):
            conn.close()
            self.open_count -= 1

+        for conn in self._trash:
+            conn.close()
+
    def ensure_core_connections(self):
        if self.is_shutdown:
            return