about summary refs log tree commit homepage
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2010-10-23 00:42:04 +0000
committerEric Wong <normalperson@yhbt.net>2010-10-23 00:42:54 +0000
commit4ee6e0dafeb1b7af28fa90ae27c1a1a04aa8e852 (patch)
tree71388fcb7db88abf916852ff713425f009693af3
parent180485d49ea858f83ef2a28a9e07224aa514edc7 (diff)
downloadrainbows-4ee6e0dafeb1b7af28fa90ae27c1a1a04aa8e852.tar.gz
It does not appear to be needed, for now, since the
parser and Unicorn::HttpRequest are one and the same.
-rw-r--r--lib/rainbows.rb1
-rw-r--r--lib/rainbows/http_request.rb39
2 files changed, 0 insertions, 40 deletions
diff --git a/lib/rainbows.rb b/lib/rainbows.rb
index 7a29232..a1f842c 100644
--- a/lib/rainbows.rb
+++ b/lib/rainbows.rb
@@ -39,7 +39,6 @@ module Rainbows
   require 'rainbows/http_server'
   require 'rainbows/response'
   require 'rainbows/client'
-  require 'rainbows/http_request'
   require 'rainbows/tee_input'
   require 'rainbows/process_client'
   autoload :Base, 'rainbows/base'
diff --git a/lib/rainbows/http_request.rb b/lib/rainbows/http_request.rb
deleted file mode 100644
index 56c24ca..0000000
--- a/lib/rainbows/http_request.rb
+++ /dev/null
@@ -1,39 +0,0 @@
-# -*- encoding: binary -*-
-class Rainbows::HttpRequest < Unicorn::HttpRequest
-  attr_accessor :remote_addr
-
-  def keepalive?
-    if rv = keepalive?
-      env.clear
-      parser.reset
-    end
-    rv
-  end
-
-  def initialize(socket)
-    @remote_addr = if socket.respond_to?(:kgio_addr)
-      socket.kgio_addr
-    elsif socket.respond_to?(:peeraddr)
-      socket.peeraddr[-1]
-    else
-      Kgio::LOCALHOST
-    end
-    super()
-  end
-
-  def wait_headers_readable(socket)
-    IO.select([socket], nil, nil, Rainbows::G.kato)
-  end
-
-  def tryread(socket)
-    socket.kgio_read!(16384, b = buf)
-    until e = parse
-      wait_headers_readable(socket)
-      b << socket.kgio_read!(16384)
-    end
-    e[Rainbows::Const::CLIENT_IO] = socket
-    e[RACK_INPUT] = 0 == content_length ? NULL_IO : TeeInput.new(socket, self)
-    e[REMOTE_ADDR] = @remote_addr
-    e.merge!(DEFAULTS)
-  end
-end