Show More
@@ -75,7 +75,7 b' class HeartMonitor(LoggingConfigurable):' | |||||
75 | '(in ms)', |
|
75 | '(in ms)', | |
76 | ) |
|
76 | ) | |
77 | max_heartmonitor_misses = Integer(20, config=True, |
|
77 | max_heartmonitor_misses = Integer(20, config=True, | |
78 | help='Allow misses from engine to controller heart monitor before shutting down.', |
|
78 | help='Allow consecutive misses from engine to controller heart monitor before shutting down.', | |
79 | ) |
|
79 | ) | |
80 |
|
80 | |||
81 | pingstream=Instance('zmq.eventloop.zmqstream.ZMQStream') |
|
81 | pingstream=Instance('zmq.eventloop.zmqstream.ZMQStream') | |
@@ -144,6 +144,7 b' class HeartMonitor(LoggingConfigurable):' | |||||
144 | new_probation = {} |
|
144 | new_probation = {} | |
145 | for cur_heart in (b for b in missed_beats if b in hearts): |
|
145 | for cur_heart in (b for b in missed_beats if b in hearts): | |
146 | miss_count = on_probation.get(cur_heart, 0) + 1 |
|
146 | miss_count = on_probation.get(cur_heart, 0) + 1 | |
|
147 | self.log.info("heartbeat::missed %s : %s" % (cur_heart, miss_count)) | |||
147 | if miss_count > self.max_heartmonitor_misses: |
|
148 | if miss_count > self.max_heartmonitor_misses: | |
148 | failures.append(cur_heart) |
|
149 | failures.append(cur_heart) | |
149 | else: |
|
150 | else: |
General Comments 0
You need to be logged in to leave comments.
Login now