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

Have leader provide more data in collective show

Browse Source
This commit is contained in:
Jarrod Johnson 2018-07-19 16:26:05 -04:00
parent f2f902de7b
commit 54d93571d1
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -191,12 +191,21 @@ def handle_connection(connection, cert, request, local=False):
{'collective':
{'error': 'Collective does not have quorum'}})
return
collinfo = {}
if follower:
myleader = cfm.get_collective_member_by_address(
collinfo['leader'] = cfm.get_collective_member_by_address(
currentleader)['name']
else:
myleader = get_myname()
tlvdata.send(connection, {'collective': {'leader': myleader}})
iam = get_myname()
collinfo['leader'] = iam
collinfo['active'] = list(cfm.cfgstreams)
activemembers = set(cfm.cfgstreams)
activemembers.add(iam)
collinfo['offline'] = []
for member in cfm.list_collective():
if member not in activemembers:
collinfo['offline'].append(member)
tlvdata.send(connection, {'collective': collinfo})
return
if 'invite' == operation:
try: