[QPID-2053] perftest users might benefit from having possibility to specify the queue name

• Type: Improvement
• Status: Closed
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: M3, M4
• Component/s: C++ Tools

Environment

qpid, perftest tool

• Assignee: Unassigned
• Reporter: Frantisek Reznicek
• Created: 17/Aug/09 09:05
• Updated: 12/Mar/17 14:06
• Resolved: 18/Aug/09 13:11

Description

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) {