about summary refs log tree commit homepage
path: root/lib
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-05-08 01:28:43 +0000
committerEric Wong <normalperson@yhbt.net>2011-05-08 01:28:43 +0000
commit497ce74310baaa7ac4835b8d6aa76acb40d44b7c (patch)
tree12755ba1e45fa56227e9d30a96d124ccc7880dcd /lib
parentef9376775b1a6eeae8807160b2b8ea23fbfd3607 (diff)
downloadrainbows-497ce74310baaa7ac4835b8d6aa76acb40d44b7c.tar.gz
shorter line and 3 lines of code killed!
Diffstat (limited to 'lib')
-rw-r--r--lib/rainbows/xepoll_thread_spawn/client.rb6
1 files changed, 1 insertions, 5 deletions
diff --git a/lib/rainbows/xepoll_thread_spawn/client.rb b/lib/rainbows/xepoll_thread_spawn/client.rb
index 8cb3d27..76b4ca2 100644
--- a/lib/rainbows/xepoll_thread_spawn/client.rb
+++ b/lib/rainbows/xepoll_thread_spawn/client.rb
@@ -56,7 +56,7 @@ module Rainbows::XEpollThreadSpawn::Client
       ot = now - ot
       defer = []
       LOCK.synchronize do
-        KATO.delete_if { |client, time| time < ot and client.timeout!(defer) }
+        KATO.delete_if { |client, time| time < ot and defer << client }
       end
       defer.each { |io| io.closed? or io.close }
     end
@@ -68,10 +68,6 @@ module Rainbows::XEpollThreadSpawn::Client
     epoll_run(buf)
   end
 
-  def timeout!(defer)
-    defer << self
-  end
-
   def close
     super
     kato_delete