diff options
| -rw-r--r-- | geo-replication/syncdaemon/resource.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/geo-replication/syncdaemon/resource.py b/geo-replication/syncdaemon/resource.py index 8deb5114b50..810c2a81d85 100644 --- a/geo-replication/syncdaemon/resource.py +++ b/geo-replication/syncdaemon/resource.py @@ -779,7 +779,11 @@ class SlaveRemote(object): p0.stdin.write(f) p0.stdin.write('\n') p0.stdin.close() + + # wait() for tar to terminate, collecting any errors, further + # waiting for transfer to complete p0.wait() + p0.terminate_geterr(fail_on_err = False) p1.wait() p1.terminate_geterr(fail_on_err = False) |