xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-09 21:15:53 +00:00
Code Issues Projects Releases Wiki Activity

Fix HA healing problems

Browse Source 
If we are superior to leader, become leader
When abandoned by a leader, forget the leader.
This commit is contained in:
Jarrod Johnson 2018-06-28 13:51:52 -04:00
parent 5d894912ac
commit f01c7e19f7
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
confluent_server/confluent/collective/manager.py
View File

@ -62,6 +62,8 @@ def connect_to_leader(cert=None, name=None, leader=None):
if ldrc and ldrc['name'] == name:
raise Exception("Redirected to self")
return connect_to_leader(name=name, leader=keydata['leader'])
if 'txcount' in keydata:
return become_leader(remote)
raise Exception(keydata['error'])
if follower is not None:
follower.kill()
@ -94,9 +96,11 @@ def connect_to_leader(cert=None, name=None, leader=None):
def follow_leader(remote):
global currentleader
cfm.follow_channel(remote)
# The leader has folded, time to startup again...
remote.close()
currentleader = None
eventlet.spawn_n(start_collective)