openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Check open conn count before submitting new creation task

Browse Source
This commit is contained in:
Tyler Hobbs
2013-11-04 16:20:14 -06:00
parent a2ae4906a3
commit dd84464991
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cassandra/pool.py
View File

@@ -322,6 +322,8 @@ class HostConnectionPool(object):
with self._lock: with self._lock:
if self._scheduled_for_creation >= _MAX_SIMULTANEOUS_CREATION: if self._scheduled_for_creation >= _MAX_SIMULTANEOUS_CREATION:
return return
if self.open_count >= self._session.cluster.get_max_connections_per_host(self.host_distance):
return
self._scheduled_for_creation += 1 self._scheduled_for_creation += 1
log.debug("Submitting task for creation of new Connection to %s", self.host) log.debug("Submitting task for creation of new Connection to %s", self.host)