2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-29 21:09:32 +00:00

Force fullsync if dead sync thread likely

If the sync thread died previously, force the next sync to be full.
This commit is contained in:
Jarrod Johnson 2018-10-10 14:32:13 -04:00
parent 32ddb33de3
commit 3b2b96a4cf

View File

@ -2065,6 +2065,9 @@ class ConfigManager(object):
cls._cfgwriter.isAlive()):
cls._writepending = True
return
if cls._syncrunning: # This suggests an unclean write attempt,
# do a fullsync as a recovery
fullsync = True
cls._syncrunning = True
# if the thread is exiting, join it to let it close, just in case
if cls._cfgwriter is not None: