diff options
author | Eric Wong <normalperson@yhbt.net> | 2009-10-17 22:42:55 -0700 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2009-10-17 22:42:55 -0700 |
commit | b79ce7e6594259669763251e3cbf4404a6381d7c (patch) | |
tree | 6f1b55b1301107ea3e6bdbf21ecf9dd90cfca2a9 /lib/rainbows | |
parent | e0c33c583c5b4d2a4661edb6c41d6a60b44dae9d (diff) | |
download | rainbows-b79ce7e6594259669763251e3cbf4404a6381d7c.tar.gz |
It's more fool-proof this way and prevents us from using idiotic/non-obvious concurrency model names.
Diffstat (limited to 'lib/rainbows')
-rw-r--r-- | lib/rainbows/http_server.rb | 1 | ||||
-rw-r--r-- | lib/rainbows/thread_pool.rb | 1 | ||||
-rw-r--r-- | lib/rainbows/thread_spawn.rb | 1 |
3 files changed, 1 insertions, 2 deletions
diff --git a/lib/rainbows/http_server.rb b/lib/rainbows/http_server.rb index fc51ac3..6d61228 100644 --- a/lib/rainbows/http_server.rb +++ b/lib/rainbows/http_server.rb @@ -32,6 +32,7 @@ module Rainbows raise ArgumentError, "concurrency model #{model.inspect} not supported" extend(mod) Const::RACK_DEFAULTS['rainbows.model'] = @use = model + Const::RACK_DEFAULTS['rack.multithread'] = !!(/Thread/ =~ model.to_s) end def worker_connections(*args) diff --git a/lib/rainbows/thread_pool.rb b/lib/rainbows/thread_pool.rb index 2bae89b..c742e5d 100644 --- a/lib/rainbows/thread_pool.rb +++ b/lib/rainbows/thread_pool.rb @@ -27,7 +27,6 @@ module Rainbows def worker_loop(worker) init_worker_process(worker) - RACK_DEFAULTS["rack.multithread"] = true pool = (1..worker_connections).map { new_worker_thread } m = 0 diff --git a/lib/rainbows/thread_spawn.rb b/lib/rainbows/thread_spawn.rb index fb9ea57..104e764 100644 --- a/lib/rainbows/thread_spawn.rb +++ b/lib/rainbows/thread_spawn.rb @@ -21,7 +21,6 @@ module Rainbows def worker_loop(worker) init_worker_process(worker) - RACK_DEFAULTS["rack.multithread"] = true threads = ThreadGroup.new alive = worker.tmp m = 0 |