You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Frantisek Reznicek (JIRA)" <qp...@incubator.apache.org> on 2009/08/17 11:06:14 UTC
[jira] Created: (QPID-2053) perftest users might benefit from
having possibility to specify the queue name
perftest users might benefit from having possibility to specify the queue name
------------------------------------------------------------------------------
Key: QPID-2053
URL: https://issues.apache.org/jira/browse/QPID-2053
Project: Qpid
Issue Type: Improvement
Components: Tools
Affects Versions: M4, M3
Environment: qpid, perftest tool
Reporter: Frantisek Reznicek
Priority: Trivial
Current version of perftest does not allow queue name specification. It would be beneficial to have this possibility, especially for testing purposes.
This patch works well for me (qpid project checkout rev 787816 qpid/cpp/src/tests/perftest.cpp)
*** qpid_cpp_tests/perftest.cpp 2009-06-11 11:52:26.000000000 +0200
--- qpid_cpp_tests/perftest.cpp.new 2009-06-01 11:36:14.000000000 +0200
***************
*** 74,79 ****
--- 74,80 ----
// Queue policy
uint32_t queueMaxCount;
uint64_t queueMaxSize;
+ string queueName;
bool queueDurable;
// Publisher
***************
*** 110,115 ****
--- 111,117 ----
pubs(1), count(500000), size(1024), confirm(true), durable(false), uniqueData(false), syncPub(false),
subs(1), ack(0),
qt(1),singleConnect(false), iterations(1), mode(SHARED), summary(false),
+ queueName("perftest"),
intervalSub(0), intervalPub(0), tx(0), txPub(0), txSub(0), commitAsync(false)
{
addOptions()
***************
*** 141,146 ****
--- 143,149 ----
("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-name", optValue(queueName, "QUEUE-NAME"), "queue name used by perftest program")
("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)")
***************
*** 267,273 ****
settings.setInt("qpid.max_size", opts.queueMaxSize);
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream qname;
! qname << "perftest" << i;
queueInit(qname.str(), opts.durable || opts.queueDurable, settings);
}
}
--- 270,277 ----
settings.setInt("qpid.max_size", opts.queueMaxSize);
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream qname;
! //qname << "perftest" << i;
! qname << opts.queueName << i;
queueInit(qname.str(), opts.durable || opts.queueDurable, settings);
}
}
***************
*** 679,685 ****
// Start pubs/subs for each queue/topic.
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream key;
! key << "perftest" << i; // Queue or topic name.
if (opts.publish) {
size_t n = singleProcess ? opts.pubs : 1;
for (size_t j = 0; j < n; ++j) {
--- 683,690 ----
// Start pubs/subs for each queue/topic.
for (size_t i = 0; i < opts.qt; ++i) {
ostringstream key;
! //key << "perftest" << i; // Queue or topic name.
! key << opts.queueName << i; // Queue or topic name.
if (opts.publish) {
size_t n = singleProcess ? opts.pubs : 1;
for (size_t j = 0; j < n; ++j) {
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] Resolved: (QPID-2053) perftest users might benefit from
having possibility to specify the queue name
Posted by "Gordon Sim (JIRA)" <qp...@incubator.apache.org>.
[ https://issues.apache.org/jira/browse/QPID-2053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gordon Sim resolved QPID-2053.
------------------------------
Resolution: Fixed
Implemented as r805404.
> perftest users might benefit from having possibility to specify the queue name
> ------------------------------------------------------------------------------
>
> Key: QPID-2053
> URL: https://issues.apache.org/jira/browse/QPID-2053
> Project: Qpid
> Issue Type: Improvement
> Components: Tools
> Affects Versions: M3, M4
> Environment: qpid, perftest tool
> Reporter: Frantisek Reznicek
> Priority: Trivial
> Original Estimate: 1h
> Remaining Estimate: 1h
>
> Current version of perftest does not allow queue name specification. It would be beneficial to have this possibility, especially for testing purposes.
> This patch works well for me (qpid project checkout rev 787816 qpid/cpp/src/tests/perftest.cpp)
> *** qpid_cpp_tests/perftest.cpp 2009-06-11 11:52:26.000000000 +0200
> --- qpid_cpp_tests/perftest.cpp.new 2009-06-01 11:36:14.000000000 +0200
> ***************
> *** 74,79 ****
> --- 74,80 ----
> // Queue policy
> uint32_t queueMaxCount;
> uint64_t queueMaxSize;
> + string queueName;
> bool queueDurable;
>
> // Publisher
> ***************
> *** 110,115 ****
> --- 111,117 ----
> pubs(1), count(500000), size(1024), confirm(true), durable(false), uniqueData(false), syncPub(false),
> subs(1), ack(0),
> qt(1),singleConnect(false), iterations(1), mode(SHARED), summary(false),
> + queueName("perftest"),
> intervalSub(0), intervalPub(0), tx(0), txPub(0), txSub(0), commitAsync(false)
> {
> addOptions()
> ***************
> *** 141,146 ****
> --- 143,149 ----
> ("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-name", optValue(queueName, "QUEUE-NAME"), "queue name used by perftest program")
> ("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)")
> ***************
> *** 267,273 ****
> settings.setInt("qpid.max_size", opts.queueMaxSize);
> for (size_t i = 0; i < opts.qt; ++i) {
> ostringstream qname;
> ! qname << "perftest" << i;
> queueInit(qname.str(), opts.durable || opts.queueDurable, settings);
> }
> }
> --- 270,277 ----
> settings.setInt("qpid.max_size", opts.queueMaxSize);
> for (size_t i = 0; i < opts.qt; ++i) {
> ostringstream qname;
> ! //qname << "perftest" << i;
> ! qname << opts.queueName << i;
> queueInit(qname.str(), opts.durable || opts.queueDurable, settings);
> }
> }
> ***************
> *** 679,685 ****
> // Start pubs/subs for each queue/topic.
> for (size_t i = 0; i < opts.qt; ++i) {
> ostringstream key;
> ! key << "perftest" << i; // Queue or topic name.
> if (opts.publish) {
> size_t n = singleProcess ? opts.pubs : 1;
> for (size_t j = 0; j < n; ++j) {
> --- 683,690 ----
> // Start pubs/subs for each queue/topic.
> for (size_t i = 0; i < opts.qt; ++i) {
> ostringstream key;
> ! //key << "perftest" << i; // Queue or topic name.
> ! key << opts.queueName << i; // Queue or topic name.
> if (opts.publish) {
> size_t n = singleProcess ? opts.pubs : 1;
> for (size_t j = 0; j < n; ++j) {
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org