Method: Open4.spawn

Defined in:

lib/crazy_ivan/vendor/open4-1.0.1/lib/open4.rb

.spawn(arg, *argv) ⇒ Object

Raises:

• (SpawnError)

# File 'lib/crazy_ivan/vendor/open4-1.0.1/lib/open4.rb', line 249

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 ) ]

  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
          popen4(*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