Class: Excon::Test::Server

Inherits:
Object
  • Object
show all
Defined in:
lib/excon/test/server.rb

Constant Summary collapse

INSTANCE_REQUIRES =

Methods that must be implemented by a plugin

[:start]

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(args) ⇒ Server



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
# File 'lib/excon/test/server.rb', line 22

def initialize(args)
  # TODO: Validate these args
  @server = args.keys.first
  @app = args[server]
  args[:bind] ||= 'tcp://127.0.0.1:9292'
  @bind = URI.parse(args[:bind])
  @is_unix_socket = (@bind.scheme == 'unix')
  @bind.host = @bind.host.gsub(/[\[\]]/, '') unless @is_unix_socket
  if args[:timeout]
    @timeout = args[:timeout]
  else
    @timeout = 20
  end
  name = @server.to_s.split('_').collect(&:capitalize).join
  plug = nested_const_get("Excon::Test::Plugin::Server::#{name}")
  self.extend plug
  check_implementation(plug)
end

Instance Attribute Details

#appObject

Returns the value of attribute app



12
13
14
# File 'lib/excon/test/server.rb', line 12

def app
  @app
end

#bindObject

Returns the value of attribute bind



12
13
14
# File 'lib/excon/test/server.rb', line 12

def bind
  @bind
end

#errorObject

Returns the value of attribute error



12
13
14
# File 'lib/excon/test/server.rb', line 12

def error
  @error
end

#pidObject

Returns the value of attribute pid



12
13
14
# File 'lib/excon/test/server.rb', line 12

def pid
  @pid
end

#readObject

Returns the value of attribute read



12
13
14
# File 'lib/excon/test/server.rb', line 12

def read
  @read
end

#serverObject

Returns the value of attribute server



12
13
14
# File 'lib/excon/test/server.rb', line 12

def server
  @server
end

#started_atObject

Returns the value of attribute started_at



12
13
14
# File 'lib/excon/test/server.rb', line 12

def started_at
  @started_at
end

#timeoutObject

Returns the value of attribute timeout



12
13
14
# File 'lib/excon/test/server.rb', line 12

def timeout
  @timeout
end

#writeObject

Returns the value of attribute write



12
13
14
# File 'lib/excon/test/server.rb', line 12

def write
  @write
end

Instance Method Details

#dump_errorsObject



73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
# File 'lib/excon/test/server.rb', line 73

def dump_errors
  lines = error.read.split($/)
  while line = lines.shift
    case line
      when /(ERROR|Error)/
        unless line =~ /(null cert chain|did not return a certificate|SSL_read:: internal error)/
          in_err = true
          puts
        end
      when /^(127|localhost)/
        in_err = false
      end
    puts line if in_err
  end
end

#elapsed_timeObject



51
52
53
# File 'lib/excon/test/server.rb', line 51

def elapsed_time
  Time.now - started_at
end

#open_process(*args) ⇒ Object



41
42
43
44
45
46
47
48
49
# File 'lib/excon/test/server.rb', line 41

def open_process(*args)
  if RUBY_PLATFORM == 'java'
    @pid, @write, @read, @error = IO.popen4(*args)
  else
    GC.disable if RUBY_VERSION < '1.9'
    @pid, @write, @read, @error = Open4.popen4(*args)
  end
  @started_at = Time.now
end

#stopObject



55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
# File 'lib/excon/test/server.rb', line 55

def stop
  if RUBY_PLATFORM == 'java'
    Process.kill('USR1', pid)
  else
    Process.kill(9, pid)
    GC.enable if RUBY_VERSION < '1.9'
    Process.wait(pid)
  end

  if @is_unix_socket
    socket = @bind.path
    File.delete(socket) if File.exist?(socket)
  end

  # TODO: Ensure process is really dead
  dump_errors
  true
end