Class: Spec::Distributed::MasterRunner

Inherits:
Runner::BehaviourRunner
  • Object
show all
Defined in:
lib/spec/distributed/master_runner.rb

Direct Known Subclasses

RindaMasterRunner

Instance Method Summary collapse

Constructor Details

#initialize(options, args = nil) ⇒ MasterRunner

Returns a new instance of MasterRunner.



7
8
9
10
 
# File 'lib/spec/distributed/master_runner.rb', line 7

def initialize(options, args=nil)
  super(options)
  process_args(args)
end

Instance Method Details

#process_args(args) ⇒ Object 



12
13
14
15
 
# File 'lib/spec/distributed/master_runner.rb', line 12

def process_args(args)
  @slave_urls = args.split(",")
  raise "You must pass the DRb URLs: --runner #{self.class}:druby://host1:port1,drb://host2:port2" if @slave_urls.empty?
end

#run(paths, exit_when_done) ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/spec/distributed/master_runner.rb', line 17

def run(paths, exit_when_done)
  @master_paths = paths
  @svn_rev = `svn info`.match(/Revision: (\d+)/m)[1] rescue nil
  STDERR.puts "WARNING - no local svn revision found. Your slaves may be out of sync." if @svn_rev.nil?
  super(paths, exit_when_done)
end

#run_behaviours ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/spec/distributed/master_runner.rb', line 24

def run_behaviours
  DRb.start_service
  behaviour_reports = Queue.new
  index_queue = Queue.new
  @behaviours.length.times {|index| index_queue << index}

  @threads = slave_runners.map do |slave_runner|
    Thread.new do
      slave_runner.prepare_run(@master_paths, @svn_rev)
      drb_error = nil
      while !index_queue.empty?
        begin
          i = index_queue.pop
          behaviour = @behaviours[i]
          behaviour_report = slave_runner.run_behaviour_at(i, @options.dry_run, @options.reverse, @options.timeout)
          behaviour_reports << behaviour_report
        rescue DRb::DRbConnError => e
          # Maybe the slave is down. Put the index back and die
          index_queue << i
          drb_error = e
          break
        end
      end
      
      unless drb_error
        slave_runner.report_end
        slave_runner.report_dump
      end
    end
  end

  return unless @threads.length > 0
  
  # Add a last thread for the reporter
  @threads << Thread.new do
    @behaviours.length.times do
      behaviour_reports.pop.replay(@options.reporter)
    end
  end

  @threads.each do |t| 
    t.join
  end
end

#slave_runners ⇒ Object 



69
70
71
 
# File 'lib/spec/distributed/master_runner.rb', line 69

def slave_runners
  @slave_urls.map { |slave_url| DRbObject.new_with_uri(slave_url) }
end