Qpid
  1. Qpid
  2. QPID-2053

perftest users might benefit from having possibility to specify the queue name

    Details

    • Type: Improvement Improvement
    • Status: Resolved
    • Priority: Trivial Trivial
    • Resolution: Fixed
    • Affects Version/s: M3, M4
    • Fix Version/s: None
    • Component/s: Tools
    • Labels:
      None
    • Environment:

      qpid, perftest tool

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

        Activity

        Hide
        Gordon Sim added a comment -

        Implemented as r805404.

        Show
        Gordon Sim added a comment - Implemented as r805404.

          People

          • Assignee:
            Unassigned
            Reporter:
            Frantisek Reznicek
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Time Tracking

              Estimated:
              Original Estimate - 1h
              1h
              Remaining:
              Remaining Estimate - 1h
              1h
              Logged:
              Time Spent - Not Specified
              Not Specified

                Development