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

Wait an extra second before handling UP messages

Browse Source
This commit is contained in:
Tyler Hobbs
2014-04-22 16:53:59 -05:00
parent 469dd674f3
commit d20db205f1
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cassandra/cluster.py
View File

@@ -1659,10 +1659,10 @@ class ControlConnection(object):
if change_type == "UP": if change_type == "UP":
if host is None: if host is None:
# this is the first time we've seen the node # this is the first time we've seen the node
self._cluster.scheduler.schedule(1, self.refresh_node_list_and_token_map) self._cluster.scheduler.schedule(2, self.refresh_node_list_and_token_map)
else: else:
# this will be run by the scheduler # this will be run by the scheduler
self._cluster.scheduler.schedule(1, self._cluster.on_up, host) self._cluster.scheduler.schedule(2, self._cluster.on_up, host)
elif change_type == "DOWN": elif change_type == "DOWN":
# Note that there is a slight risk we can receive the event late and thus # Note that there is a slight risk we can receive the event late and thus
# mark the host down even though we already had reconnected successfully. # mark the host down even though we already had reconnected successfully.