diff options
author | Eric Wong <normalperson@yhbt.net> | 2011-03-14 14:58:40 -0700 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2011-03-15 01:16:52 +0000 |
commit | b0be66c37bb7080b0f06ab76b0e7d3404e2f9059 (patch) | |
tree | 01b10dbfc1075fa5059511b451ff13a3107923c2 | |
parent | 65dc45b7a13c92b27bc3589e37a3b52c29b7fbee (diff) | |
download | raindrops-b0be66c37bb7080b0f06ab76b0e7d3404e2f9059.tar.gz |
It is more accurate than sleep and doesn't require calculating times
-rwxr-xr-x | examples/linux-listener-stats.rb | 16 |
1 files changed, 15 insertions, 1 deletions
diff --git a/examples/linux-listener-stats.rb b/examples/linux-listener-stats.rb index 3494dff..ed58d27 100755 --- a/examples/linux-listener-stats.rb +++ b/examples/linux-listener-stats.rb @@ -8,6 +8,10 @@ require 'raindrops' require 'optparse' require 'ipaddr' require 'time' +begin + require 'sleepy_penguin' +rescue LoadError +end usage = "Usage: #$0 [-d DELAY] [-t QUEUED_THRESHOLD] ADDR..." ARGV.size > 0 or abort usage delay = false @@ -31,6 +35,16 @@ rescue LoadError $stderr.puts "Aggregate missing, USR1 and USR2 handlers unavailable" end if delay +if delay && defined?(SleepyPenguin::TimerFD) + @tfd = SleepyPenguin::TimerFD.new + @tfd.settime nil, delay, delay + def delay_for(seconds) + @tfd.expirations + end +else + alias delay_for sleep +end + agg_active = agg_queued = nil if delay && defined?(Aggregate) agg_active = Aggregate.new @@ -109,4 +123,4 @@ begin next if queued < queued_thresh printf fmt, now ||= Time.now.utc.iso8601, addr, active, queued end -end while delay && sleep(delay) +end while delay && delay_for(delay) |