Class: TestQueue::Runner::Sample
Instance Attribute Summary
#concurrency, #exit_when_done, #stats
Instance Method Summary
collapse
#abort, #after_fork_internal, #around_filter, #awaiting_suites?, #cleanup_worker, #connect_to_relay, #discover_suites, #distribute_queue, #enqueue_discovered_suite, #execute, #execute_internal, #initialize, #kill_subprocesses, #kill_suite_discovery_process, #kill_workers, #prepare, #queue_status, #reap_suite_discovery_process, #reap_workers, #relay?, #relay_to_master, #start_master, #start_relay, #stats_file, #stop_master, #summarize, #summarize_internal, #worker_completed
Instance Method Details
#after_fork(num) ⇒ Object
12
13
14
15
|
# File 'lib/test_queue/runner/sample.rb', line 12
def after_fork(num)
puts " -- worker #{num} booted as pid #{$$}"
super
end
|
#run_worker(iterator) ⇒ Object
17
18
19
20
21
22
23
24
|
# 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 ⇒ Object
7
8
9
10
|
# File 'lib/test_queue/runner/sample.rb', line 7
def spawn_workers
puts "Spawning #@concurrency workers"
super
end
|
#summarize_worker(worker) ⇒ Object
26
27
28
29
|
# File 'lib/test_queue/runner/sample.rb', line 26
def summarize_worker(worker)
worker.summary = worker.output.scan(/^\s*(\d+)/).join(', ')
worker.failure_output = ''
end
|