From cb802d7d136c12bf0baf041679cf09fad34fd30c Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Sun, 4 May 2008 16:41:26 +0000 Subject: Allow queue durbaility to be specified independent of message durability. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@653252 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/perftest.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'cpp') diff --git a/cpp/src/tests/perftest.cpp b/cpp/src/tests/perftest.cpp index 231b25daa4..2a8a9ec17c 100644 --- a/cpp/src/tests/perftest.cpp +++ b/cpp/src/tests/perftest.cpp @@ -75,6 +75,7 @@ struct Opts : public TestOptions { // Queue policy uint32_t queueMaxCount; uint64_t queueMaxSize; + bool queueDurable; // Publisher size_t pubs; @@ -132,8 +133,9 @@ struct Opts : public TestOptions { ("iterations", optValue(iterations, "N"), "Desired number of iterations of the test.") ("summary,s", optValue(summary), "Summary output: pubs/sec subs/sec transfers/sec Mbytes/sec") - ("queue_max_count", optValue(queueMaxCount, "N"), "queue policy: count to trigger 'flow to disk'") - ("queue_max_size", optValue(queueMaxSize, "N"), "queue policy: accumulated size to trigger 'flow to disk'") + ("queue-max-count", optValue(queueMaxCount, "N"), "queue policy: count to trigger 'flow to disk'") + ("queue-max-size", optValue(queueMaxSize, "N"), "queue policy: accumulated size to trigger 'flow to disk'") + ("queue-durable", optValue(queueDurable, "N"), "Make queue durable (implied if durable set)") ("interval_sub", optValue(intervalSub, "ms"), ">=0 delay between msg consume") ("interval_pub", optValue(intervalPub, "ms"), ">=0 delay between msg publish"); @@ -226,7 +228,7 @@ struct Setup : public Client { for (size_t i = 0; i < opts.qt; ++i) { ostringstream qname; qname << "perftest" << i; - queueInit(qname.str(), opts.durable, settings); + queueInit(qname.str(), opts.durable || opts.queueDurable, settings); } } } -- cgit v1.2.1