# File lib/spork/run_strategy/magazine.rb, line 72 def self.available? true end
# File lib/spork/run_strategy/magazine.rb, line 28 def initialize(test_framework) @test_framework = test_framework this_path = File.expand_path(File.dirname(__FILE__)) @path = File.join(this_path, 'magazine') @pids = [] @pids << start_Rinda_ringserver sleep 1 fill_slave_pool rescue RuntimeError => e kill_all_processes raise e end
# File lib/spork/run_strategy/magazine.rb, line 116 def abort kill_all_processes end
# File lib/spork/run_strategy/magazine.rb, line 48 def fill_slave_pool Slave_Id_Range.each do |id| start_slave(id) end puts " -- Starting to fill pool..." puts " Wait until at least one slave is provided before running tests..." puts " ** CTRL+BREAK to stop Spork and kill all ruby slave processes **" $stdout.flush end
# File lib/spork/run_strategy/magazine.rb, line 103 def kill_all_processes @pids.each {|pid| Process.kill(9, pid)} puts "\nKilling processes."; $stdout.flush end
# File lib/spork/run_strategy/magazine.rb, line 120 def preload true # @test_framework.preload end
# File lib/spork/run_strategy/magazine.rb, line 97 def restart_slave(id) pid = @pids[id] Process.kill(9, pid) start_slave(id) end
# File lib/spork/run_strategy/magazine.rb, line 76 def run(argv, stderr, stdout) DRb.start_service ts = Rinda::RingFinger.primary if ts.read_all([:name, :MagazineSlave, nil, nil]).size > 0 print ' <-- take tuple'; stdout.flush tuple = ts.take([:name, :MagazineSlave, nil, nil]) slave = tuple[2] id = tuple[3] puts "(#{slave.id_num}); slave.run..."; $stdout.flush begin slave.run(argv,stderr,stdout) puts " -- (#{slave.id_num});run done"; $stdout.flush ensure restart_slave(id) end else puts '- NO tuple'; $stdout.flush end end
# File lib/spork/run_strategy/magazine.rb, line 125 def running? @running end
# File lib/spork/run_strategy/magazine.rb, line 109 def slave_count DRb.start_service ts = Rinda::RingFinger.primary ts.read_all([:name, :MagazineSlave, nil, nil]).size end
# File lib/spork/run_strategy/magazine.rb, line 24 def slave_max Slave_Id_Range.to_a.size end
# File lib/spork/run_strategy/magazine.rb, line 64 def spawn_process(app) if RUBY_VERSION < '1.9.1' Process.create( :app_name => app, :cwd => @path ).process_id else Process.spawn( app, :chdir => @path ) end end
Generated with the Darkfish Rdoc Generator 2.