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: [], verbose: false, postfork_require: :spec_helper) ⇒ Worker

Returns a new instance of Worker.



20
21
22
23
24
25
26
27
28
 
# File 'lib/rspec/conductor/worker.rb', line 20

def initialize(worker_number:, socket:, rspec_args: [], verbose: false, postfork_require: :spec_helper)
  @worker_number = worker_number
  @socket = socket
  @rspec_args = rspec_args
  @verbose = verbose
  @postfork_require = postfork_require

  @message_queue = []
end

Instance Method Details

#run ⇒ Object 



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
68
 
# File 'lib/rspec/conductor/worker.rb', line 30

def run
  suppress_output unless @verbose
  debug "Worker #{@worker_number} starting"
  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
ensure
  @socket.close
end