Module: Debugger::MultiProcess

Defined in:
lib/ruby-debug-ide/multiprocess/monkey.rb,
lib/ruby-debug-ide/multiprocess/pre_child.rb

Class Method Summary collapse

Class Method Details

.create_mp_exec(private = false) ⇒ Object



19
20
21
22
23
24
25
26
27
28
29
# File 'lib/ruby-debug-ide/multiprocess/monkey.rb', line 19

def self.create_mp_exec(private=false)
  %Q{
    alias pre_debugger_exec exec
    
    #{private ? "private" : ""}
    def exec(*args)
      Debugger.interface.close
      pre_debugger_exec(*args)
    end
  }
end

.create_mp_fork(private = false) ⇒ Object



3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
# File 'lib/ruby-debug-ide/multiprocess/monkey.rb', line 3

def self.create_mp_fork(private=false)
  %Q{
    alias pre_debugger_fork fork

    #{private ? "private" : ""}
    def fork(*args)
      if block_given?
        return pre_debugger_fork{Debugger::MultiProcess::pre_child; yield}
      end
      result = pre_debugger_fork
      Debugger::MultiProcess::pre_child unless result
      result
    end
  }
end

.find_free_port(host) ⇒ Object



49
50
51
52
53
54
# File 'lib/ruby-debug-ide/multiprocess/pre_child.rb', line 49

def find_free_port(host)
  server = TCPServer.open(host, 0)
  port   = server.addr[1]
  server.close
  port
end

.pre_childObject



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
# File 'lib/ruby-debug-ide/multiprocess/pre_child.rb', line 4

def pre_child

  require 'socket'
  require 'ostruct'

  host = ENV['DEBUGGER_HOST']
  port = find_free_port(host)

  options = OpenStruct.new(
      'frame_bind'  => false,
      'host'        => host,
      'load_mode'   => false,
      'port'        => port,
      'stop'        => false,
      'tracing'     => false,
      'int_handler' => true,
      'cli_debug'   => (ENV['DEBUGGER_CLI_DEBUG'] == 'true'),
      'notify_dispatcher' => true
  )

  start_debugger(options)
end

.start_debugger(options) ⇒ Object



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
# File 'lib/ruby-debug-ide/multiprocess/pre_child.rb', line 27

def start_debugger(options)
  if Debugger.started?
    # we're in forked child, only need to restart control thread
    Debugger.breakpoints.clear
    Debugger.control_thread = nil
    Debugger.start_control(options.host, options.port, options.notify_dispatcher)
  end

  if options.int_handler
    # install interruption handler
    trap('INT') { Debugger.interrupt_last }
  end

  # set options
  Debugger.keep_frame_binding = options.frame_bind
  Debugger.tracing = options.tracing
  Debugger.cli_debug = options.cli_debug

  Debugger.prepare_debugger(options)
end