Class: DEBUGGER__::UI_TcpServer

Inherits:

UI_ServerBase

• Object
• UI_Base
• UI_ServerBase
• DEBUGGER__::UI_TcpServer

Defined in:

lib/debug/server.rb

Instance Attribute Summary

Attributes inherited from UI_ServerBase

#reader_thread

Instance Method Summary

• #accept ⇒ Object
• #chrome_setup ⇒ Object
• #initialize(host: nil, port: nil) ⇒ UI_TcpServer constructor

  A new instance of UI_TcpServer.

Methods inherited from UI_ServerBase

#activate, #after_fork_parent, #ask, #check_cookie, #cleanup_reader, #deactivate, #greeting, #parse_option, #pause, #process, #puts, #quit, #readline, #remote?, #setup_interrupt, #sigurg_overridden?, #sock, #vscode_setup, #width

Methods inherited from UI_Base

#event, #flush, #ignore_output_on_suspend?

Constructor Details

#initialize(host: nil, port: nil) ⇒ UI_TcpServer

Returns a new instance of UI_TcpServer.

# File 'lib/debug/server.rb', line 387

def initialize host: nil, port: nil
  @local_addr = nil
  @host = host || CONFIG[:host]
  @port_save_file = nil
  @port = begin
    port_str = (port && port.to_s) || CONFIG[:port] || raise("Specify listening port by RUBY_DEBUG_PORT environment variable.")
    case port_str
    when /\A\d+\z/
      port_str.to_i
    when /\A(\d+):(.+)\z/
      @port_save_file = $2
      $1.to_i
    else
      raise "Specify digits for port number"
    end
  end
  @port_range = if @port.zero?
    0
  else
    port_range_str = (CONFIG[:port_range] || "0").to_s
    raise "Specify a positive integer <=16 for port range" unless port_range_str.match?(/\A\d+\z/) && port_range_str.to_i <= 16
    port_range_str.to_i
  end
  @uuid = nil # for CDP

  super()
end

Instance Method Details

#accept ⇒ Object

# File 'lib/debug/server.rb', line 428

def accept
  retry_cnt = 0
  super # for fork

  begin
    Socket.tcp_server_sockets @host, @port do |socks|
      @local_addr = socks.first.local_address # Change this part if `socks` are multiple.
      rdbg = File.expand_path('../../exe/rdbg', __dir__)
      DEBUGGER__.warn "Debugger can attach via TCP/IP (#{@local_addr.inspect_sockaddr})"

      if @port_save_file
        File.write(@port_save_file, "#{socks[0].local_address.ip_port.to_s}\n")
        DEBUGGER__.warn "Port is saved into #{@port_save_file}"
      end

      DEBUGGER__.info "      With rdbg, use the following command line:\n      #\n      #   \#{rdbg} --attach \#{@local_addr.ip_address} \#{@local_addr.ip_port}\n      #\n      EOS\n\n      case CONFIG[:open]\n      when 'chrome'\n        chrome_setup\n      when 'vscode'\n        vscode_setup @local_addr.inspect_sockaddr\n      end\n\n      Socket.accept_loop(socks) do |sock, client|\n        @client_addr = client\n        yield @sock_for_fork = sock\n      end\n    end\n  rescue Errno::EADDRINUSE\n    number_of_retries = @port_range.zero? ? 10 : @port_range\n    if retry_cnt < number_of_retries\n      @port += 1 unless @port_range.zero?\n      retry_cnt += 1\n      sleep 0.1\n      retry\n    else\n      raise\n    end\n  rescue Terminate\n    # OK\n  rescue => e\n    $stderr.puts e.inspect, e.message\n    pp e.backtrace\n    exit\n  end\nensure\n  @sock_for_fork = nil\n\n  if @port_save_file && File.exist?(@port_save_file)\n    File.unlink(@port_save_file)\n  end\nend\n"

#chrome_setup ⇒ Object

# File 'lib/debug/server.rb', line 415

def chrome_setup
  require_relative 'server_cdp'

  @uuid = SecureRandom.uuid
  @chrome_pid = UI_CDP.setup_chrome(@local_addr.inspect_sockaddr, @uuid)
  DEBUGGER__.warn "    With Chrome browser, type the following URL in the address-bar:\n\n       devtools://devtools/bundled/inspector.html?v8only=true&panel=sources&noJavaScriptCompletion=true&ws=\#{@local_addr.inspect_sockaddr}/\#{@uuid}\n\n    EOS\nend\n"