From c1113430a2632725017759531bb6ce4fa103a815 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 30 Sep 2021 08:11:19 -0400 Subject: [PATCH] Pass only the name rather than full sockaddr on retire Followers of a server that is retiring to join the better leader were being given incorrect format which would fail in the dns lookup. --- confluent_server/confluent/collective/manager.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index abb4fc64..7e597176 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -478,10 +478,10 @@ def handle_connection(connection, cert, request, local=False): return log.log({'info': 'Connecting in response to assimilation', 'subsystem': 'collective'}) - if cfm.cfgstreams: - retire_as_leader(connection.getpeername()) - tlvdata.send(connection, {'status': 0}) newleader = connection.getpeername()[0] + if cfm.cfgstreams: + retire_as_leader(newleader) + tlvdata.send(connection, {'status': 0}) connection.close() if not connect_to_leader(None, None, leader=newleader): if retrythread is None: