Methods
- #
- A
- I
- N
- P
- R
- S
Included Modules
- DRb::DRbUndumped
Class Public methods
new() Link
Instance Public methods
<<(o) Link
active_workers?() Link
interrupt() Link
pop() Link
record(reporter, result) Link
# File activesupport/lib/active_support/testing/parallelization/server.rb, line 21 def record(reporter, result) raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown) @in_flight.delete([result.klass, result.name]) reporter.synchronize do reporter.prerecord(PrerecordResultClass.new(result.klass), result.name) reporter.record(result) end end
remove_dead_workers(dead_pids) Link
# File activesupport/lib/active_support/testing/parallelization/server.rb, line 54 def remove_dead_workers(dead_pids) dead_pids.each do |dead_pid| worker_id = @worker_pids.key(dead_pid) if worker_id @active_workers.delete(worker_id) @worker_pids.delete(worker_id) end end end
shutdown() Link
# File activesupport/lib/active_support/testing/parallelization/server.rb, line 72 def shutdown # Wait for initial queue to drain while @queue.length != 0 sleep 0.1 end @queue.close # Wait until all workers have finished while active_workers? sleep 0.1 end @in_flight.values.each do |(klass, name, reporter)| result = Minitest::Result.from(klass.new(name)) error = RuntimeError.new("result not reported") error.set_backtrace([""]) result.failures << Minitest::UnexpectedError.new(error) reporter.synchronize do reporter.record(result) end end end