2 # Copyright (c) 2009 Rainbows! developers
7 # sometimes we rely on http_proxy to avoid wasting bandwidth with Isolate
8 # and multiple Ruby versions
9 NO_PROXY
=${UNICORN_TEST_ADDR-127.0.0.1}
14 # defaulting to Base would unfortunately fail some concurrency tests
16 t_info
"model undefined, defaulting to $model"
21 RUBY_VERSION
=${RUBY_VERSION-$($RUBY -e 'puts RUBY_VERSION')}
22 t_pfx
=$PWD/trash
/$model.
$T-$RUBY_ENGINE-$RUBY_VERSION
28 test -x $PWD/bin
/unused_listen || die
"must be run in 't' directory"
30 # requires $1 and prints out the value of $2
34 if ! $RUBY -r$lib -e "puts $const" >/dev
/null
2>&1
36 t_info
"skipping $T since we don't have $lib"
41 # "date +%s" is not in POSIX, but in GNU, and FreeBSD 9.0 (possibly earlier)
43 $RUBY -e 'puts Time.now.to_i'
46 # "wc -c" outputs leading whitespace on *BSDs, filter it out for portability
48 wc -c |
tr -d '[:space:]'
54 if test x
"$model" != x
"$i"
58 t_info
"skipping $T since it is not compatible with $model"
64 # given a list of variable names, create temporary files and assign
65 # the pathnames to those variables
77 T_RM_LIST
="$T_RM_LIST $_tmp"
81 T_RM_LIST
="$T_RM_LIST $_tmp"
85 T_OK_RM_LIST
="$T_OK_RM_LIST $_tmp"
95 sed -e "s/^/$id:/" < $_file
102 if grep -i Error
$_r_err
104 die
"Errors found in $_r_err"
105 elif grep SIGKILL
$_r_err
107 die
"SIGKILL found in $_r_err"
111 # rainbows_setup [ MODEL [ WORKER_CONNECTIONS ] ]
113 eval $
(unused_listen
)
114 rtmpfiles unicorn_config pid r_err r_out fifo tmp ok
115 cat > $unicorn_config <<EOF
121 after_fork do |server, worker|
122 # test script will block while reading from $fifo,
123 # so notify the script on the first worker we spawn
124 # by opening the FIFO
126 File.open("$fifo", "wb") { |fp| fp.syswrite "START" }
131 # set a higher default for tests since we run heavily-loaded
132 # boxes and sometimes sleep 1s in tests
135 echo " client_max_body_size nil"
139 test $# -ge 2 && echo " worker_connections $2"
142 echo " keepalive_timeout $3"
144 echo " keepalive_timeout $kato"
148 echo " keepalive_timeout $kato"
154 rainbows_wait_start
() {
155 # "cat $fifo" will block until the before_fork hook is called in
156 # the Unicorn config file
157 test xSTART
= x
"$(cat $fifo)"
158 rainbows_pid
=$
(cat $pid)
163 0) err_log
=$r_err status
=done ;;
164 1) err_log
=$1 status
=done ;;
165 2) err_log
=$1 status
=$2 ;;
167 while ! egrep '(done|error) reloading' < $err_log >/dev
/null
171 grep "$status reloading" $err_log >/dev
/null
180 while ! grep reaped
< $err_log >/dev
/null
187 _cmd
="$(which sha1sum 2>/dev/null || :)"
188 test -n "$_cmd" || _cmd
="$(which openssl 2>/dev/null || :) sha1"
189 test "$_cmd" != " sha1" || _cmd
="$(which gsha1sum 2>/dev/null || :)"
191 # last resort, see comments in sha1sum.rb for reasoning
192 test -n "$_cmd" || _cmd
=sha1sum.rb
193 expr "$($_cmd)" : '\([a-f0-9]\{40\}\)'
196 req_curl_chunked_upload_err_check
() {
198 curl
--version 2>/dev
/null |
awk '$1 == "curl" {
200 if ((v[1] < 7) || (v[1] == 7 && v[2] < 18))
206 t_info
"curl >= 7.18.0 required for $T"
215 t_info
"skipping $T since it's not Linux"
220 # we only allow splice on 2.6.32+
221 min
=32 uname_r
=$
(uname
-r)
224 sub
=$
(expr "$uname_r" : '2\.6\.\(.*\)$')
225 if test $sub -lt $min
227 t_info
"skipping $T (Linux $(uname_r < 2.6.$min)"
235 t_info
"skipping $T (Linux $uname_r < 2.6.$min)"
241 check_threaded_app_dispatch
() {
243 ThreadSpawn|ThreadPool
) ;;
244 RevThreadSpawn|RevThreadPool
) ;;
245 CoolioThreadSpawn|CoolioThreadPool
) ;;
246 XEpollThreadSpawn|XEpollThreadPool
) ;;
248 t_info
"$0 is only compatible with threaded app dispatch"
253 check_copy_stream
() {
254 case $RUBY_VERSION in
257 t_info
"skipping $T since it can't IO.copy_stream"
263 ThreadSpawn|WriterThreadSpawn|ThreadPool|WriterThreadPool|Base
) ;;
264 XEpollThreadSpawn|XEpollThreadPool
) ;;
266 t_info
"skipping $T since it doesn't use copy_stream"
273 Rev
) require_check
rev Rev
::VERSION
;;
274 Coolio
) require_check coolio Coolio
::VERSION
;;
275 Revactor
) require_check revactor Revactor
::VERSION
;;
276 EventMachine
) require_check eventmachine EventMachine
::VERSION
;;