diff options
| author | Csaba Henk <csaba@gluster.com> | 2011-04-29 06:24:45 +0000 |
|---|---|---|
| committer | Anand Avati <avati@gluster.com> | 2011-05-09 13:27:03 -0700 |
| commit | 6f2ed82bfcfe494ef273bff55cf69480a7472cc5 (patch) | |
| tree | e911f81c9bcc82628b3dc3e651616349dbc0f6b3 /xlators/features/marker/utils/syncdaemon/gsyncd.py | |
| parent | 9ffd9c51f3833e04a60373648ba3c69c2ed7a68a (diff) | |
syncdaemon: some refactor on monitor
- detect faulty state early
- keep the feedback fd in gsyncd module
Signed-off-by: Csaba Henk <csaba@gluster.com>
Signed-off-by: Anand Avati <avati@gluster.com>
BUG: 2537 (gsync autorestart)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=2537
Diffstat (limited to 'xlators/features/marker/utils/syncdaemon/gsyncd.py')
| -rw-r--r-- | xlators/features/marker/utils/syncdaemon/gsyncd.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/xlators/features/marker/utils/syncdaemon/gsyncd.py b/xlators/features/marker/utils/syncdaemon/gsyncd.py index 963e7101b..a502c2009 100644 --- a/xlators/features/marker/utils/syncdaemon/gsyncd.py +++ b/xlators/features/marker/utils/syncdaemon/gsyncd.py @@ -252,8 +252,7 @@ def main_i(): ffd = rconf.get('feedback_fd') if ffd: - gconf.feedback_fd = ffd - fcntl.fcntl(int(ffd), fcntl.F_SETFD, fcntl.FD_CLOEXEC) + fcntl.fcntl(ffd, fcntl.F_SETFD, fcntl.FD_CLOEXEC) #normalize loglevel lvl0 = gconf.log_level @@ -295,6 +294,8 @@ def main_i(): # complete remote connection in child remote.connect_remote(go_daemon='done') local.connect() + if ffd: + os.close(ffd) local.service_loop(*[r for r in [remote] if r]) logging.info("exiting.") |