Socket

# File lib/mogilefs/util.rb, line 161
    def mogilefs_new(host, port, timeout = 5.0)
      sock = mogilefs_new_nonblock(host, port) or return sock

      while timeout > 0
        t0 = Time.now
        r = IO.select(nil, [sock], nil, timeout)
        return sock if r && r[1] && sock.mogilefs_init
        timeout -= (Time.now - t0)
      end

      sock.close rescue nil
      raise MogileFS::Timeout, 'socket write timeout'
    end

# File lib/mogilefs/util.rb, line 148
    def mogilefs_new_nonblock(host, port)
      sock = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0)
      sock.sync = true
      if defined?(Socket::TCP_NODELAY)
        sock.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1)
      end
      sock.mogilefs_init(host, port)
      sock
    end

# File lib/mogilefs/util.rb, line 180
    def mogilefs_new_request(host, port, request, timeout = 5.0)
      t0 = Time.now
      sock = mogilefs_new(host, port, timeout)
      syswrite_full(sock, request, timeout)
      timeout -= (Time.now - t0)
      if timeout < 0
        sock.close rescue nil
        raise MogileFS::Timeout, 'socket read timeout'
      end
      r = IO.select([sock], nil, nil, timeout)
      return sock if r && r[0]

      sock.close rescue nil
      raise MogileFS::Timeout, 'socket read timeout'
    end

# File lib/mogilefs/util.rb, line 129
  def mogilefs_init(host = nil, port = nil)
    return true if defined?(@mogilefs_connected)

    @mogilefs_addr = Socket.sockaddr_in(port, host).freeze if port && host

    begin
      connect_nonblock(@mogilefs_addr)
      @mogilefs_connected = true
    rescue Errno::EINPROGRESS
      nil
    rescue Errno::EISCONN
      @mogilefs_connected = true
    end
  end

# File lib/mogilefs/util.rb, line 125
  def mogilefs_peername
    Socket.unpack_sockaddr_in(getpeername).reverse.map {|x| x.to_s }.join(':')
  end

# File lib/mogilefs/util.rb, line 117
  def mogilefs_tcp_cork=(set)
    if defined?(TCP_CORK)
      self.setsockopt(SOL_TCP, TCP_CORK, set ? 1 : 0) rescue nil
    end
    set
  end