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