Sha256: 2c96f85e8c7837bc5c7cbd899fbd51be5156ef1a4f08579dccc1ed628cd87b18
Contents?: true
Size: 1.9 KB
Versions: 7
Compression:
Stored size: 1.9 KB
Contents
# frozen_string_literal: true
require 'openssl'
require_relative './socket'
# Open ssl socket helper methods (to make it compatible with Socket API)
class ::OpenSSL::SSL::SSLSocket
alias_method :orig_initialize, :initialize
def initialize(socket, context = nil)
socket = socket.respond_to?(:io) ? socket.io || socket : socket
context ? orig_initialize(socket, context) : orig_initialize(socket)
end
def dont_linger
io.dont_linger
end
def no_delay
io.no_delay
end
def reuse_addr
io.reuse_addr
end
alias_method :orig_accept, :accept
def accept
while true
result = accept_nonblock(exception: false)
case result
when :wait_readable then Thread.current.backend.wait_io(io, false)
when :wait_writable then Thread.current.backend.wait_io(io, true)
else
return result
end
end
end
def accept_loop
while true
yield accept
end
end
alias_method :orig_sysread, :sysread
def sysread(maxlen, buf = +'')
while true
case (result = read_nonblock(maxlen, buf, exception: false))
when :wait_readable then Thread.current.backend.wait_io(io, false)
when :wait_writable then Thread.current.backend.wait_io(io, true)
else return result
end
end
end
alias_method :orig_syswrite, :syswrite
def syswrite(buf)
while true
case (result = write_nonblock(buf, exception: false))
when :wait_readable then Thread.current.backend.wait_io(io, false)
when :wait_writable then Thread.current.backend.wait_io(io, true)
else
return result
end
end
end
def flush
# osync = @sync
# @sync = true
# do_write ""
# return self
# ensure
# @sync = osync
end
def readpartial(maxlen, buf = +'')
result = sysread(maxlen, buf)
result || (raise EOFError)
end
def read_loop
while (data = sysread(8192))
yield data
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems