summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--geo-replication/syncdaemon/resource.py6
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)