diff options
| author | Eric Wong <e@yhbt.net> | 2010-08-25 13:58:11 -0700 |
|---|---|---|
| committer | Eric Wong <normalperson@yhbt.net> | 2010-08-26 08:47:36 +0000 |
| commit | 47e1ee2d90161abf92ce14562bf508398fdfa6c9 (patch) | |
| tree | d4fb816d9874ec0b0bdfd285e9ca10e4f17d0227 /lib/rainbows/thread_pool.rb | |
| parent | bd3ed0b04f826b20cce83f9b77fc13c0eefd3902 (diff) | |
| download | rainbows-47e1ee2d90161abf92ce14562bf508398fdfa6c9.tar.gz | |
Trying to avoid adding singleton methods since it's too easily accessible by the public and not needed by the general public. This also allows us (or just Zbatery) to more easily add support systems without FD_CLOEXEC or fcntl, and also to optimize away a fcntl call for systems that inherit FD_CLOEXEC.
Diffstat (limited to 'lib/rainbows/thread_pool.rb')
| -rw-r--r-- | lib/rainbows/thread_pool.rb | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/lib/rainbows/thread_pool.rb b/lib/rainbows/thread_pool.rb index 28a943e..a643bd8 100644 --- a/lib/rainbows/thread_pool.rb +++ b/lib/rainbows/thread_pool.rb @@ -24,6 +24,7 @@ module Rainbows module ThreadPool include Base + include Rainbows::Acceptor def worker_loop(worker) # :nodoc: init_worker_process(worker) @@ -44,7 +45,7 @@ module Rainbows def sync_worker # :nodoc: s = LISTENERS[0] begin - c = Rainbows.sync_accept(s) and process_client(c) + c = sync_accept(s) and process_client(c) rescue => e Error.listen_loop(e) end while G.alive @@ -58,7 +59,7 @@ module Rainbows # problem. On the other hand, a thundering herd may not # even incur as much overhead as an extra Mutex#synchronize ret = IO.select(LISTENERS, nil, nil, 1) and ret[0].each do |s| - s = Rainbows.accept(s) and process_client(s) + s = accept(s) and process_client(s) end rescue Errno::EINTR rescue => e |