2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-01-12 02:52:30 +00:00

Ensure that wait_for_sync always does a new sync

If a sync is in progress, wait for that to complete.

Then issue the requested *new* sync.

Probably only needed if fullsync, as the one in progress may be a
'dirty' only sync and fullsync would be satisfied by the partial sync
without it, which is bad.
This commit is contained in:
Jarrod Johnson
2018-07-13 22:15:38 -04:00
parent 1dad69097b
commit 0016077bee

View File

@@ -1906,6 +1906,8 @@ class ConfigManager(object):
@classmethod
def wait_for_sync(cls, fullsync=False):
if cls._cfgwriter is not None:
cls._cfgwriter.join()
cls._bg_sync_to_file(fullsync)
if cls._cfgwriter is not None:
cls._cfgwriter.join()