Class: RSpec::Conductor::Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/rspec/conductor/worker.rb

Instance Method Summary collapse

Constructor Details

#initialize(worker_number:, socket:, rspec_args: [], postfork_require: :spec_helper, debug_io: nil) ⇒ Worker

Returns a new instance of Worker.



6
7
8
9
10
11
12
13
 
# File 'lib/rspec/conductor/worker.rb', line 6

def initialize(worker_number:, socket:, rspec_args: [], postfork_require: :spec_helper, debug_io: nil)
  @worker_number = worker_number
  @socket = socket
  @rspec_args = rspec_args
  @postfork_require = postfork_require
  @debug_io = debug_io
  @message_queue = []
end

Instance Method Details

#run ⇒ Object 



15
16
17
18
19
20
21
22
23
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
 
# File 'lib/rspec/conductor/worker.rb', line 15

def run
  debug "Worker #{@worker_number} starting"
  setup_signal_handlers
  setup_load_path
  require_postfork_preloads

  loop do
    debug "Waiting for message"
    message = @message_queue.shift || @socket.receive_message

    unless message
      debug "Received nil message, exiting"
      break
    end

    debug "Received: #{message.inspect}"

    case message[:type].to_sym
    when :worker_assigned_spec
      debug "Running spec: #{message[:file]}"
      run_spec(message[:file])
      debug "Finished spec: #{message[:file]}"
      break if @shutdown_requested
    when :shutdown
      debug "Shutdown received"
      @shutdown_requested = true
      break
    end
  end

  debug "Worker #{@worker_number} shutting down, running after(:suite) hooks and exiting"
  RSpec.configuration.__run_after_suite_hooks
rescue StandardError => e
  debug "Worker crashed: #{e.class}: #{e.message}"
  debug e.backtrace.join("\n")
  raise
end