diff options
author | Eric Wong <e@80x24.org> | 2016-06-05 22:48:44 +0000 |
---|---|---|
committer | Eric Wong <e@80x24.org> | 2016-06-05 22:48:44 +0000 |
commit | 5e211ea003d20708a221d124e139f72ded4e18b0 (patch) | |
tree | 392185e2eb42888853fc016711a19d452542e46f /lib/yahns/proxy_http_response.rb | |
parent | dcdeb4071ded73bcf4fd696b268bce7ee2021f5d (diff) | |
download | yahns-5e211ea003d20708a221d124e139f72ded4e18b0.tar.gz |
@busy will be reset on wbuf_write anyways, since there is no initial data and we will always attempt to write to the socket aggressively.
Diffstat (limited to 'lib/yahns/proxy_http_response.rb')
-rw-r--r-- | lib/yahns/proxy_http_response.rb | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/yahns/proxy_http_response.rb b/lib/yahns/proxy_http_response.rb index ea176d9..61f1539 100644 --- a/lib/yahns/proxy_http_response.rb +++ b/lib/yahns/proxy_http_response.rb @@ -19,9 +19,9 @@ module Yahns::HttpResponse # :nodoc: :ignore end - def wbuf_alloc(req_res, busy) + def wbuf_alloc(req_res) if req_res.proxy_pass.proxy_buffering - Yahns::Wbuf.new(nil, req_res.alive, self.class.output_buffer_tmpdir, busy) + Yahns::Wbuf.new(nil, req_res.alive, self.class.output_buffer_tmpdir) else Yahns::WbufLite.new(req_res) end @@ -37,7 +37,7 @@ module Yahns::HttpResponse # :nodoc: when String, Array # partial write, hope the skb grows buf = rv when :wait_writable, :wait_readable - wbuf = req_res.resbuf ||= wbuf_alloc(req_res, rv) + wbuf = req_res.resbuf ||= wbuf_alloc(req_res) break end while true end @@ -75,7 +75,7 @@ module Yahns::HttpResponse # :nodoc: end def wait_on_upstream(req_res) - req_res.resbuf ||= wbuf_alloc(req_res, false) + req_res.resbuf ||= wbuf_alloc(req_res) :wait_readable # self remains in :ignore, wait on upstream end |