diff options
| author | Gordon Sim <gsim@apache.org> | 2011-08-01 15:24:59 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-08-01 15:24:59 +0000 |
| commit | 7818a4da57950679498d981b27393aa944f17b97 (patch) | |
| tree | cbac4598e63d5bb689f1cf30c4794f17053276bc | |
| parent | a285ea48162a3eefdbdf69c5499cf521e43fad78 (diff) | |
| download | qpid-python-7818a4da57950679498d981b27393aa944f17b97.tar.gz | |
QPID-3383: Changed to explicit credit management for control subscription in publishers to prevent incorrect allocation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1152825 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/cpp/src/tests/qpid-perftest.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/cpp/src/tests/qpid-perftest.cpp b/qpid/cpp/src/tests/qpid-perftest.cpp index 8a5cf05775..1ca12a726d 100644 --- a/qpid/cpp/src/tests/qpid-perftest.cpp +++ b/qpid/cpp/src/tests/qpid-perftest.cpp @@ -510,10 +510,11 @@ struct PublishThread : public Client { } SubscriptionManager subs(session); LocalQueue lq; - subs.setFlowControl(1, SubscriptionManager::UNLIMITED, true); - subs.subscribe(lq, fqn("pub_start")); + subs.setFlowControl(0, SubscriptionManager::UNLIMITED, false); + Subscription cs = subs.subscribe(lq, fqn("pub_start")); for (size_t j = 0; j < opts.iterations; ++j) { + cs.grantMessageCredit(1); expect(lq.pop().getData(), "start"); AbsTime start=now(); for (size_t i=0; i<opts.count; i++) { |