diff options
| -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 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: |