class ChildLabor::Task

# File lib/child_labor.rb, line 21
def initialize(cmd)
  @cmd = cmd
  @pid = nil
  @exit_status = nil
  @terminated  = false
end

# File lib/child_labor.rb, line 122
def close
  close_read
  close_write
  close_stderr
end

# File lib/child_labor.rb, line 107
def close_read
  @stdout.close if @stdout
  @stdout = nil
end

# File lib/child_labor.rb, line 117
def close_stderr
  @stderr.close if @stderr
  @stderr = nil
end

# File lib/child_labor.rb, line 112
def close_write
  @stdin.close if @stdin
  @stdin = nil
end

# File lib/child_labor.rb, line 66
def exit_status
  poll_status
  @exit_status
end

# File lib/child_labor.rb, line 28
def launch
  create_pipes

  @pid = Process.fork

  # child
  unless @pid
    @stdout.close
    STDOUT.reopen @stdout_child

    @stdin.close
    STDIN.reopen @stdin_child

    @stderr.close
    STDERR.reopen @stderr_child

    Process.exec cmd
  end

  @stdout_child.close
  @stdin_child.close
  @stderr_child.close

  true
end

# File lib/child_labor.rb, line 54
def launched?
  @pid
end

# File lib/child_labor.rb, line 87
def read(length = nil, buffer = nil)
  @stdout.read(length, buffer)
end

# File lib/child_labor.rb, line 95
def read_stderr(length = nil, buffer = nil)
  @stderr.read(length, buffer)
end

# File lib/child_labor.rb, line 91
def readline
  @stdout.readline
end

# File lib/child_labor.rb, line 79
def resume
  signal('CONT')
end

# File lib/child_labor.rb, line 58
def running?
  poll_status(Process::WNOHANG)
end

# File lib/child_labor.rb, line 103
def signal(signal)
  Process.kill(signal, @pid)
end

# File lib/child_labor.rb, line 75
def suspend
  signal('STOP')
end

# File lib/child_labor.rb, line 83
def terminate(signal = 'TERM')
  signal(signal)
end

# File lib/child_labor.rb, line 62
def terminated?
  launched? && !running?
end

# File lib/child_labor.rb, line 71
def wait
  exit_status
end

# File lib/child_labor.rb, line 99
def write(str)
  @stdin.write(str)
end