From b59e62e27cc59fa59d0f89aae2ddf115c939aa71 Mon Sep 17 00:00:00 2001 From: Kotresh HR Date: Thu, 7 Dec 2017 04:46:08 -0500 Subject: geo-rep: Cleanup stale unprocessed xsync changelogs Fixes: #376 Change-Id: Ib92920c716c7d27e1eeb4bc4ebaf3efb48e0694d Signed-off-by: Kotresh HR --- geo-replication/syncdaemon/master.py | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'geo-replication') diff --git a/geo-replication/syncdaemon/master.py b/geo-replication/syncdaemon/master.py index 552c4deec44..89e57b42a37 100644 --- a/geo-replication/syncdaemon/master.py +++ b/geo-replication/syncdaemon/master.py @@ -1543,6 +1543,11 @@ class GMasterXsyncMixin(GMasterChangelogMixin): pass else: raise + # Purge stale unprocessed xsync changelogs + for f in os.listdir(self.tempdir): + if f.startswith("XSYNC-CHANGELOG"): + os.remove(os.path.join(self.tempdir, f)) + def crawl(self): """ -- cgit