mirror of
https://github.com/xcat2/confluent.git
synced 2026-03-03 20:39:17 +00:00
Only zap cfgleader if not set
stale relay_slaved_requests was trouncing following status, correct by avoiding zapping that state
This commit is contained in:
@@ -479,7 +479,7 @@ def relay_slaved_requests(name, listener):
|
||||
msg = listener.recv(8)
|
||||
listener.close()
|
||||
del cfgstreams[name]
|
||||
if not cfgstreams:
|
||||
if not cfgstreams and not cfgleader:
|
||||
cfgleader = True
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user