xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 17:43:14 +00:00
Code Issues Projects Releases Wiki Activity

Recognize loss of follower as step toward loss of quorum

Browse Source 
Properly reap the loss of a follower.
This commit is contained in:
Jarrod Johnson 2018-06-22 16:17:48 -04:00
parent 5a5f0169a7
commit bf4f5ad5ae
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/config/configmanager.py
View File

@ -449,6 +449,7 @@ def set_global(globalname, value):
cfgstreams = {}
def relay_slaved_requests(name, listener):
global cfgleader
cfgstreams[name] = listener
msg = listener.recv(8)
while msg:
@ -465,6 +466,9 @@ def relay_slaved_requests(name, listener):
if 'xid' in rpc:
_push_rpc(listener, cPickle.dumps({'xid': rpc['xid']}))
msg = listener.recv(8)
del cfgstreams[name]
if not cfgstreams:
cfgleader = True
def stop_leading():