From 97ca6dc48e04c4e822169470dd1bd1501d037fc1 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Mon, 21 Oct 2019 13:55:43 -0400 Subject: [PATCH] Provide more detail on leader when leader is lost --- confluent_server/confluent/collective/manager.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index c1d20427..efde39ab 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -160,11 +160,11 @@ def connect_to_leader(cert=None, name=None, leader=None): raise currentleader = leader #spawn this as a thread... - follower = eventlet.spawn(follow_leader, remote, pvers) + follower = eventlet.spawn(follow_leader, remote, pvers, leader) return True -def follow_leader(remote, proto): +def follow_leader(remote, proto, leader): global currentleader cleanexit = False try: @@ -176,8 +176,8 @@ def follow_leader(remote, proto): log.log({'info': 'Previous following cleanly closed', 'subsystem': 'collective'}) return - log.log({'info': 'Current leader has disappeared, restarting ' - 'collective membership', 'subsystem': 'collective'}) + log.log({'info': 'Current leader ({0}) has disappeared, restarting ' + 'collective membership'.format(leader), 'subsystem': 'collective'}) # The leader has folded, time to startup again... cfm.stop_following() currentleader = None