summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorCsaba Henk <csaba@gluster.com>2011-07-12 22:18:58 +0200
committerAnand Avati <avati@gluster.com>2011-07-28 03:01:20 -0700
commit2a6de14e22445fc3017c9aa25b9c56bc4259d373 (patch)
tree096de9082c6c10901259196eb9684a52e57dd939
parentcf4501899ca75a6641a31cf7116d439dfb6dd4de (diff)
gsyncd: exit in slave when RePCe session came to an end
Change-Id: I4317e60fce3280c45dbcc4a5f233a4344aba9500 BUG: 2778 Reviewed-on: http://review.gluster.com/83 Tested-by: Gluster Build System <jenkins@build.gluster.com> Reviewed-by: Anand Avati <avati@gluster.com>
-rw-r--r--xlators/features/marker/utils/syncdaemon/resource.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/xlators/features/marker/utils/syncdaemon/resource.py b/xlators/features/marker/utils/syncdaemon/resource.py
index 1e1364c2671..09839f09ea6 100644
--- a/xlators/features/marker/utils/syncdaemon/resource.py
+++ b/xlators/features/marker/utils/syncdaemon/resource.py
@@ -195,7 +195,8 @@ class SlaveLocal(object):
def service_loop(self):
repce = RepceServer(self.server, sys.stdin, sys.stdout, int(gconf.sync_jobs))
- t = syncdutils.Thread(target=repce.service_loop)
+ t = syncdutils.Thread(target=lambda: (repce.service_loop(),
+ syncdutils.finalize()))
t.start()
logging.info("slave listening")
if gconf.timeout and int(gconf.timeout) > 0: