/usr/lib/ruby/vendor_ruby/childprocess/abstract_process.rb is in ruby-childprocess 0.5.9-1ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 | module ChildProcess
class AbstractProcess
POLL_INTERVAL = 0.1
attr_reader :exit_code
#
# Set this to true if you do not care about when or if the process quits.
#
attr_accessor :detach
#
# Set this to true if you want to write to the process' stdin (process.io.stdin)
#
attr_accessor :duplex
#
# Modify the child's environment variables
#
attr_reader :environment
#
# Set the child's current working directory.
#
attr_accessor :cwd
#
#
# Set this to true to make the child process the leader of a new process group
#
# This can be used to make sure that all grandchildren are killed
# when the child process dies.
#
attr_accessor :leader
#
# Create a new process with the given args.
#
# @api private
# @see ChildProcess.build
#
def initialize(args)
unless args.all? { |e| e.kind_of?(String) }
raise ArgumentError, "all arguments must be String: #{args.inspect}"
end
@args = args
@started = false
@exit_code = nil
@io = nil
@cwd = nil
@detach = false
@duplex = false
@leader = false
@environment = {}
end
#
# Returns a ChildProcess::AbstractIO subclass to configure the child's IO streams.
#
def io
raise SubclassResponsibility, "io"
end
#
# @return [Fixnum] the pid of the process after it has started
#
def pid
raise SubclassResponsibility, "pid"
end
#
# Launch the child process
#
# @return [AbstractProcess] self
#
def start
launch_process
@started = true
self
end
#
# Forcibly terminate the process, using increasingly harsher methods if possible.
#
# @param [Fixnum] timeout (3) Seconds to wait before trying the next method.
#
def stop(timeout = 3)
raise SubclassResponsibility, "stop"
end
#
# Block until the process has been terminated.
#
# @return [Fixnum] The exit status of the process
#
def wait
raise SubclassResponsibility, "wait"
end
#
# Did the process exit?
#
# @return [Boolean]
#
def exited?
raise SubclassResponsibility, "exited?"
end
#
# Is this process running?
#
# @return [Boolean]
#
def alive?
started? && !exited?
end
#
# Returns true if the process has exited and the exit code was not 0.
#
# @return [Boolean]
#
def crashed?
exited? && @exit_code != 0
end
#
# Wait for the process to exit, raising a ChildProcess::TimeoutError if
# the timeout expires.
#
def poll_for_exit(timeout)
log "polling #{timeout} seconds for exit"
end_time = Time.now + timeout
until (ok = exited?) || Time.now > end_time
sleep POLL_INTERVAL
end
unless ok
raise TimeoutError, "process still alive after #{timeout} seconds"
end
end
private
def launch_process
raise SubclassResponsibility, "launch_process"
end
def started?
@started
end
def detach?
@detach
end
def duplex?
@duplex
end
def leader?
@leader
end
def log(*args)
$stderr.puts "#{self.inspect} : #{args.inspect}" if $DEBUG
end
def assert_started
raise Error, "process not started" unless started?
end
end # AbstractProcess
end # ChildProcess
|