diff options
| author | Kotresh HR <khiremat@redhat.com> | 2017-12-07 04:46:08 -0500 |
|---|---|---|
| committer | Kotresh HR <khiremat@redhat.com> | 2017-12-11 01:48:53 -0500 |
| commit | b59e62e27cc59fa59d0f89aae2ddf115c939aa71 (patch) | |
| tree | b0050e09f2babb1fdc316a30e80c5899c1a02c41 /geo-replication | |
| parent | c7a3e0ba9fa68503917e694e2595ee4e97d4e608 (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')
| -rw-r--r-- | geo-replication/syncdaemon/master.py | 5 |
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): """ |