File Content: handle.rb module ChildProcess module Windows class Handle class << self private :new def open(pid, access = PROCESS_ALL_ACCESS) handle = Lib.open_process(access, false, pid) if handle.null? raise Error, Lib.last_error_message end h = new(handle, pid) return h unless block_given? begin yield h ensure h.close end end end attr_reader :pointer def initialize(pointer, pid) unless pointer.kind_of?(FFI::Pointer) raise TypeError, "invalid handle: #{pointer.inspect}" end if pointer.null? raise ArgumentError, "handle is null: #{pointer.inspect}" end @pid = pid @pointer = pointer @closed = false end def exit_code code_pointer = FFI::MemoryPointer.new :ulong ok = Lib.get_exit_code(@pointer, code_pointer) if ok code_pointer.get_ulong(0) else close raise Error, Lib.last_error_message end end def send(signal) case signal when 0 exit_code == PROCESS_STILL_ALIVE when WIN_SIGINT Lib.generate_console_ctrl_event(CTRL_C_EVENT, @pid) when WIN_SIGBREAK Lib.generate_console_ctrl_event(CTRL_BREAK_EVENT, @pid) when WIN_SIGKILL ok = Lib.terminate_process(@pointer, @pid) Lib.check_error ok else thread_id = FFI::MemoryPointer.new(:ulong) module_handle = Lib.get_module_handle("kernel32") proc_address = Lib.get_proc_address(module_handle, "ExitProcess") thread = Lib.create_remote_thread(@pointer, 0, 0, proc_address, 0, 0, thread_id) check_error thread Lib.wait_for_single_object(thread, 5) true end end def close return if @closed Lib.close_handle(@pointer) @closed = true end def wait(milliseconds = nil) Lib.wait_for_single_object(@pointer, milliseconds || INFINITE) end end # Handle end # Windows end # ChildProcess Submit