Sha256: 190c18b8d7ec0a40e6eaad21ce1a89dd410bca6e098181d7ad1748d984687eb3
Contents?: true
Size: 1.84 KB
Versions: 11
Compression:
Stored size: 1.84 KB
Contents
module DeepTest
module Distributed
class RemoteWorkerClient
def initialize(options, test_server, failover_workers)
@failover_workers = failover_workers
@options = options
@test_server = test_server
end
def load_files(filelist)
@options.new_listener_list.before_sync
t = Thread.new do
@test_server.sync(@options)
@worker_server = @test_server.spawn_worker_server(@options)
@worker_server.slaves.each do |s|
DeepTest.logger.debug "Startng the DRb service to connect to: #{s.inspect}"
DRb.start_service(s.__drburi, nil, DRbFire::ROLE => DRbFire::CLIENT)
end
@worker_server.load_files filelist
end
filelist.each {|f| load f}
begin
t.join
rescue => e
# The failover here doesn't invoke load_files on the failover_workers
# because they will be LocalWorkers, which fork from the current
# process. The fact that we depend in this here is damp...
#
fail_over("load_files", e)
end
end
def start_all(drbserver)
@worker_server.slaves.each do |s|
DeepTest.logger.debug "Remote worker client start_all sending Server reference to RemoteWorkerServer: #{s.inspect}"
s.drbserver = drbserver
end
@worker_server.start_all
rescue => e
raise if failed_over?
fail_over("start_all", e)
retry
end
def stop_all
@worker_server.stop_all
end
def fail_over(method, exception)
@options.ui_instance.distributed_failover_to_local(method, exception)
@worker_server = @failover_workers
end
def failed_over?
@worker_server == @failover_workers
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems