Class: Spork::Server

Inherits:

Object

• Object
• Spork::Server

show all

Includes:

CustomIOStreams

Defined in:

lib/spork/server.rb

Overview

Instance Attribute Summary (collapse)

• - (Object) port

  Returns the value of attribute port.

• - (Object) run_strategy readonly

  Returns the value of attribute run_strategy.

Class Method Summary (collapse)

• + (Object) run(options = {})

Instance Method Summary (collapse)

• - (Object) abort
• - (Server) initialize(options = {}) constructor

  A new instance of Server.

• - (Object) listen

  Sets up signals and starts the DRb service.

• - (Object) run(argv, stderr, stdout)

  This is the public facing method that is served up by DRb.

Methods included from CustomIOStreams

included, #stderr, #stdout

14
15
16
17

# File 'lib/spork/server.rb', line 14

def initialize(options = {})
  @run_strategy = options[:run_strategy]
  @port = options[:port]
end

36
37
38

# File 'lib/spork/server.rb', line 36

def port
  @port
end

11
12
13

# File 'lib/spork/server.rb', line 11

def run_strategy
  @run_strategy
end

19
20
21

# File 'lib/spork/server.rb', line 19

def self.run(options = {})
  new(options).listen
end

53
54
55

# File 'lib/spork/server.rb', line 53

def abort
  run_strategy.abort
end

24
25
26
27
28
29
30
31
32
33
34

# File 'lib/spork/server.rb', line 24

def listen
  @run_strategy.assert_ready!
  trap("SIGINT") { sig_int_received }
  trap("SIGTERM") { abort; exit!(0) }
  trap("USR2") { abort; restart } if Signal.list.has_key?("USR2")
  @drb_service = DRb.start_service("druby://127.0.0.1:#{port}", self)
  Spork.each_run { @drb_service.stop_service } if @run_strategy.class == Spork::RunStrategy::Forking
  stderr.puts "Spork is ready and listening on #{port}!"
  stderr.flush
  DRb.thread.join
end

DRb.start_service("druby://localhost:0") # this allows Ruby to do some magical stuff so you can pass an output stream over DRb.
                                         # see http://redmine.ruby-lang.org/issues/show/496 to see why localhost:0 is used.
spec_server = DRbObject.new_with_uri("druby://127.0.0.1:8989")
spec_server.run(options.argv, $stderr, $stdout)

46
47
48
49
50
51

# File 'lib/spork/server.rb', line 46

def run(argv, stderr, stdout)
  puts "Running tests with args #{argv.inspect}..."
  result = run_strategy.run(argv, stderr, stdout)
  puts "Done.\n\n"
  result
end