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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
require 'support/config'
require 'support/test_helper'
require 'phusion_passenger/abstract_request_handler'
require 'fileutils'
include PhusionPassenger
describe AbstractRequestHandler do
before :each do
@old_passenger_tmpdir = Utils.passenger_tmpdir
Utils.passenger_tmpdir = "abstract_request_handler_spec.tmp"
@owner_pipe = IO.pipe
@request_handler = AbstractRequestHandler.new(@owner_pipe[1])
def @request_handler.process_request(*args)
# Do nothing.
end
end
after :each do
@request_handler.cleanup
@owner_pipe[0].close rescue nil
Utils.passenger_tmpdir = @old_passenger_tmpdir
FileUtils.rm_rf("abstract_request_handler_spec.tmp")
end
def prepare
# Do nothing. To be overrided by sub describe blocks.
end
it "exits if the owner pipe is closed" do
@request_handler.start_main_loop_thread
@owner_pipe[0].close
begin
Timeout.timeout(5) do
wait_until do
!@request_handler.main_loop_running?
end
end
rescue Timeout::Error
violated
end
end
it "ignores new connections that don't send any data" do
def @request_handler.accept_connection
return nil
end
@request_handler.start_main_loop_thread
wait_until do
@request_handler.iterations != 0
end
@request_handler.processed_requests.should == 0
end
it "creates a socket file in the Phusion Passenger temp folder, unless when using TCP sockets" do
if @request_handler.socket_type == "unix"
File.chmod(0700, "abstract_request_handler_spec.tmp/backends")
Dir["abstract_request_handler_spec.tmp/backends/*"].should_not be_empty
end
end
it "accepts pings" do
@request_handler.start_main_loop_thread
if @request_handler.socket_type == "unix"
client = UNIXSocket.new(@request_handler.socket_name)
else
addr, port = @request_handler.socket_name.split(/:/)
client = TCPSocket.new(addr, port.to_i)
end
begin
channel = MessageChannel.new(client)
channel.write_scalar("REQUEST_METHOD\0ping\0")
client.read.should == "pong"
ensure
client.close
end
end
def wait_until
while !yield
sleep 0.01
end
end
end
|
