mirror of
https://github.com/ruby/ruby.git
synced 2025-08-25 22:14:37 +02:00

* lib/webrick/https.rb: SSLSocket handling is moved to webrick/ssl.rb. * lib/webrick/compat.rb (File::fnmatch): remove old migration code. * lib/webrick/httpserver.rb (HTTPServer#run): ditto. * lib/webrick/server.rb (GenericServer#listen): the body of this method is pull out as Utils::create_lisnteners. * lib/webrick/utils.rb (Utils::create_lisnteners): new method. * lib/webrick/server.rb (GenericServer#start): should not through unknown errors. and refine comments. * ext/openssl/lib/openssl/ssl.rb (SSLServer#accept): should close socket if SSLSocket raises error. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@4409 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
89 lines
1.6 KiB
Ruby
89 lines
1.6 KiB
Ruby
=begin
|
|
= $RCSfile$ -- Ruby-space definitions that completes C-space funcs for SSL
|
|
|
|
= Info
|
|
'OpenSSL for Ruby 2' project
|
|
Copyright (C) 2001 GOTOU YUUZOU <gotoyuzo@notwork.org>
|
|
All rights reserved.
|
|
|
|
= Licence
|
|
This program is licenced under the same licence as Ruby.
|
|
(See the file 'LICENCE'.)
|
|
|
|
= Version
|
|
$Id$
|
|
=end
|
|
|
|
require 'openssl/buffering'
|
|
|
|
module OpenSSL
|
|
module SSL
|
|
module SocketForwarder
|
|
def addr
|
|
to_io.addr
|
|
end
|
|
|
|
def peeraddr
|
|
to_io.peeraddr
|
|
end
|
|
|
|
def getsockopt(level, optname, optval)
|
|
to_io.setsockopt(level, optname, optval)
|
|
end
|
|
|
|
def setsockopt(level, optname)
|
|
to_io.setsockopt(level, optname)
|
|
end
|
|
|
|
def fcntl(*args)
|
|
to_io.fcntl(*args)
|
|
end
|
|
|
|
def closed?
|
|
to_io.closed?
|
|
end
|
|
end
|
|
|
|
class SSLSocket
|
|
include Buffering
|
|
include SocketForwarder
|
|
end
|
|
|
|
class SSLServer
|
|
include SocketForwarder
|
|
attr_accessor :start_immediately
|
|
|
|
def initialize(svr, ctx)
|
|
@svr = svr
|
|
@ctx = ctx
|
|
@start_immediately = true
|
|
end
|
|
|
|
def to_io
|
|
@svr
|
|
end
|
|
|
|
def listen(basklog=5)
|
|
@svr.listen(backlog)
|
|
end
|
|
|
|
def accept
|
|
sock = @svr.accept
|
|
begin
|
|
ssl = OpenSSL::SSL::SSLSocket.new(sock, @ctx)
|
|
ssl.sync = true
|
|
ssl.sync_close = true
|
|
ssl.accept if @start_immediately
|
|
ssl
|
|
rescue SSLError => ex
|
|
sock.close
|
|
raise ex
|
|
end
|
|
end
|
|
|
|
def close
|
|
@svr.close
|
|
end
|
|
end
|
|
end
|
|
end
|