1
2
3
4
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
# frozen_string_literal: true
# Licensed to the Software Freedom Conservancy (SFC) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The SFC licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
module Selenium
module WebDriver
#
# @api private
#
class ChildProcess
TimeoutError = Class.new(StandardError)
SIGTERM = 'TERM'
SIGKILL = 'KILL'
POLL_INTERVAL = 0.1
attr_accessor :detach
attr_writer :io
def self.build(*command)
new(*command)
end
def initialize(*command)
@command = command
@detach = false
@pid = nil
@status = nil
end
def io
@io ||= Platform.null_device
end
def start
options = {%i[out err] => io}
options[:pgroup] = true unless Platform.windows? # NOTE: this is a bug only in Windows 7
WebDriver.logger.debug("Starting process: #{@command} with #{options}", id: :process)
@pid = Process.spawn(*@command, options)
WebDriver.logger.debug(" -> pid: #{@pid}", id: :process)
Process.detach(@pid) if detach
end
def stop(timeout = 3)
return unless @pid
return if exited?
terminate_and_wait_else_kill(timeout)
rescue Errno::ECHILD, Errno::ESRCH => e
# Process exited earlier than terminate/kill could catch
WebDriver.logger.debug(" -> process: #{@pid} does not exist (#{e.class.name})", id: :process)
end
def alive?
@pid && !exited?
end
def exited?
return false unless @pid
WebDriver.logger.debug("Checking if #{@pid} is exited:", id: :process)
_, @status = waitpid2(@pid, Process::WNOHANG | Process::WUNTRACED) if @status.nil?
return false if @status.nil?
exit_code = @status.exitstatus || @status.termsig
WebDriver.logger.debug(" -> exit code is #{exit_code.inspect}", id: :process)
!!exit_code
rescue Errno::ECHILD, Errno::ESRCH
WebDriver.logger.debug(" -> process: #{@pid} already finished", id: :process)
true
end
def poll_for_exit(timeout)
WebDriver.logger.debug("Polling #{timeout} seconds for exit of #{@pid}", id: :process)
end_time = Time.now + timeout
sleep POLL_INTERVAL until exited? || Time.now > end_time
raise TimeoutError, " -> #{@pid} still alive after #{timeout} seconds" unless exited?
end
def wait
return if exited?
_, @status = waitpid2(@pid)
end
private
def terminate_and_wait_else_kill(timeout)
WebDriver.logger.debug("Sending TERM to process: #{@pid}", id: :process)
terminate(@pid)
poll_for_exit(timeout)
WebDriver.logger.debug(" -> stopped #{@pid}", id: :process)
rescue TimeoutError, Errno::EINVAL
WebDriver.logger.debug(" -> sending KILL to process: #{@pid}", id: :process)
kill(@pid)
wait
WebDriver.logger.debug(" -> killed #{@pid}", id: :process)
end
def terminate(pid)
Process.kill(SIGTERM, pid)
rescue Errno::ECHILD, Errno::ESRCH
# Process does not exist, nothing to terminate
end
def kill(pid)
Process.kill(SIGKILL, pid)
rescue Errno::ECHILD, Errno::ESRCH
# Process does not exist, nothing to kill
end
def waitpid2(pid, flags = 0)
Process.waitpid2(pid, flags)
end
end # ChildProcess
end # WebDriver
end # Selenium
|
