diff options
author | Rajith Muditha Attapattu <rajith@apache.org> | 2009-08-24 16:02:08 +0000 |
---|---|---|
committer | Rajith Muditha Attapattu <rajith@apache.org> | 2009-08-24 16:02:08 +0000 |
commit | 8aa5b3e1c1cb28d0b7fd2cefec9ed4f85b3606a5 (patch) | |
tree | 764d810b3e54b3917f8f57ded219fe45b7acadc9 /cpp/src/qpidd.cpp | |
parent | 66e450e61e2e6fc4b31126ddd21d1778550470ca (diff) | |
download | qpid-python-8aa5b3e1c1cb28d0b7fd2cefec9ed4f85b3606a5.tar.gz |
This is related to QPID-2074
I added a flag to disable flow control when max prefetch is zero. This will also prevent unnessacery suspend/resume actions (and hence extra threads being spawned) when the non meaningful thresholds (for the above case) are passed.
I also think that adjusting the count and puting the message into the queue should be an atomic operation. This means notifying the listener will also need to be squeezed insde the same sync block. Another point to note is that this is redundent in the 0-10 codepath as we have protocol level flow control. Since a more complete overhaul is needed in this area, for the time being I have only done the bare minimum.
I also added a timeout for all sync receives in the DurableSubscriptionTest. This will prevent the whole test suite from hanging if messages don't arrive as expected.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@807292 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpidd.cpp')
0 files changed, 0 insertions, 0 deletions