svn commit: r653252 - /incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp

[gsim]

Author: gsim
Date: Sun May  4 09:41:26 2008
New Revision: 653252

URL: http://svn.apache.org/viewvc?rev=653252&view=rev
Log:
Allow queue durbaility to be specified independent of message durability.


Modified:
    incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp?rev=653252&r1=653251&r2=653252&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp Sun May  4 09:41:26 
2008
@@ -75,6 +75,7 @@
     // Queue policy
     uint32_t queueMaxCount;
     uint64_t queueMaxSize;
+    bool queueDurable;
 
     // Publisher
     size_t pubs;
@@ -132,8 +133,9 @@
             ("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 @@
             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); 
             }
         }
     }