about summary refs log tree commit homepage
path: root/lib/rainbows/revactor.rb
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2010-12-30 08:32:24 +0000
committerEric Wong <normalperson@yhbt.net>2011-01-04 16:21:17 -0800
commit72a315441937f9e0531112f2b7080da39ca6064d (patch)
treefe310ac81f73605f2e278d8680aaf9eb4e755a71 /lib/rainbows/revactor.rb
parent1f28534fce2b30bf3099ea0d014b62ac4a3205f0 (diff)
downloadrainbows-72a315441937f9e0531112f2b7080da39ca6064d.tar.gz
This lets us simplify repetitive checks worry less about
properly maintaining/closing client connections for each
concurrency model we support.
Diffstat (limited to 'lib/rainbows/revactor.rb')
-rw-r--r--lib/rainbows/revactor.rb5
1 files changed, 2 insertions, 3 deletions
diff --git a/lib/rainbows/revactor.rb b/lib/rainbows/revactor.rb
index d996243..f4e8fca 100644
--- a/lib/rainbows/revactor.rb
+++ b/lib/rainbows/revactor.rb
@@ -42,7 +42,7 @@ module Rainbows::Revactor
     else
       LOCALHOST
     end
-    hp = Unicorn::HttpParser.new
+    hp = Rainbows::HttpParser.new
     buf = hp.buf
     alive = false
 
@@ -67,8 +67,7 @@ module Rainbows::Revactor
       if hp.headers?
         headers = HH.new(headers)
         range = make_range!(env, status, headers) and status = range.shift
-        alive = hp.next? && G.alive && G.kato > 0
-        headers[CONNECTION] = alive ? KEEP_ALIVE : CLOSE
+        headers[CONNECTION] = (alive = hp.next?) ? KEEP_ALIVE : CLOSE
         client.write(response_header(status, headers))
         alive && ts and buf << ts.leftover
       end