summaryrefslogtreecommitdiffstats
path: root/geo-replication/syncdaemon/master.py
diff options
context:
space:
mode:
authorKotresh HR <khiremat@redhat.com>2017-12-07 04:46:08 -0500
committerKotresh HR <khiremat@redhat.com>2017-12-11 01:48:53 -0500
commitb59e62e27cc59fa59d0f89aae2ddf115c939aa71 (patch)
treeb0050e09f2babb1fdc316a30e80c5899c1a02c41 /geo-replication/syncdaemon/master.py
parentc7a3e0ba9fa68503917e694e2595ee4e97d4e608 (diff)
geo-rep: Cleanup stale unprocessed xsync changelogs
Fixes: #376 Change-Id: Ib92920c716c7d27e1eeb4bc4ebaf3efb48e0694d Signed-off-by: Kotresh HR <khiremat@redhat.com>
Diffstat (limited to 'geo-replication/syncdaemon/master.py')
-rw-r--r--geo-replication/syncdaemon/master.py5
1 files changed, 5 insertions, 0 deletions
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):
"""