def spawn arg, *argv
argv.unshift(arg)
opts = ((argv.size > 1 and Hash === argv.last) ? argv.pop : {})
argv.flatten!
cmd = argv.join(' ')
getopt = getopts opts
ignore_exit_failure = getopt[ 'ignore_exit_failure', getopt['quiet', false] ]
ignore_exec_failure = getopt[ 'ignore_exec_failure', !getopt['raise', true] ]
exitstatus = getopt[ %w( exitstatus exit_status status ) ]
stdin = getopt[ %w( stdin in i 0 ) << 0 ]
stdout = getopt[ %w( stdout out o 1 ) << 1 ]
stderr = getopt[ %w( stderr err e 2 ) << 2 ]
pid = getopt[ 'pid' ]
timeout = getopt[ %w( timeout spawn_timeout ) ]
stdin_timeout = getopt[ %w( stdin_timeout ) ]
stdout_timeout = getopt[ %w( stdout_timeout io_timeout ) ]
stderr_timeout = getopt[ %w( stderr_timeout ) ]
status = getopt[ %w( status ) ]
cwd = getopt[ %w( cwd dir ) ]
closefds = getopt[ %w( close_fds ) ]
exitstatus =
case exitstatus
when TrueClass, FalseClass
ignore_exit_failure = true if exitstatus
[0]
else
[*(exitstatus || 0)].map{|i| Integer i}
end
stdin ||= '' if stdin_timeout
stdout ||= '' if stdout_timeout
stderr ||= '' if stderr_timeout
started = false
status =
begin
chdir(cwd) do
Timeout::timeout(timeout) do
popen4ext(closefds, *argv) do |c, i, o, e|
started = true
%w( replace pid= << push update ).each do |msg|
break(pid.send(msg, c)) if pid.respond_to? msg
end
te = ThreadEnsemble.new c
te.add_thread(i, stdin) do |_i, _stdin|
relay _stdin, _i, stdin_timeout
_i.close rescue nil
end
te.add_thread(o, stdout) do |_o, _stdout|
relay _o, _stdout, stdout_timeout
end
te.add_thread(e, stderr) do |_o, _stderr|
relay e, _stderr, stderr_timeout
end
te.run
end
end
end
rescue
raise unless(not started and ignore_exec_failure)
end
raise SpawnError.new(cmd, status) unless
(ignore_exit_failure or (status.nil? and ignore_exec_failure) or exitstatus.include?(status.exitstatus))
status
end