diff options
author | Eric Wong <normalperson@yhbt.net> | 2011-05-08 01:28:43 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2011-05-08 01:28:43 +0000 |
commit | 497ce74310baaa7ac4835b8d6aa76acb40d44b7c (patch) | |
tree | 12755ba1e45fa56227e9d30a96d124ccc7880dcd /lib/rainbows/xepoll_thread_spawn/client.rb | |
parent | ef9376775b1a6eeae8807160b2b8ea23fbfd3607 (diff) | |
download | rainbows-497ce74310baaa7ac4835b8d6aa76acb40d44b7c.tar.gz |
shorter line and 3 lines of code killed!
Diffstat (limited to 'lib/rainbows/xepoll_thread_spawn/client.rb')
-rw-r--r-- | lib/rainbows/xepoll_thread_spawn/client.rb | 6 |
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 |