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
| | #!/bin/sh
. ./test-lib.sh
STRACE=$(which strace 2>/dev/null || :)
if ! test -x "$STRACE"
then
t_info "strace not found, skipping $T"
exit 0
fi
if test x"$(uname -s)" != xLinux
then
t_info "Linux is the only supported OS for $T"
exit 0
fi
# these buffer internally in external libraries, so we can't detect when
# to use TCP_CORK
skip_models EventMachine NeverBlock
skip_models StreamResponseEpoll
skip_models Coolio CoolioThreadPool CoolioThreadSpawn
skip_models Revactor Rev RevThreadPool RevThreadSpawn
# not sure why, but we don't have time to care about Ruby 1.8 too much
case $RUBY_VERSION in
1.8.*) skip_models WriterThreadSpawn WriterThreadPool ;;
esac
t_plan 13 "Kgio autopush tests"
start_strace () {
# dbgcat strace_out
> $strace_out
sleep 1
strace -p $worker_pid -e '!futex' -f -o $strace_out &
strace_pid=$!
while ! test -s $strace_out; do sleep 1; done
}
check_TCP_CORK () {
nr=0
while test 2 -gt $(grep TCP_CORK $strace_out | count_lines)
do
nr=$(( $nr + 1 ))
if test $nr -gt 30
then
dbgcat strace_out
die "waited too long ($nr seconds) for TCP_CORK"
fi
sleep 1
done
test 2 -eq $(grep TCP_CORK $strace_out | count_lines)
fgrep 'SOL_TCP, TCP_CORK, [0],' $strace_out
fgrep 'SOL_TCP, TCP_CORK, [1],' $strace_out
}
t_begin "setup and start" && {
rainbows_setup $model 1 1
rtmpfiles strace_out
ed -s $unicorn_config <<EOF
,s/^listen.*/listen "$listen", :tcp_nodelay => true, :tcp_nopush => true/
w
EOF
rainbows -D large-file-response.ru -c $unicorn_config -E none
rainbows_wait_start
}
t_begin "read worker pid" && {
worker_pid=$(curl -sSf http://$listen/pid)
kill -0 $worker_pid
}
t_begin "start strace on worker" && start_strace
t_begin "reading RSS uncorks" && {
curl -sSf http://$listen/rss >/dev/null
}
t_begin "restart strace on worker" && {
kill $strace_pid
wait
start_strace
}
t_begin "reading static file uncorks" && {
curl -sSf http://$listen/random_blob >/dev/null
check_TCP_CORK
}
t_begin "stop strace on worker" && {
kill $strace_pid
wait
}
t_begin "enable sendfile" && {
echo >> $unicorn_config 'require "sendfile"'
kill -HUP $rainbows_pid
test xSTART = x"$(cat $fifo)"
}
t_begin "reread worker pid" && {
worker_pid=$(curl -sSf http://$listen/pid)
kill -0 $worker_pid
}
t_begin "restart strace on the worker" && start_strace
t_begin "HTTP/1.x GET on static file with sendfile uncorks" && {
curl -sSf http://$listen/random_blob >/dev/null
check_TCP_CORK
}
t_begin "killing succeeds" && {
kill $strace_pid
wait
# dbgcat strace_out
kill $rainbows_pid
}
t_begin "check stderr" && check_stderr
t_done
|