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
155
| | #!/bin/sh
# Copyright (c) 2009 Rainbows! developers
. ./my-tap-lib.sh
set +u
if test -z "$model"
then
# defaulting to Base would unfortunately fail some concurrency tests
model=ThreadSpawn
t_info "model undefined, defaulting to $model"
fi
set -e
RUBY="${RUBY-ruby}"
RUBY_VERSION=${RUBY_VERSION-$($RUBY -e 'puts RUBY_VERSION')}
t_pfx=$PWD/trash/$model.$T-$RUBY_VERSION
set -u
PATH=$PWD/bin:$PATH
export PATH
test -x $PWD/bin/unused_listen || die "must be run in 't' directory"
wait_for_pid () {
path="$1"
nr=30
while ! test -s "$path" && test $nr -gt 0
do
nr=$(($nr - 1))
sleep 1
done
}
# requires $1 and prints out the value of $2
require_check () {
lib=$1
const=$2
if ! $RUBY -r$lib -e "puts $const" >/dev/null 2>&1
then
t_info "skipping $T since we don't have $lib"
exit 0
fi
}
# given a list of variable names, create temporary files and assign
# the pathnames to those variables
rtmpfiles () {
for id in "$@"
do
name=$id
_tmp=$t_pfx.$id
eval "$id=$_tmp"
case $name in
*fifo)
rm -f $_tmp
mkfifo $_tmp
T_RM_LIST="$T_RM_LIST $_tmp"
;;
*socket)
rm -f $_tmp
T_RM_LIST="$T_RM_LIST $_tmp"
;;
*)
> $_tmp
T_OK_RM_LIST="$T_OK_RM_LIST $_tmp"
;;
esac
done
}
dbgcat () {
id=$1
eval '_file=$'$id
echo "==> $id <=="
sed -e "s/^/$id:/" < $_file
}
check_stderr () {
set +u
_r_err=${1-${r_err}}
set -u
if grep -i Error $_r_err
then
die "Errors found in $_r_err"
elif grep SIGKILL $_r_err
then
die "SIGKILL found in $_r_err"
fi
}
# rainbows_setup [ MODEL [ WORKER_CONNECTIONS ] ]
rainbows_setup () {
eval $(unused_listen)
rtmpfiles unicorn_config pid r_err r_out fifo tmp ok
cat > $unicorn_config <<EOF
listen "$listen"
pid "$pid"
stderr_path "$r_err"
stdout_path "$r_out"
after_fork do |server, worker|
# test script will block while reading from $fifo,
# so notify the script on the first worker we spawn
# by opening the FIFO
if worker.nr == 0
File.open("$fifo", "wb") { |fp| fp.syswrite "START" }
end
end
EOF
{
# set a higher default for tests since we run heavily-loaded
# boxes and sometimes sleep 1s in tests
kato=5
echo 'Rainbows! do'
if test $# -ge 1
then
echo " use :$1"
test $# -eq 2 && echo " worker_connections $2"
if test $# -eq 3
then
echo " keepalive_timeout $3"
else
echo " keepalive_timeout $kato"
fi
else
echo " use :$model"
echo " keepalive_timeout $kato"
fi
echo end
} >> $unicorn_config
}
rainbows_wait_start () {
# "cat $fifo" will block until the before_fork hook is called in
# the Unicorn config file
test xSTART = x"$(cat $fifo)"
rainbows_pid=$(cat $pid)
}
rsha1 () {
_cmd="$(which sha1sum 2>/dev/null || :)"
test -n "$_cmd" || _cmd="$(which openssl 2>/dev/null || :) sha1"
test "$_cmd" != " sha1" || _cmd="$(which gsha1sum 2>/dev/null || :)"
# last resort, see comments in sha1sum.rb for reasoning
test -n "$_cmd" || _cmd=sha1sum.rb
expr "$($_cmd < random_blob)" : '\([a-f0-9]\{40\}\)'
}
case $model in
Rev) require_check rev Rev::VERSION ;;
Revactor) require_check revactor Revactor::VERSION ;;
EventMachine) require_check eventmachine EventMachine::VERSION ;;
esac
|