xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-16 04:39:16 +00:00
Code Issues Projects Releases Wiki Activity

Add missing subsystem marker from a collective log

Browse Source
This commit is contained in:
Jarrod Johnson 2018-10-10 16:30:28 -04:00
parent 2d0199a4e9
commit be930fc076
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -101,7 +101,7 @@ def connect_to_leader(cert=None, name=None, leader=None):
log.log({'info':
'Prospective leader {0} has inferior '
'transaction count, becoming leader'
''.format(leader)})
''.format(leader), 'subsystem': 'collective'})
return become_leader(remote)
print(keydata['error'])
return False
@ -360,7 +360,7 @@ def handle_connection(connection, cert, request, local=False):
tlvdata.send(connection,
{'error': 'Refusing to be assimilated by inferior'
'transaction count',
'txcount': cfm._txcount})
'txcount': cfm._txcount,})
return
eventlet.spawn_n(connect_to_leader, None, None,
leader=connection.getpeername()[0])