summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* QPID-2920: Batch acquire/dequeue messages in cluster.qpid-2920-activeAlan Conway2011-11-0424-182/+318
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197749 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Introduced "ticks" for timing.Alan Conway2011-11-0418-103/+281
| | | | | | | - Use fewer timer tasks - 1 per group - Dispatch timer tasks in separate thread context per group. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197748 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Minor updates to design/plan docs.Alan Conway2011-11-042-9/+29
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197548 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Updates to new-cluster-plan.txtAlan Conway2011-10-311-11/+32
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1195515 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Updated cluster/exp/overview.h & other comments.Alan Conway2011-10-316-15/+66
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1195424 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Updates to new-cluster-plan.txt and new-cluster-design.txtAlan Conway2011-10-312-69/+104
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1195413 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Replace RwLock with Mutex in cluster::LockedMap.Alan Conway2011-10-195-27/+15
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1186499 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Updates to new-cluster-plan.Alan Conway2011-10-191-19/+15
| | | | | | Re-organized tasks by priority. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1186474 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Updates to new-cluster-plan.Alan Conway2011-10-192-11/+24
| | | | | | Filled out plan to-do list. More implementation detail. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1186466 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Changed qpid-cluster-benchmark defaults for more statistically ↵Alan Conway2011-10-191-2/+2
| | | | | | reliable tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1186427 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Improved error messages from qpid-cpp-benchmark.Alan Conway2011-10-131-3/+10
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1183029 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Clean up cluster log messages.Alan Conway2011-10-135-25/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1182914 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Update new-cluster-plan.txt and new-cluster-design.txt.Alan Conway2011-10-132-22/+32
| | | | | | Refined comments on live upgrade in design and plan. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1182815 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Improvements to cluster benchmarks.Alan Conway2011-10-122-8/+24
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1182605 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Update new-cluster-plan.txt and new-cluster-design.txt.Alan Conway2011-10-122-39/+79
| | | | | | | Filled out outstanding tasks in plan. Added comments on live upgrades to design and plan. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1182558 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Clean up out-dated FIXME comments.Alan Conway2011-10-1244-150/+76
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1182557 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Update new-cluster-design and new-cluster-plan to reflect current ↵Alan Conway2011-10-073-575/+224
| | | | | | status. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1180238 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Configurable connection output prefetch.Alan Conway2011-10-067-14/+32
| | | | | | | | | | Allow connections to collect more output than they can write immediately. Improves performance in a cluster: while a broker has the consume lock connections can collect extra output data to keep them busy while waiting for the consume lock to return. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1179839 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Configurable control over concurrencyAlan Conway2011-10-0511-33/+46
| | | | | | | | - new config option controls number of CPG groups used. - minor log message improvements - minor code clean-up git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1179456 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Remove incorrect recursive lock.Alan Conway2011-10-051-1/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1179455 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: consistent error messages in MessageHandler.Alan Conway2011-10-041-4/+4
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1178802 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Asynchronous completion.Alan Conway2011-10-0410-33/+195
| | | | | | | | Keep track of local messages in flight. Prepare async completion counter on local enqueue. Signal async completion when local message is self delivered. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1178801 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Send messages frame by frame.Alan Conway2011-09-3019-40/+294
| | | | | | | | The sender picks a channel number unique within that sender. Messages are sent over CPG frame-by-frame and assembled based on the sender and channel number. Channel numbers can be re-used once the send is complete. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177833 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Improve benchmark tests, allow saving received messages.Alan Conway2011-09-303-3/+17
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177832 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Fix race condition causing sporadic duplicate messages.Alan Conway2011-09-301-1/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177831 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Remove unused QueueHandler member from BrokerContext.Alan Conway2011-09-303-8/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177830 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Renamed Stoppable to Activity, clearer naming.Alan Conway2011-09-304-38/+50
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177829 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: removed temporary debug logging statements.Alan Conway2011-09-302-4/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177676 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Minor improvements to cluster tests and logging.Alan Conway2011-09-296-16/+40
| | | | | | Changed default --consume-lock to 10000. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1177443 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Use multiple independent CPG groups.Alan Conway2011-09-2710-118/+49
| | | | | | | | | | | | | Use a fixed set of CPG groups, hash queue names to choose the group for a given operation. Operations on a given queue will always use the same CPG group but operations on different queues can execute concurrently on different groups. Removed fanuout optimization, it doesn't work with multiple CPG groups. Can't guratnee that "routing" will proceed enqueues on different CPG groups. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1176373 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Groundwork to enable queues hashed over multiple CPG groups.Alan Conway2011-09-2717-64/+302
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1176372 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Make consume-lock timeout configurableAlan Conway2011-09-2314-66/+124
| | | | | | | - Configurable cluster-lock timeout. - Tweaked qpid-cluster-benchmark default settings. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1174930 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Fix deadlock in QueueContext/QueueContextAlan Conway2011-09-218-42/+42
| | | | | | | | | | | Deadlock between to brokers occured if a SHARED_OWNER broker sent a resubscribe, then the other broker left making the remaining broker SOLE_OWNER. Previous logic ignored the SOLE_OWNER -> SOLE_OWNER transition. Fixed several other minor bugs showing up in make check. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1173796 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Fixed race condition around Queue::listeners.Alan Conway2011-09-2112-54/+42
| | | | | | | - moved call to cluster dequeue, no deferred dequeue. - removed unused function broker::Cluster::empty git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1173697 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Remove deferred dequeue, not needed.Alan Conway2011-09-216-9/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1173696 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Fixing hangs in qid-cpp-benchmark with 2 brokers.Alan Conway2011-09-2110-45/+60
| | | | | | This test hangs: qpid-cpp-benchmark -b localhost:5556,localhost:5555 -r2 -m10000 git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1173695 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Fixing QueueContext state transtions for timed ownership.Alan Conway2011-09-1621-105/+188
| | | | | | - Renamed release to requeue for Cluster interface. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1171757 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: New cluster release/requeue.Alan Conway2011-09-1626-157/+267
| | | | | | | Almost functional, seeing sporadic hangs in qpid-cpp-benchmark with two brokers: qpid-cpp-benchmark -b localhost:5556,localhost:5555 -r2 -m10000 git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1171756 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Active-active new cluster prototypeAlan Conway2011-09-080-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1166912 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Rebased on trunk, fix up minor conflicts.qpid-2920-1Alan Conway2011-09-064-12/+9
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165889 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Clean up of debugging messages, install test exes.Alan Conway2011-09-0612-47/+51
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165888 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Initial stab at time-based queue sharing.Alan Conway2011-09-0611-118/+133
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165887 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Broken checkpoint: passing dequeue mutex test with issuesAlan Conway2011-09-0630-136/+999
| | | | | | | | | | | | - handler/context/replica convention (see overview.h doc notes) - rename BrokerHandler to BrokerContext - notify Cluster (BrokerContext) on queue stopped or empty (need empty?) - Implementing Stoppable & stoppable scopes in Queue.cpp - Move queue ownership logic from dequeue to acquire Releasing on message count will not work, switch to timer based release. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165886 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: pass configuration changes to handlers.Alan Conway2011-09-062-0/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165884 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: add conveniece function to multicast AMQBodys directly.Alan Conway2011-09-062-1/+14
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165883 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Remove const from some broker::Cluster functions to allow cluster ↵Alan Conway2011-09-066-39/+40
| | | | | | to work. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165882 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Allow stopping consumers on queues.Alan Conway2011-09-064-11/+166
| | | | | | Stop consumers from dispatching and wait for already dispatching consumers to exit. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165881 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Sleep on cpg flow control to avoid thrashing.Alan Conway2011-09-061-0/+1
| | | | | | | Added a 1ms sleep when CPG is flow controlled. Huge thruput improvement for qpid-cluster-benchmarks multi-host case. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165880 13f79535-47bb-0310-9956-ffa450edef68
* QPID-2920: Improvements to qpid-cpp-benchmark.Alan Conway2011-09-061-19/+27
| | | | | | | - fixed error message. - add necessary waiting to deal with async wiring in the new cluster. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165879 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA: Fix ambiguous option to qpid-cluster-benchmark.Alan Conway2011-09-061-6/+6
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-1@1165878 13f79535-47bb-0310-9956-ffa450edef68
View Lorry Controller Status