Sha256: 468470ee732ceebc1cedfc522727242fb7907c77dc8bf74ba143033d05614ca9
Contents?: true
Size: 1.21 KB
Versions: 54
Compression:
Stored size: 1.21 KB
Contents
# frozen_string_literal: true
module Excon
class UnixSocket < Excon::Socket
private
def connect
@socket = ::Socket.new(::Socket::AF_UNIX, ::Socket::SOCK_STREAM, 0)
# If a Unix proxy was specified, the :path option will be set for it,
# otherwise fall back to the :socket option.
proxy_path = @data[:proxy] ? @data[:proxy][:path] : nil
sockaddr = ::Socket.sockaddr_un(proxy_path || @data[:socket])
if @nonblock
begin
@socket.connect_nonblock(sockaddr)
rescue Errno::EINPROGRESS
unless IO.select(nil, [@socket], nil, @data[:connect_timeout])
raise(Excon::Errors::Timeout.new("connect timeout reached"))
end
begin
@socket.connect_nonblock(sockaddr)
rescue Errno::EISCONN
0 # same return as connect_nonblock success
end
end
else
begin
Timeout.timeout(@data[:connect_timeout]) do
@socket.connect(sockaddr)
end
rescue Timeout::Error
raise Excon::Errors::Timeout.new('connect timeout reached')
end
end
rescue => error
@socket.close rescue nil if @socket
raise error
end
end
end
Version data entries
54 entries across 53 versions & 2 rubygems