summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/QueueTest.cpp
Commit message (Collapse)AuthorAgeFilesLines
* QPID-7207: remove cpp and python subdirs from svn trunk, they have migrated ↵Robert Gemmell2016-07-051-629/+0
| | | | | | to their own git repositories git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1751566 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5748: [C++ broker] Make Queue::purgeExpired more efficient; remove ↵Pavel Moravec2014-05-281-1/+0
| | | | | | ExpiryPolicy git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1597931 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5783: Share immutable state between copies of a message. Avoid using ↵Gordon Sim2014-05-231-1/+0
| | | | | | memory for annotations unless actually required. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1597121 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5758: Move purging of expired messages from timer thread to worker threadGordon Sim2014-05-131-1/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1594220 13f79535-47bb-0310-9956-ffa450edef68
* QPID-5667: C++ broker: QMF subscribe events are not raised with AMQP 1.0Alan Conway2014-04-071-1/+1
| | | | | | | The raise event logic for subscribe/unsubscribe events was in 0-10 specific code. Moved it into Queue.cpp so events are generated regardless of protocol. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1585587 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4976: support standard lifetime policiesGordon Sim2013-07-101-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1501768 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Removed Timer.h out of the chain of header files included by Broker.hAndrew Stitcher2012-12-211-0/+1
| | | | | | (since that is widely included) to avoid unnecessary recompilation git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1425037 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4178: broker refactoringGordon Sim2012-08-101-1096/+171
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1371676 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA Fix signed/unsigned warnings on RHEL 5 w/ Boost 1.33.1Stephen D. Huston2012-05-301-22/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1344458 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Allow Queue::setPosition() to truncate the queue.Alan Conway2012-05-281-53/+193
| | | | | | | | | | | | In the new HA code a backup may sometimes be ahead of the new primary after a fail-over. In that case the backup truncates it's queues to the same position as the primary so it can continue replicating. (Note the assertions added to verify setPosition showed up a minor bug in the old cluster code, which was leaving messages on the cluster update queue after an update. This patch fixes the issue.) git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1343347 13f79535-47bb-0310-9956-ffa450edef68
* QPID-4005: Eliminate "using" especially "using namespace" from header fileAndrew Stitcher2012-05-161-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1339403 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3883: Using application headers in messages causes a very large slowdownAndrew Stitcher2012-03-051-26/+26
| | | | | | | | | | Change Exchange route interface not to require a fieldtable - Exchanges that actually use the fieldtable for routing need to extract it directly from the message themselves. This avoids the need to extract the fieldtable from the message unnecessarily. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1297183 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Merge new HA foundations.Alan Conway2012-02-171-1/+8
| | | | | | | Merged from qpid-3603-7. This is basic support for the new HA approach. For information & limitations see qpid/cpp/design_docs/new-ha-design.txt. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1245587 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Merge SemanticState unsubscribe with cancel.Alan Conway2012-01-181-0/+1
| | | | | | Simplyfig the code, there is no need for these to be separate functions. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233087 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Replace public broker::Consumer::position variable with get/set ↵Alan Conway2012-01-181-1/+1
| | | | | | | | function pair. Public member variables are not good sytle. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233080 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA - Removed tabs from sourceTed Ross2011-10-141-24/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1183453 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3417: C++ broker - support adding arrival timestamp to received messages.Kenneth Anthony Giusti2011-10-121-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1182490 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3346: move message group feature into trunk.Kenneth Anthony Giusti2011-10-071-17/+296
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1180050 13f79535-47bb-0310-9956-ffa450edef68
* QPID-702656 Patch from Gordon Sim plus tests which detect the condition ↵Kim van der Riet2011-07-191-25/+21
| | | | | | being solved. Added a make check-long target to the Makefile in the cpp dir to make it easier to run the long tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1148503 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3280: Performance problem with TTL messages.Alan Conway2011-06-151-2/+2
| | | | | | | | | | | | When sending a large number of messages with nonzero TTLs to a cluster, overall message throughput drops by around 20-30% compared to messages with TTL 0. The previous approach to TTL in the cluster is replaced with a simpler "cluster clock". Also QueueCleaner is executed in the cluster timer, and modified to be deterministic in a cluster. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1136170 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3208: Exchanges make best effort to route messages if there is an error.Alan Conway2011-04-181-9/+21
| | | | | | | | | | | | | | | Previously if multiple queues were bound to the same routing key, then a failure to deliver to one of the queues (e.g. policy limit error) could prevent delivery on some of the other queues. With this commit the exchange delivers to every queue that did not have an error before raising an error. Note: this was originally committed as r1092765, but it caused test failures was reverted as r1092804. The original commit did not create exceptions of the correct type. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1094734 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3073: refactor to eliminate locks, malloc, and map insert/remove in ↵Kenneth Anthony Giusti2011-03-081-2/+0
| | | | | | receive path. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1079385 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3087: Fixes to store interaction changesGordon Sim2011-02-281-4/+4
| | | | | | | | | * don't create queue on recovery * ensure laternate exchange is set before creating store record for queue git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075331 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2935: merge producer flow control (C++ broker).Kenneth Anthony Giusti2011-02-191-0/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072356 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3015: Added create and delete methods to management schema for brokerGordon Sim2011-02-181-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1072179 13f79535-47bb-0310-9956-ffa450edef68
* Revert commits r981517 and r981435 that moved periodic purging of queues ↵Gordon Sim2010-08-111-1/+1
| | | | | | onto cluster's timer. If the timer fires during an update it causes errors; it also puts a potentially time consuming task on the clusters dispatch thread. Instead don't purge LVQs to avoid cluster inconsistencies (and more directly the assertion that aims to prevent these). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@984357 13f79535-47bb-0310-9956-ffa450edef68
* Ensure that for clustered broker the queue cleaner is run on the correct thread.Gordon Sim2010-08-021-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@981435 13f79535-47bb-0310-9956-ffa450edef68
* fix & test QPID-2320Carl C. Trieloff2010-01-061-0/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@896687 13f79535-47bb-0310-9956-ffa450edef68
* Revert "Added getStoreDir() to MessageStore"Alan Conway2009-11-201-2/+0
| | | | | | | | | | | This reverts revision 882218 which broke the Windows. It also assumes that a MessageStore has an associated directory, which is not the case for all stores. We need a portable way to associate extra state with a store. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@882623 13f79535-47bb-0310-9956-ffa450edef68
* Added getStoreDir() to MessageStoreAlan Conway2009-11-191-0/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@882218 13f79535-47bb-0310-9956-ffa450edef68
* Also remove liner search from seek() & add testsCarl C. Trieloff2009-11-101-0/+52
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@834607 13f79535-47bb-0310-9956-ffa450edef68
* remove looping for position search and replace with stl algorithms for ↵Carl C. Trieloff2009-11-091-1/+2
| | | | | | better performance git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@834172 13f79535-47bb-0310-9956-ffa450edef68
* Transient flow-to-disk messages switched to store from BDB. Only ↵Kim van der Riet2009-09-281-2/+2
| | | | | | single-queue transient messages are handled at this point, multi-queue bindings are blocked under all circumstances to prevent routing order dependencies from making the outcome inconsistent. BZ525813 - "Move Flow to disk from BDB to journal" git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@819600 13f79535-47bb-0310-9956-ffa450edef68
* Minor update to allow store access to the message isPersistent() method. ↵Kim van der Riet2009-09-221-1/+1
| | | | | | This is required for correctly setting the transient flag. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817748 13f79535-47bb-0310-9956-ffa450edef68
* Joint checkin from gsim, kpvdr, cctrieloff. See QPID-2102: Exceeding reject ↵Kim van der Riet2009-09-221-17/+324
| | | | | | queue policy under a transaction causes broker crash git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@817742 13f79535-47bb-0310-9956-ffa450edef68
* Reversed checkin of r.813825 until its problems can be resolvedKim van der Riet2009-09-141-120/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@814692 13f79535-47bb-0310-9956-ffa450edef68
* Fix for signed-unsigned mismatch in testKim van der Riet2009-09-111-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@814020 13f79535-47bb-0310-9956-ffa450edef68
* Joint checkin with cctrieloff. Refactor of exchange routing so that ↵Kim van der Riet2009-09-111-4/+130
| | | | | | multi-queue policy differences may be resolved and allow for correct multi-queue flow-to-disk behavior. Different queues may have differing policies and persistence properties - these were previously being neglected. New c++ test added. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@813825 13f79535-47bb-0310-9956-ffa450edef68
* Tidied up namespace usageAndrew Stitcher2009-09-091-75/+80
| | | | | | Miscelleneous whitespace fixes git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@813094 13f79535-47bb-0310-9956-ffa450edef68
* handle fail setting last-node-standing with unit test, still needs system testCarl C. Trieloff2009-07-311-2/+35
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@799658 13f79535-47bb-0310-9956-ffa450edef68
* Remove incorrect directory from #includeAlan Conway2009-07-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@793912 13f79535-47bb-0310-9956-ffa450edef68
* Add directory to #includeAlan Conway2009-07-141-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@793909 13f79535-47bb-0310-9956-ffa450edef68
* Clean up for next commit to clean broker interfaceCarl C. Trieloff2009-07-091-2/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792664 13f79535-47bb-0310-9956-ffa450edef68
* simulate this:Carl C. Trieloff2009-07-081-0/+42
| | | | | | | | | | | | | | | 1. start two nodes 2. create cluster durable queue and add some messages 3. kill one node (trigger force-persistent behaviour) 4. stop and recover remaining node 5. add another node 6. kill that new node again make sure that an attempt to re-enqueue a message does not happen which will result in the last man standing exiting with an error. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792286 13f79535-47bb-0310-9956-ffa450edef68
* fix for regression in patch & test to prevent regression againCarl C. Trieloff2009-07-081-0/+50
| | | | | | | | | | | | | | | | | Simulate this: 1. start 2 nodes 2. create cluster durable lvq 3. send a transient message to the queue 4. kill one of the nodes (to trigger force persistent behaviour)... 5. then restart it (to turn off force persistent behaviour) 6. send another transient message with same lvq key as in 3 7. kill the second node again (retrigger force persistent) 8. stop and recover the first node git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792259 13f79535-47bb-0310-9956-ffa450edef68
* test for last commitCarl C. Trieloff2009-07-081-1/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792210 13f79535-47bb-0310-9956-ffa450edef68
* More tests and completion of fix for 791672Carl C. Trieloff2009-07-071-0/+28
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@791858 13f79535-47bb-0310-9956-ffa450edef68
* Corrected the case where message on more than one queue does not persist ↵Carl C. Trieloff2009-07-071-1/+32
| | | | | | when last node standing is enabled git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@791672 13f79535-47bb-0310-9956-ffa450edef68
* Cluster support for message time-to-live.Alan Conway2009-02-091-1/+2
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@742774 13f79535-47bb-0310-9956-ffa450edef68
* Removed BodyHolder: minor performance improvement, opens the way for more ↵Alan Conway2009-01-221-2/+2
| | | | | | efficient memory management. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@736783 13f79535-47bb-0310-9956-ffa450edef68