mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
84b012e02a
In case a process encounters high-numbered FDs, this allows consistent performance on systems with ppoll support. [ruby-core:35572] * ext/socket/lib/socket.rb (connect_nonblock): use IO#wait_writable * lib/drb/drb.rb (DRB::DRbTCPSocket#alive?): use IO#wait_readable * lib/webrick/httpserver.rb (run): ditto * lib/resolv.rb (request): ditto for single socket case [ruby-core:68943] [Feature #11081] git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@50432 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
279 lines
7.7 KiB
Ruby
279 lines
7.7 KiB
Ruby
#
|
|
# httpserver.rb -- HTTPServer Class
|
|
#
|
|
# Author: IPR -- Internet Programming with Ruby -- writers
|
|
# Copyright (c) 2000, 2001 TAKAHASHI Masayoshi, GOTOU Yuuzou
|
|
# Copyright (c) 2002 Internet Programming with Ruby writers. All rights
|
|
# reserved.
|
|
#
|
|
# $IPR: httpserver.rb,v 1.63 2002/10/01 17:16:32 gotoyuzo Exp $
|
|
|
|
require 'io/wait'
|
|
require 'webrick/server'
|
|
require 'webrick/httputils'
|
|
require 'webrick/httpstatus'
|
|
require 'webrick/httprequest'
|
|
require 'webrick/httpresponse'
|
|
require 'webrick/httpservlet'
|
|
require 'webrick/accesslog'
|
|
|
|
module WEBrick
|
|
class HTTPServerError < ServerError; end
|
|
|
|
##
|
|
# An HTTP Server
|
|
|
|
class HTTPServer < ::WEBrick::GenericServer
|
|
##
|
|
# Creates a new HTTP server according to +config+
|
|
#
|
|
# An HTTP server uses the following attributes:
|
|
#
|
|
# :AccessLog:: An array of access logs. See WEBrick::AccessLog
|
|
# :BindAddress:: Local address for the server to bind to
|
|
# :DocumentRoot:: Root path to serve files from
|
|
# :DocumentRootOptions:: Options for the default HTTPServlet::FileHandler
|
|
# :HTTPVersion:: The HTTP version of this server
|
|
# :Port:: Port to listen on
|
|
# :RequestCallback:: Called with a request and response before each
|
|
# request is serviced.
|
|
# :RequestTimeout:: Maximum time to wait between requests
|
|
# :ServerAlias:: Array of alternate names for this server for virtual
|
|
# hosting
|
|
# :ServerName:: Name for this server for virtual hosting
|
|
|
|
def initialize(config={}, default=Config::HTTP)
|
|
super(config, default)
|
|
@http_version = HTTPVersion::convert(@config[:HTTPVersion])
|
|
|
|
@mount_tab = MountTable.new
|
|
if @config[:DocumentRoot]
|
|
mount("/", HTTPServlet::FileHandler, @config[:DocumentRoot],
|
|
@config[:DocumentRootOptions])
|
|
end
|
|
|
|
unless @config[:AccessLog]
|
|
@config[:AccessLog] = [
|
|
[ $stderr, AccessLog::COMMON_LOG_FORMAT ],
|
|
[ $stderr, AccessLog::REFERER_LOG_FORMAT ]
|
|
]
|
|
end
|
|
|
|
@virtual_hosts = Array.new
|
|
end
|
|
|
|
##
|
|
# Processes requests on +sock+
|
|
|
|
def run(sock)
|
|
while true
|
|
res = HTTPResponse.new(@config)
|
|
req = HTTPRequest.new(@config)
|
|
server = self
|
|
begin
|
|
timeout = @config[:RequestTimeout]
|
|
while timeout > 0
|
|
break if sock.to_io.wait_readable(0.5)
|
|
break if @status != :Running
|
|
timeout -= 0.5
|
|
end
|
|
raise HTTPStatus::EOFError if timeout <= 0 || @status != :Running
|
|
raise HTTPStatus::EOFError if sock.eof?
|
|
req.parse(sock)
|
|
res.request_method = req.request_method
|
|
res.request_uri = req.request_uri
|
|
res.request_http_version = req.http_version
|
|
res.keep_alive = req.keep_alive?
|
|
server = lookup_server(req) || self
|
|
if callback = server[:RequestCallback]
|
|
callback.call(req, res)
|
|
elsif callback = server[:RequestHandler]
|
|
msg = ":RequestHandler is deprecated, please use :RequestCallback"
|
|
@logger.warn(msg)
|
|
callback.call(req, res)
|
|
end
|
|
server.service(req, res)
|
|
rescue HTTPStatus::EOFError, HTTPStatus::RequestTimeout => ex
|
|
res.set_error(ex)
|
|
rescue HTTPStatus::Error => ex
|
|
@logger.error(ex.message)
|
|
res.set_error(ex)
|
|
rescue HTTPStatus::Status => ex
|
|
res.status = ex.code
|
|
rescue StandardError => ex
|
|
@logger.error(ex)
|
|
res.set_error(ex, true)
|
|
ensure
|
|
if req.request_line
|
|
if req.keep_alive? && res.keep_alive?
|
|
req.fixup()
|
|
end
|
|
res.send_response(sock)
|
|
server.access_log(@config, req, res)
|
|
end
|
|
end
|
|
break if @http_version < "1.1"
|
|
break unless req.keep_alive?
|
|
break unless res.keep_alive?
|
|
end
|
|
end
|
|
|
|
##
|
|
# Services +req+ and fills in +res+
|
|
|
|
def service(req, res)
|
|
if req.unparsed_uri == "*"
|
|
if req.request_method == "OPTIONS"
|
|
do_OPTIONS(req, res)
|
|
raise HTTPStatus::OK
|
|
end
|
|
raise HTTPStatus::NotFound, "`#{req.unparsed_uri}' not found."
|
|
end
|
|
|
|
servlet, options, script_name, path_info = search_servlet(req.path)
|
|
raise HTTPStatus::NotFound, "`#{req.path}' not found." unless servlet
|
|
req.script_name = script_name
|
|
req.path_info = path_info
|
|
si = servlet.get_instance(self, *options)
|
|
@logger.debug(format("%s is invoked.", si.class.name))
|
|
si.service(req, res)
|
|
end
|
|
|
|
##
|
|
# The default OPTIONS request handler says GET, HEAD, POST and OPTIONS
|
|
# requests are allowed.
|
|
|
|
def do_OPTIONS(req, res)
|
|
res["allow"] = "GET,HEAD,POST,OPTIONS"
|
|
end
|
|
|
|
##
|
|
# Mounts +servlet+ on +dir+ passing +options+ to the servlet at creation
|
|
# time
|
|
|
|
def mount(dir, servlet, *options)
|
|
@logger.debug(sprintf("%s is mounted on %s.", servlet.inspect, dir))
|
|
@mount_tab[dir] = [ servlet, options ]
|
|
end
|
|
|
|
##
|
|
# Mounts +proc+ or +block+ on +dir+ and calls it with a
|
|
# WEBrick::HTTPRequest and WEBrick::HTTPResponse
|
|
|
|
def mount_proc(dir, proc=nil, &block)
|
|
proc ||= block
|
|
raise HTTPServerError, "must pass a proc or block" unless proc
|
|
mount(dir, HTTPServlet::ProcHandler.new(proc))
|
|
end
|
|
|
|
##
|
|
# Unmounts +dir+
|
|
|
|
def unmount(dir)
|
|
@logger.debug(sprintf("unmount %s.", dir))
|
|
@mount_tab.delete(dir)
|
|
end
|
|
alias umount unmount
|
|
|
|
##
|
|
# Finds a servlet for +path+
|
|
|
|
def search_servlet(path)
|
|
script_name, path_info = @mount_tab.scan(path)
|
|
servlet, options = @mount_tab[script_name]
|
|
if servlet
|
|
[ servlet, options, script_name, path_info ]
|
|
end
|
|
end
|
|
|
|
##
|
|
# Adds +server+ as a virtual host.
|
|
|
|
def virtual_host(server)
|
|
@virtual_hosts << server
|
|
@virtual_hosts = @virtual_hosts.sort_by{|s|
|
|
num = 0
|
|
num -= 4 if s[:BindAddress]
|
|
num -= 2 if s[:Port]
|
|
num -= 1 if s[:ServerName]
|
|
num
|
|
}
|
|
end
|
|
|
|
##
|
|
# Finds the appropriate virtual host to handle +req+
|
|
|
|
def lookup_server(req)
|
|
@virtual_hosts.find{|s|
|
|
(s[:BindAddress].nil? || req.addr[3] == s[:BindAddress]) &&
|
|
(s[:Port].nil? || req.port == s[:Port]) &&
|
|
((s[:ServerName].nil? || req.host == s[:ServerName]) ||
|
|
(!s[:ServerAlias].nil? && s[:ServerAlias].find{|h| h === req.host}))
|
|
}
|
|
end
|
|
|
|
##
|
|
# Logs +req+ and +res+ in the access logs. +config+ is used for the
|
|
# server name.
|
|
|
|
def access_log(config, req, res)
|
|
param = AccessLog::setup_params(config, req, res)
|
|
@config[:AccessLog].each{|logger, fmt|
|
|
logger << AccessLog::format(fmt+"\n", param)
|
|
}
|
|
end
|
|
|
|
##
|
|
# Mount table for the path a servlet is mounted on in the directory space
|
|
# of the server. Users of WEBrick can only access this indirectly via
|
|
# WEBrick::HTTPServer#mount, WEBrick::HTTPServer#unmount and
|
|
# WEBrick::HTTPServer#search_servlet
|
|
|
|
class MountTable # :nodoc:
|
|
def initialize
|
|
@tab = Hash.new
|
|
compile
|
|
end
|
|
|
|
def [](dir)
|
|
dir = normalize(dir)
|
|
@tab[dir]
|
|
end
|
|
|
|
def []=(dir, val)
|
|
dir = normalize(dir)
|
|
@tab[dir] = val
|
|
compile
|
|
val
|
|
end
|
|
|
|
def delete(dir)
|
|
dir = normalize(dir)
|
|
res = @tab.delete(dir)
|
|
compile
|
|
res
|
|
end
|
|
|
|
def scan(path)
|
|
@scanner =~ path
|
|
[ $&, $' ]
|
|
end
|
|
|
|
private
|
|
|
|
def compile
|
|
k = @tab.keys
|
|
k.sort!
|
|
k.reverse!
|
|
k.collect!{|path| Regexp.escape(path) }
|
|
@scanner = Regexp.new("^(" + k.join("|") +")(?=/|$)")
|
|
end
|
|
|
|
def normalize(dir)
|
|
ret = dir ? dir.dup : ""
|
|
ret.sub!(%r|/+$|, "")
|
|
ret
|
|
end
|
|
end
|
|
end
|
|
end
|