diff options
| -rw-r--r-- | geo-replication/syncdaemon/resource.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/geo-replication/syncdaemon/resource.py b/geo-replication/syncdaemon/resource.py index d372203a7ea..6d26a56a7bf 100644 --- a/geo-replication/syncdaemon/resource.py +++ b/geo-replication/syncdaemon/resource.py @@ -1065,6 +1065,12 @@ class SlaveRemote(object): # waiting for transfer to complete _, stderr1 = p1.communicate() + # stdin and stdout of p0 is already closed, Reset to None and + # wait for child process to complete + p0.stdin = None + p0.stdout = None + p0.communicate() + if log_err: for errline in stderr1.strip().split("\n")[:-1]: logging.error("SYNC Error(Untar): %s" % errline) |