Class: Async::WebDriver::Bridge::ProcessGroup

Inherits:
Object
  • Object
show all
Defined in:
lib/async/webdriver/bridge/process_group.rb

Overview

A group of processes that are all killed when the group is closed.

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(pid) ⇒ ProcessGroup

Create a new process group from an existing process id.



22
23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/async/webdriver/bridge/process_group.rb', line 22

def initialize(pid)
  @pid = pid
  
  @status_task = Async(transient: true) do
    @status = ::Process.wait(@pid)
    
    unless @status.success?
      Console.error(self, "Process exited unexpectedly: #{@status}")
    end
  ensure
    self.close
  end
end

Class Method Details

.spawn(*arguments) ⇒ Object

Spawn a new process group with a given command.



13
14
15
16
17
18
 
# File 'lib/async/webdriver/bridge/process_group.rb', line 13

def self.spawn(*arguments)
  # This might be problematic...
  self.new(
    ::Process.spawn(*arguments, pgroup: true, out: File::NULL, err: File::NULL)
  )
end

Instance Method Details

#close ⇒ Object

Close the process group.



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
 
# File 'lib/async/webdriver/bridge/process_group.rb', line 37

def close
  if @status_task
    @status_task.stop
    @status_task = nil
  end
  
  if @pid
    ::Process.kill("INT", -@pid)
    
    Async do |task|
      task.with_timeout(1) do
        ::Process.wait(@pid)
      rescue Errno::ECHILD
        # Done.
      rescue Async::TimeoutError
        Console.info(self, "Killing pid #{@pid}...")
        ::Process.kill("KILL", -@pid)
      end
    end.wait
    
    wait_all(-@pid)
    @pid = nil
  end
end