Contents

class Rubish::UnixExecutable < Rubish::Executable
  EIO = Rubish::Executable::ExecutableIO
  
  class UnixJob < Rubish::Job
    attr_reader :pids
    attr_reader :goods
    attr_reader :bads

    class BadExit < RuntimeError
      attr_reader :exitstatuses
      def initialize(exitstatuses)
        @exitstatuses = exitstatuses
      end
    end

    def initialize(exe)
      # prepare_io returns an instance of ExeIO
      @ios = EIO.ios([exe.i || Rubish::Context.current.i,"r"],
                     [exe.o || Rubish::Context.current.o,"w"],
                     [exe.err || Rubish::Context.current.err,"w"])
      i,o,err = @ios
      @pids = exe.exec_with(i.io,o.io,err.io)
      __start
    end

    def wait
      raise Rubish::Error.new("already waited") if self.done?
      begin
        exits = self.pids.map do |pid|
          Process.wait(pid)
          $?
        end
        @ios.each do |io|
          io.close
        end
        @goods, @bads = exits.partition { |status| status.exitstatus == 0}
        @result = goods # set result to processes that exit properly
        if !bads.empty?
          raise Rubish::Job::Failure.new(self,BadExit.new(bads))
        else
          return self.result
        end
      ensure
        __finish
      end
    end

    def stop(sig="TERM")
      self.pids.each do |pid|
        Process.kill(sig,pid)
      end
      self.wait
    end

    def stop!
      self.stop("KILL")
    end

  end

  def exec!
    UnixJob.new(self)
  end

  # TODO catch interrupt here
  def exec
    exec!.wait
  end

  def exec_with(i,o,e)
    raise "abstract"
  end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rubish-0.1.0	lib/rubish/unix_executable.rb
rubish-0.0.1	lib/rubish/unix_executable.rb