Class: WatchedProcessGroup

Inherits:
Array
  • Object
show all
Defined in:
lib/stream2tracks/process.rb

Overview

A WatchedProcessGroup is a group of processes running in parallel, all of which can collectively be watched to indicate progress so far. It also supports visually representing progress of all processes in the group as a progress bar.

Instance Method Summary collapse

Instance Method Details

#watch(options) ⇒ Object 



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
 
# File 'lib/stream2tracks/process.rb', line 8

def watch options
  @bar=nil
  update_bar=proc do |current,total|
 # FIXME: remove hardwired 'Downloading' label
 @bar=ProgressBar.new('Downloading',total,$stderr) if total!=@old_total or @bar.nil?
 @old_total=total
 @bar.set current
  end

  all_done=false

  until all_done do
 all_done=true
 current,@old_total,total=0,0,0
 each do |_|
    begin
  status=_.watch options
    rescue RuntimeError => e
  # FIXME: @log belongs to StreamTrackRipper instance, not WatchedProcessGroup!
  # TODO: wrap in an error handler to both log and print to stderr
  @log.error e.message
  $stderr.puts "\nE: %s: %s" % [@cmd,e.message]
  delete _
    end
    if status.current
  # The reported totals may not be accurate. Rather
  # than recompute the actual total when the track
  # finishes, just accumulate the reported total
  # to improve accuracy of the progress bar.
  current+=status.eof ? status.total : status.current
  total+=status.total
    end
    all_done=false unless status.eof
 end
 update_bar[current,total] if total>0
  end

  @bar.finish if @bar
end