mirror of
https://github.com/xcat2/confluent.git
synced 2026-04-29 11:57:49 +00:00
Add an error if cfgstreams loses a follower
This commit is contained in:
@@ -462,6 +462,8 @@ def relay_slaved_requests(name, listener):
|
||||
cfgstreams[name] = listener
|
||||
msg = listener.recv(8)
|
||||
while msg:
|
||||
if name not in cfgstreams:
|
||||
raise Exception("Unexpected loss of node in followers: " + name)
|
||||
sz = struct.unpack('!Q', msg)[0]
|
||||
if sz != 0:
|
||||
rpc = ''
|
||||
|
||||
Reference in New Issue
Block a user