1 files changed, 6 insertions, 31 deletions
diff --git a/lib/unicorn/socket_helper.rb b/lib/unicorn/socket_helper.rb
index 8a6f6ee..986932f 100644
--- a/lib/unicorn/socket_helper.rb
+++ b/lib/unicorn/socket_helper.rb
@@ -1,20 +1,9 @@
  # -*- encoding: binary -*-
+# frozen_string_literal: false
  # :enddoc:
  require 'socket'
  
  module Unicorn
-
-  # Instead of using a generic Kgio::Socket for everything,
-  # tag TCP sockets so we can use TCP_INFO under Linux without
-  # incurring extra syscalls for Unix domain sockets.
-  # TODO: remove these when we remove kgio
-  TCPClient = Class.new(Kgio::Socket) # :nodoc:
-  class TCPSrv < Kgio::TCPServer # :nodoc:
-    def kgio_tryaccept # :nodoc:
-      super(TCPClient)
-    end
-  end
-
    module SocketHelper
  
      # internal interface
@@ -91,7 +80,7 @@ module Unicorn
      def set_server_sockopt(sock, opt)
        opt = DEFAULTS.merge(opt || {})
  
-      TCPSocket === sock and set_tcp_sockopt(sock, opt)
+      set_tcp_sockopt(sock, opt) if sock.local_address.ip?
  
        rcvbuf, sndbuf = opt.values_at(:rcvbuf, :sndbuf)
        if rcvbuf || sndbuf
@@ -135,7 +124,9 @@ module Unicorn
          end
          old_umask = File.umask(opt[:umask] || 0)
          begin
-          Kgio::UNIXServer.new(address)
+          s = Socket.new(:UNIX, :STREAM)
+          s.bind(Socket.sockaddr_un(address))
+          s
          ensure
            File.umask(old_umask)
          end
@@ -163,8 +154,7 @@ module Unicorn
          sock.setsockopt(:SOL_SOCKET, :SO_REUSEPORT, 1)
        end
        sock.bind(Socket.pack_sockaddr_in(port, addr))
-      sock.autoclose = false
-      TCPSrv.for_fd(sock.fileno)
+      sock
      end
  
      # returns rfc2732-style (e.g. "[::1]:666") addresses for IPv6
@@ -180,10 +170,6 @@ module Unicorn
      def sock_name(sock)
        case sock
        when String then sock
-      when UNIXServer
-        Socket.unpack_sockaddr_un(sock.getsockname)
-      when TCPServer
-        tcp_name(sock)
        when Socket
          begin
            tcp_name(sock)
@@ -196,16 +182,5 @@ module Unicorn
      end
  
      module_function :sock_name
-
-    # casts a given Socket to be a TCPServer or UNIXServer
-    def server_cast(sock)
-      begin
-        Socket.unpack_sockaddr_in(sock.getsockname)
-        TCPSrv.for_fd(sock.fileno)
-      rescue ArgumentError
-        Kgio::UNIXServer.for_fd(sock.fileno)
-      end
-    end
-
    end # module SocketHelper
  end # module Unicorn