Class: ActiveSupport::Testing::Parallelization::Server
Relationships & Source Files | |
Super Chains via Extension / Inclusion / Inheritance | |
Instance Chain:
self,
DRb::DRbUndumped
|
|
Inherits: | Object |
Defined in: | activesupport/lib/active_support/testing/parallelization/server.rb |
Class Method Summary
- .new ⇒ Server constructor
Instance Attribute Summary
- #active_workers? ⇒ Boolean readonly
Instance Method Summary
Constructor Details
.new ⇒ Server
# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 12
def initialize @queue = Queue.new @active_workers = Concurrent::Map.new @in_flight = Concurrent::Map.new end
Instance Attribute Details
#active_workers? ⇒ Boolean
(readonly)
[ GitHub ]
# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 48
def active_workers? @active_workers.size > 0 end
Instance Method Details
#<<(o)
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 28
def <<(o) o[2] = DRbObject.new(o[2]) if o @queue << o end
#interrupt
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 52
def interrupt @queue.clear end
#pop
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 33
def pop if test = @queue.pop @in_flight[[test[0].to_s, test[1]]] = test test end end
#record(reporter, result)
# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 18
def record(reporter, result) raise DRb::DRbConnError if result.is_a?(DRb::DRbUnknown) @in_flight.delete([result.klass, result.name]) reporter.synchronize do reporter.record(result) end end
#shutdown
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 56
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
#start_worker(worker_id)
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 40
def start_worker(worker_id) @active_workers[worker_id] = true end
#stop_worker(worker_id)
[ GitHub ]# File 'activesupport/lib/active_support/testing/parallelization/server.rb', line 44
def stop_worker(worker_id) @active_workers.delete(worker_id) end