Module: Debugger::Xml::MultiProcess
- Defined in:
- lib/debugger/xml/multiprocess/monkey.rb,
lib/debugger/xml/multiprocess/pre_child.rb
Class Method Summary collapse
- .create_mp_exec(private = false) ⇒ Object
- .create_mp_fork(private = false) ⇒ Object
- .find_free_port(host) ⇒ Object
- .pre_child ⇒ Object
- .start_debugger(options) ⇒ Object
Class Method Details
.create_mp_exec(private = false) ⇒ Object
20 21 22 23 24 25 26 27 28 29 30 |
# File 'lib/debugger/xml/multiprocess/monkey.rb', line 20 def self.create_mp_exec(private=false) %Q{ alias pre_debugger_exec exec #{private ? "private" : ""} def exec(*args) Debugger.handler.interface.close pre_debugger_exec(*args) end } end |
.create_mp_fork(private = false) ⇒ Object
4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
# File 'lib/debugger/xml/multiprocess/monkey.rb', line 4 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::Xml::MultiProcess::pre_child; yield} end result = pre_debugger_fork Debugger::Xml::MultiProcess::pre_child unless result result end } end |
.find_free_port(host) ⇒ Object
71 72 73 74 75 76 |
# File 'lib/debugger/xml/multiprocess/pre_child.rb', line 71 def find_free_port(host) server = TCPServer.open(host, 0) port = server.addr[1] server.close port end |
.pre_child ⇒ Object
5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/debugger/xml/multiprocess/pre_child.rb', line 5 def pre_child require 'socket' require 'ostruct' host = ENV['DEBUGGER_HOST'] port = find_free_port(host) = OpenStruct.new( host: host, port: port, stop: false, tracing: false, wait_for_start: true, int_handler: true, debug_mode: (ENV['DEBUGGER_DEBUG_MODE'] == 'true'), dispatcher_port: ENV['IDE_PROCESS_DISPATCHER'] ) acceptor_host, acceptor_port = ENV['IDE_PROCESS_DISPATCHER'].split(":") acceptor_host, acceptor_port = '127.0.0.1', acceptor_host unless acceptor_port connected = false 3.times do |i| begin s = TCPSocket.open(acceptor_host, acceptor_port) s.print(port) s.close connected = true start_debugger() return rescue => bt $stderr.puts "#{Process.pid}: connection failed(#{i+1})" $stderr.puts "Exception: #{bt}" $stderr.puts bt.backtrace.map { |l| "\t#{l}" }.join("\n") sleep 0.3 end unless connected end end |
.start_debugger(options) ⇒ Object
45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 |
# File 'lib/debugger/xml/multiprocess/pre_child.rb', line 45 def start_debugger() if Debugger.started? # we're in forked child, only need to restart control thread Debugger.breakpoints.clear Debugger.control_thread = nil end if .int_handler # install interruption handler trap('INT') { Debugger.interrupt_last } end # set options Debugger.tracing = .tracing Debugger.wait_for_start = .wait_for_start Debugger.wait_connection = true Debugger.printer = Printers::Xml.new Debugger::Xml.logger = if .debug_mode Debugger::Xml::Ide::Logger.new else Debugger::Xml::FakeLogger.new end Debugger.start_remote_ide(.host, .port) end |