diff options
| author | Eric Wong <normalperson@yhbt.net> | 2013-02-08 22:45:20 +0000 |
|---|---|---|
| committer | Eric Wong <normalperson@yhbt.net> | 2013-02-11 01:57:05 +0000 |
| commit | e166cfe5e8d648b544b1291ec157bd234a425e21 (patch) | |
| tree | 8ac56aadc51d81d4d250cfec696446f19ffd1d64 /lib/rainbows/coolio/thread_client.rb | |
| parent | e6faf9e26bcb172026a4984ecadbaa8b6789bcb7 (diff) | |
| download | rainbows-e166cfe5e8d648b544b1291ec157bd234a425e21.tar.gz | |
This requires Rack 1.5.x and unicorn 4.6.0 for hijacking support. Older versions of Rack continue to work fine, but we must use unicorn 4.6.0 features to support this.
Diffstat (limited to 'lib/rainbows/coolio/thread_client.rb')
| -rw-r--r-- | lib/rainbows/coolio/thread_client.rb | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/rainbows/coolio/thread_client.rb b/lib/rainbows/coolio/thread_client.rb index abc11d2..ee9fa04 100644 --- a/lib/rainbows/coolio/thread_client.rb +++ b/lib/rainbows/coolio/thread_client.rb @@ -14,6 +14,7 @@ class Rainbows::Coolio::ThreadClient < Rainbows::Coolio::Client # this is only called in the master thread def response_write(response) + return hijacked if @hp.hijacked? ev_write_response(*response, @hp.next?) rescue => e handle_error(e) @@ -25,6 +26,7 @@ class Rainbows::Coolio::ThreadClient < Rainbows::Coolio::Client def app_response begin @env[REMOTE_ADDR] = @_io.kgio_addr + @hp.hijack_setup(@env, @_io) APP.call(@env.merge!(RACK_DEFAULTS)) rescue => e Rainbows::Error.app(e) # we guarantee this does not raise |