lib/ring/sqa/poller/sender.rb in ring-sqa-0.1.2 vs lib/ring/sqa/poller/sender.rb in ring-sqa-0.1.3
- old
+ new
@@ -12,10 +12,12 @@
@nodes.all.each do |node, _|
query node, udp
sleep INTER_NODE_GAP
end
duration = Time.now-loop_start
- if duration < INTERVAL
+ if duration < 0
+ Log.warn "Send loop duration was negative - ntp sync?"
+ elsif duration < INTERVAL
sleep INTERVAL-duration
else
Log.warn "Send loop took longer than #{INTERVAL}s"
end
end