diff options
| author | Csaba Henk <csaba@gluster.com> | 2011-07-12 22:18:58 +0200 |
|---|---|---|
| committer | Anand Avati <avati@gluster.com> | 2011-07-28 03:01:20 -0700 |
| commit | 2a6de14e22445fc3017c9aa25b9c56bc4259d373 (patch) | |
| tree | 096de9082c6c10901259196eb9684a52e57dd939 | |
| parent | cf4501899ca75a6641a31cf7116d439dfb6dd4de (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.py | 3 |
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 1e1364c26..09839f09e 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: |