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
|
#!/bin/bash
# Simple script to time running the examples in various languages.
# Should be run in the build directory.
# Use command line to run different combinations.
# For example to run C broker, Go sender and C++ receiver pass arguments: C GO CPP
MESSAGES=100000
BLD=$(pwd)
C=$BLD/c/examples
C_BROKER="$C/broker"
C_SEND="$C/send localhost amqp x $MESSAGES"
C_RECV="$C/receive localhost amqp x $MESSAGES"
GO=$BLD/go/examples/electron
GO_BROKER="$GO/broker"
GO_SEND="$GO/send -count $MESSAGES /x"
GO_RECV="$GO/receive -count $MESSAGES -prefetch 100 /x"
CPP=$BLD/cpp/examples
CPP_BROKER="$CPP/broker"
CPP_SEND="$CPP/simple_send -a /x -m $MESSAGES"
CPP_RECV="$CPP/simple_recv -a /x -m $MESSAGES"
amqp_busy() { ss -tlp | grep $* amqp; }
start_broker() {
amqp_busy && { "amqp port busy"; exit 1; }
"$@" & BROKER_PID=$!
until amqp_busy -q; do sleep .1; done
}
stop_broker() {
kill $BROKER_PID
wait $BROKER_PID 2> /dev/null
}
run() {
echo
echo "run: $*"
BROKER=${!1}
SEND=${!2}
RECV=${!3}
start_broker $BROKER
time {
$RECV > /dev/null& RECV_PID=$!
$SEND
wait $RECV_PID
}
stop_broker
}
if test -z "$*"; then
# By default run the broker/sender/receiver combo for each language
run C_BROKER C_SEND C_RECV
run GO_BROKER GO_SEND GO_RECV
run CPP_BROKER CPP_SEND CPP_RECV
else
while test -n "$*"; do
run ${1}_BROKER ${2}_SEND ${3}_RECV
shift; shift; shift
done
fi
|
