diff options
Diffstat (limited to 'src/server/rz_kernel.py')
| -rw-r--r-- | src/server/rz_kernel.py | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/server/rz_kernel.py b/src/server/rz_kernel.py index 6069e688..628fdd02 100644 --- a/src/server/rz_kernel.py +++ b/src/server/rz_kernel.py @@ -100,17 +100,15 @@ class RZ_Kernel(object): Handle periodic server tasks: - manage rzdoc subscriber lists """ - while True: + while False == self.should_stop: + for rzdoc, r_assoc_set in self.rzdoc_reader_assoc_map.items(): for r_assoc in r_assoc_set: if r_assoc.err_count__IO > 3: r_assoc_set.remove(r_assoc) log.info('rz_kernel: evicting reader: IO error count exceeded limit: remote-addr: %s, rzdoc: %s' % (r_assoc.remote_socket_addr, rzdoc.name)) - for i in xrange(self.heartbeat_period_sec * 2): - if False == self.should_stop: - return; - time.sleep(0.5) + time.sleep(self.heartbeat_period_sec) self.executor = ThreadPoolExecutor(max_workers=8) self.executor.submit(kernel_heartbeat) |