##// END OF EJS Templates
Improve documentation of default to indicate consecutive and supply logging of misses
chapmanb -
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