Sha256: 6619a2b4641d31cae0fbe94415a1afd40b0fc341b05d3d0a436ecce52037cc9e
Contents?: true
Size: 1.68 KB
Versions: 4
Compression:
Stored size: 1.68 KB
Contents
module DeepTest
module Distributed
class DispatchController
def initialize(options, receivers)
@options = options
@receivers = receivers
end
def dispatch(method_name, *args)
dispatch_with_options(method_name, {}, *args)
end
def dispatch_with_options(method_name, options, *args)
raise NoDispatchReceiversError if @receivers.empty?
@options.ui_instance.dispatch_starting(method_name)
threads = @receivers.map do |r|
Thread.new do
begin
Thread.current[:receiver] = r
r.send method_name, *args
rescue Exception => e
Thread.current[:original_exception] = e
raise
end
end
end
results = []
threads.each do |t|
begin
results << t.value
rescue Timeout::Error
@receivers.delete t[:receiver]
DeepTest.logger.error { "Timeout dispatching #{method_name} to #{description t[:receiver]}" }
rescue Exception => this_exception
@receivers.delete t[:receiver]
DeepTest.logger.error { "Exception while dispatching #{method_name} to #{description t[:receiver]}:" }
e = t[:original_exception] || this_exception
DeepTest.logger.error { "#{e.class}: #{e.message}" }
e.backtrace.each {|l| DeepTest.logger.error { l } }
end
end
results
ensure
@options.ui_instance.dispatch_finished(method_name)
end
def description(receiver)
receiver.inspect
end
end
class NoDispatchReceiversError < StandardError; end
end
end
Version data entries
4 entries across 4 versions & 2 rubygems