mirror of
https://github.com/xcat2/confluent.git
synced 2025-02-12 08:40:24 +00:00
Fix greenlet 'isAlive'
There is no 'isAlive' in a greenlet.
This commit is contained in:
parent
606a308046
commit
fc626d36ba
@ -403,7 +403,7 @@ def handle_connection(connection, cert, request, local=False):
|
||||
connection.close()
|
||||
return
|
||||
if (currentleader == connection.getpeername()[0] and
|
||||
follower and follower.isAlive()):
|
||||
follower and not follower.dead:
|
||||
# if we are happily following this leader already, don't stir
|
||||
# the pot
|
||||
tlvdata.send(connection, {'status': 0})
|
||||
|
@ -2338,7 +2338,7 @@ class ConfigManager(object):
|
||||
return
|
||||
with cls._syncstate:
|
||||
if (cls._syncrunning and cls._cfgwriter is not None and
|
||||
cls._cfgwriter.isAlive()):
|
||||
not cls._cfgwriter.dead):
|
||||
cls._writepending = True
|
||||
return
|
||||
if cls._syncrunning: # This suggests an unclean write attempt,
|
||||
|
Loading…
x
Reference in New Issue
Block a user