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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
| | #!/bin/sh
. ./test-lib.sh
skip_models StreamResponseEpoll
t_plan 25 "simple HTTP connection keepalive/pipelining tests for $model"
t_begin "checking for config.ru for $model" && {
tbase=simple-http_$model.ru
test -f "$tbase"
}
t_begin "setup and start" && {
rainbows_setup
rainbows -D $tbase -c $unicorn_config
rainbows_wait_start
}
t_begin "pid file exists" && {
test -f $pid
}
t_begin "single request" && {
curl -sSfv http://$listen/
}
t_begin "handles client EOF gracefully" && {
printf 'GET / HTTP/1.1\r\nHost: example.com\r\n\r\n' | \
socat - TCP4:$listen > $tmp
dbgcat tmp
if grep 'HTTP.* 500' $tmp
then
die "500 error returned on client shutdown(SHUT_WR)"
fi
check_stderr
}
dbgcat r_err
t_begin "two requests with keepalive" && {
curl -sSfv http://$listen/a http://$listen/b > $tmp 2>&1
}
dbgcat r_err
dbgcat tmp
t_begin "reused existing connection" && {
grep 'Re-using existing connection' < $tmp
}
t_begin "pipelining partial requests" && {
req='GET / HTTP/1.1\r\nHost: example.com\r\n'
(
cat $fifo > $tmp &
printf "$req"'\r\n'"$req"
sleep 1
printf 'Connection: close\r\n\r\n'
wait
echo ok > $ok
) | socat - TCP:$listen > $fifo
}
dbgcat tmp
t_begin "two HTTP/1.1 responses" && {
test 2 -eq $(grep '^HTTP/1.1' $tmp | count_lines)
}
t_begin "two HTTP/1.1 200 OK responses" && {
test 2 -eq $(grep '^HTTP/1.1 200 OK' $tmp | count_lines)
}
t_begin 'one "Connection: keep-alive" response' && {
test 1 -eq $(grep '^Connection: keep-alive' $tmp | count_lines)
}
t_begin 'one "Connection: close" response' && {
test 1 -eq $(grep '^Connection: close' $tmp | count_lines)
}
t_begin 'check subshell success' && {
test x"$(cat $ok)" = xok
}
t_begin "check stderr" && {
check_stderr
}
t_begin "burst pipelining requests" && {
req='GET / HTTP/1.1\r\nHost: example.com\r\n'
(
cat $fifo > $tmp &
printf "$req"'\r\n'"$req"'Connection: close\r\n\r\n'
wait
echo ok > $ok
) | socat - TCP:$listen > $fifo
}
dbgcat tmp
dbgcat r_err
t_begin "got 2 HTTP/1.1 responses from pipelining" && {
test 2 -eq $(grep '^HTTP/1.1' $tmp | count_lines)
}
t_begin "got 2 HTTP/1.1 200 OK responses" && {
test 2 -eq $(grep '^HTTP/1.1 200 OK' $tmp | count_lines)
}
t_begin "one keepalive connection" && {
test 1 -eq $(grep '^Connection: keep-alive' $tmp | count_lines)
}
t_begin "second request closes connection" && {
test 1 -eq $(grep '^Connection: close' $tmp | count_lines)
}
t_begin "subshell exited correctly" && {
test x"$(cat $ok)" = xok
}
t_begin "stderr log has no errors" && {
check_stderr
}
t_begin "HTTP/0.9 request should not return headers" && {
(
printf 'GET /\r\n'
cat $fifo > $tmp &
wait
echo ok > $ok
) | socat - TCP:$listen > $fifo
}
dbgcat tmp
dbgcat r_err
t_begin "env.inspect should've put everything on one line" && {
test 1 -eq $(count_lines < $tmp)
}
t_begin "no headers in output" && {
if grep ^Connection: $tmp
then
die "Connection header found in $tmp"
elif grep ^HTTP/ $tmp
then
die "HTTP/ found in $tmp"
fi
}
t_begin "killing succeeds" && {
kill $rainbows_pid
}
t_done
|