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

Update _connection_factory attr name in pool

Browse Source
This commit is contained in:
Tyler Hobbs
2013-05-20 17:40:07 -05:00
parent de718b3fe4
commit 8f96a88920
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cassandra/pool.py
View File

@@ -234,7 +234,7 @@ class HostConnectionPool(object):
self._conn_available_condition = Condition() self._conn_available_condition = Condition()
core_conns = session.cluster.get_core_connections_per_host(host_distance) core_conns = session.cluster.get_core_connections_per_host(host_distance)
self._connections = [session.cluster.connection_factory(host.address) self._connections = [session.cluster._connection_factory(host.address)
for i in range(core_conns)] for i in range(core_conns)]
self._trash = set() self._trash = set()
self.open_count = core_conns self.open_count = core_conns
@@ -328,7 +328,7 @@ class HostConnectionPool(object):
self.open_count += 1 self.open_count += 1
try: try:
conn = self._session.cluster.connection_factory(self.host) conn = self._session.cluster._connection_factory(self.host)
with self._lock: with self._lock:
self._connections.append(conn) self._connections.append(conn)
self._signal_available_conn() self._signal_available_conn()