class TestQueue::Runner::Sample

Public Instance Methods

after_fork(num) click to toggle source
Calls superclass method TestQueue::Runner#after_fork
# File lib/test_queue/runner/sample.rb, line 12
def after_fork(num)
  puts "  -- worker #{num} booted as pid #{$$}"
  super
end
run_worker(iterator) click to toggle source
# File lib/test_queue/runner/sample.rb, line 17
def run_worker(iterator)
  sum = 0
  iterator.each do |item|
    puts "  #{item.inspect}"
    sum += item
  end
  sum
end
spawn_workers() click to toggle source
Calls superclass method TestQueue::Runner#spawn_workers
# File lib/test_queue/runner/sample.rb, line 7
def spawn_workers
  puts "Spawning #@concurrency workers"
  super
end
summarize_worker(worker) click to toggle source
# File lib/test_queue/runner/sample.rb, line 26
def summarize_worker(worker)
  stats.update(worker.stats)

  worker.summary  = worker.output.scan(/^\s*(\d+)/).join(', ')
  worker.failure_output = ''
end