blob: 2a18cb569ad40f4b558ebb859f032ad8eaf0bdc2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
#!/usr/bin/env ruby
require 'spec_helper'
require 'puppet/network/server'
require 'socket'
describe Puppet::Network::Server do
describe "when using mongrel", :if => Puppet.features.mongrel? do
before :each do
Puppet[:servertype] = 'mongrel'
Puppet[:server] = '127.0.0.1'
@params = { :port => 34346, :handlers => [ :node ] }
@server = Puppet::Network::Server.new(@params)
end
after { Puppet.settings.clear }
describe "before listening" do
it "should not be reachable at the specified address and port" do
lambda { TCPSocket.new('127.0.0.1', 34346) }.should raise_error(Errno::ECONNREFUSED)
end
end
describe "when listening" do
it "should be reachable on the specified address and port" do
@server.listen
lambda { TCPSocket.new('127.0.0.1', 34346) }.should_not raise_error
end
it "should default to '127.0.0.1' as its bind address" do
@server = Puppet::Network::Server.new(@params.merge(:port => 34343))
@server.stubs(:unlisten) # we're breaking listening internally, so we have to keep it from unlistening
@server.send(:http_server).expects(:listen).with { |args| args[:address] == "127.0.0.1" }
@server.listen
end
it "should use any specified bind address" do
Puppet[:bindaddress] = "0.0.0.0"
@server = Puppet::Network::Server.new(@params.merge(:port => 34343))
@server.stubs(:unlisten) # we're breaking listening internally, so we have to keep it from unlistening
@server.send(:http_server).expects(:listen).with { |args| args[:address] == "0.0.0.0" }
@server.listen
end
it "should not allow multiple servers to listen on the same address and port" do
@server.listen
@server2 = Puppet::Network::Server.new(@params)
lambda { @server2.listen }.should raise_error
end
end
describe "after unlistening" do
it "should not be reachable on the port and address assigned" do
@server.listen
@server.unlisten
lambda { TCPSocket.new('127.0.0.1', 34346) }.should raise_error(Errno::ECONNREFUSED)
end
end
after :each do
@server.unlisten if @server.listening?
end
end
end
|
