about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-03-14 14:58:40 -0700
committerEric Wong <normalperson@yhbt.net>2011-03-15 01:16:52 +0000
commitb0be66c37bb7080b0f06ab76b0e7d3404e2f9059 (patch)
tree01b10dbfc1075fa5059511b451ff13a3107923c2
parent65dc45b7a13c92b27bc3589e37a3b52c29b7fbee (diff)
downloadraindrops-b0be66c37bb7080b0f06ab76b0e7d3404e2f9059.tar.gz
It is more accurate than sleep and doesn't require calculating
times
-rwxr-xr-xexamples/linux-listener-stats.rb16
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)