From 3b2b96a4cf298eb331cb44a1452bbb20f7eae495 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 10 Oct 2018 14:32:13 -0400 Subject: [PATCH] Force fullsync if dead sync thread likely If the sync thread died previously, force the next sync to be full. --- confluent_server/confluent/config/configmanager.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index 0ca84ab4..afd45983 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -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: