Master xarchive now runs "sync" on slave.

This is an attempt at minimizing the chance of WAL file corruption
on slave server crash -- master xarchive command does not return
success until the the buffers on slave have been flushed to disk.

1 files changed, 6 insertions, 0 deletions

diff --git a/python/walmgr.py b/python/walmgr.py
index 7afc3c73..d4796401 100755
--- a/python/walmgr.py
+++ b/python/walmgr.py
@@ -1358,6 +1358,12 @@ STOP TIME: %(stop_time)s
         # copy data
         self.exec_rsync([ srcpath, dst_loc ], True)
 
+        # sync the buffers to disk - this is should reduce the chance
+        # of WAL file corruption in case the slave crashes.
+        slave = self.cf.get("slave")
+        cmdline = ["ssh", "-nT", slave, "sync" ]
+        self.exec_cmd(cmdline)
+
         self.log.debug("%s: done", srcname)
         end_time = time.time()
         self.stat_add('count', 1)