2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-26 19:40:12 +00:00

Add self to collective database

Database would omit initial leader otherwise.
This commit is contained in:
Jarrod Johnson 2018-05-03 13:27:48 -04:00
parent a4d80e4e3a
commit b733049a0c

View File

@ -116,6 +116,9 @@ def handle_connection(connection, cert, request, local=False):
return
myrsp = base64.b64encode(myrsp)
fprint = util.get_fingerprint(cert)
myfprint = util.get_fingerprint(mycert)
cfm.add_collective_member(socket.gethostname(),
connection.getsockname()[0], myfprint)
cfm.add_collective_member(request['name'],
connection.getpeername()[0], fprint)
tlvdata.send(connection,