lib/ring/sqa/analyzer.rb in ring-sqa-0.1.0 vs lib/ring/sqa/analyzer.rb in ring-sqa-0.1.1
- old
+ new
@@ -13,10 +13,10 @@
@db.purge
@db_id_seen, records = @db.nodes_down(@db_id_seen+1)
sleep INFLIGHT_WAIT
records = records.all
@buffer.push records.map { |record| record.peer }
- @buffer.exceed_median? ? @alarm.set(@buffer) : @alarm.clear
+ @buffer.exceed_median? ? @alarm.set(@buffer) : @alarm.clear(@buffer)
delay = INTERVAL-(Time.now-start)
if delay > 0
sleep delay
else
Log.error "Analyzer loop took longer than #{INTERVAL}, wanted to sleep for #{delay}s"