Previously .walshipping.last was updated before the rsync succeeded,
it turns out that this was too optimistic -- occasionally the rsync
fails and the .last file contains wrong information. This results
in skipped files during "master sync".
self.log.debug("%s: start copy", srcname)
self.master_periodic()
- self.set_last_complete(srcname)
dst_loc = self.cf.getfile("completed_wals")
if dst_loc[-1] != "/":
cmdline = ["ssh", "-nT", slave, "sync" ]
self.exec_cmd(cmdline)
+ # slave has the file now, set markers
+ self.set_last_complete(srcname)
+
self.log.debug("%s: done", srcname)
end_time = time.time()
self.stat_add('count', 1)