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

Add more collective event log handling

Browse Source 
More detail to analyze how the collective membership is handled.
This commit is contained in:
Jarrod Johnson 2018-09-27 15:14:45 -04:00
parent 10ce7a9de9
commit e57cdf9a7b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,6 +60,7 @@ def connect_to_leader(cert=None, name=None, leader=None):
cfginitlock = threading.RLock()
if leader is None:
leader = currentleader
log.log({'info': 'Attempting connection to leader {0}'.format(leader)})
try:
remote = connect_to_collective(cert, leader)
except socket.error as e:
@ -104,7 +105,6 @@ def connect_to_leader(cert=None, name=None, leader=None):
return become_leader(remote)
print(keydata['error'])
return False
if follower is not None:
follower.kill()
cfm.stop_following()
follower = None
@ -485,6 +485,7 @@ def retire_as_leader():
def become_leader(connection):
global currentleader
global follower
log.log({'info': 'Becoming leader of collective'})
if follower:
follower.kill()
follower = None