summaryrefslogtreecommitdiff
path: root/cpp/src/tests/qpid-cluster-benchmark
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/tests/qpid-cluster-benchmark')
-rwxr-xr-xcpp/src/tests/qpid-cluster-benchmark14
1 files changed, 9 insertions, 5 deletions
diff --git a/cpp/src/tests/qpid-cluster-benchmark b/cpp/src/tests/qpid-cluster-benchmark
index a5076799f6..d836ed709c 100755
--- a/cpp/src/tests/qpid-cluster-benchmark
+++ b/cpp/src/tests/qpid-cluster-benchmark
@@ -30,7 +30,7 @@ RECEIVERS="-r 3"
BROKERS= # Local broker
CLIENT_HOSTS= # No ssh, all clients are local
-while getopts "m:f:n:b:q:s:r:c:txy" opt; do
+while getopts "m:f:n:b:q:s:r:c:txyv-" opt; do
case $opt in
m) MESSAGES="-m $OPTARG";;
f) FLOW="--flow-control $OPTARG";;
@@ -43,13 +43,17 @@ while getopts "m:f:n:b:q:s:r:c:txy" opt; do
t) TCP_NODELAY="--connection-options {tcp-nodelay:true}";;
x) SAVE_RECEIVED="--save-received";;
y) NO_DELETE="--no-delete";;
+ v) OPTS="--verbose";;
+ -) break ;;
*) echo "Unknown option"; exit 1;;
esac
done
+shift $(($OPTIND-1))
+
+REPLICATE="node:{x-declare:{arguments:{'qpid.replicate':all}}}"
BROKER=$(echo $BROKERS | sed s/,.*//)
run_test() { echo $*; shift; "$@"; echo; echo; echo; }
-OPTS="$REPEAT $BROKERS --summarize $QUEUES $SENDERS $RECEIVERS $MESSAGES $CLIENT_HOSTS $SAVE_RECEIVED $TCP_NODELAY $NO_DELETE"
-run_test "Queue contention:" qpid-cpp-benchmark $OPTS
-run_test "No queue contention: :" qpid-cpp-benchmark $OPTS --group-receivers
-
+OPTS="$OPTS $REPEAT $BROKERS --summarize $QUEUES $SENDERS $RECEIVERS $MESSAGES $CLIENT_HOSTS $SAVE_RECEIVED $TCP_NODELAY $NO_DELETE"
+OPTS="$OPTS --create-option $REPLICATE"
+run_test "Benchmark:" qpid-cpp-benchmark $OPTS "$@"