xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-25 19:10:10 +00:00
Code Issues Projects Releases Wiki Activity

Have collective start bail out if leader

Browse Source 
Leader should not relinquish if quorum, so don't bother in such
a case.
This commit is contained in:
Jarrod Johnson 2018-10-01 15:50:31 -04:00
parent b0b5493ff7
commit 4329c1d388
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -535,6 +535,12 @@ def start_collective():
if follower:
follower.kill()
follower = None
try:
if cfm.cfgstreams and cfm.check_quorum():
# Do not start if we have quorum and are leader
return
except exc.DegradedCollective:
pass
if leader_init.active: # do not start trying to connect if we are
# xmitting data to a follower
return