diff options
author | Eric Wong <normalperson@yhbt.net> | 2011-04-29 18:11:04 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2011-04-29 18:11:04 +0000 |
commit | 73ed28f1863d5ae3048a284e25a918255bdafe8a (patch) | |
tree | 9df91dfef896bd2eae3be64d23e1aecb047e8e31 /lib | |
parent | aff36865d5e738babdbf36f34fd0693b67bb3d90 (diff) | |
download | rainbows-73ed28f1863d5ae3048a284e25a918255bdafe8a.tar.gz |
Noticed under 1.8.7
Diffstat (limited to 'lib')
-rw-r--r-- | lib/rainbows/xepoll_thread_spawn/client.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/rainbows/xepoll_thread_spawn/client.rb b/lib/rainbows/xepoll_thread_spawn/client.rb index bb1f324..9735f64 100644 --- a/lib/rainbows/xepoll_thread_spawn/client.rb +++ b/lib/rainbows/xepoll_thread_spawn/client.rb @@ -8,6 +8,7 @@ module Rainbows::XEpollThreadSpawn::Client max = Rainbows.server.worker_connections ACCEPTORS = Rainbows::HttpServer::LISTENERS.map do |sock| Thread.new do + sleep begin if io = sock.kgio_accept(Rainbows::Client) N.incr(0, 1) @@ -39,6 +40,7 @@ module Rainbows::XEpollThreadSpawn::Client end def self.loop + ACCEPTORS.each { |thr| thr.run } begin EP.wait(nil, 1000) { |fl, obj| obj.epoll_run } expire |