summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* QPID-3603: Clean up HA log messages.Alan Conway2012-01-1911-164/+92
| | | | | | | | - Reduce verbosity, drop unknown event messages. - Lots of clarifications - Fix minor test bug in ha_tests.py. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233669 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Disable federation cluster tests on qpid-3603 branch.Alan Conway2012-01-191-7/+10
| | | | | | | These tests are known to be broken by the new HA work. We will need to fix them and re-enable at some point. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233668 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Added backup connection identifier to logging output.Alan Conway2012-01-193-8/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233667 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix race condition in setting initial position of ↵Alan Conway2012-01-193-20/+8
| | | | | | ReplicatingSubscription. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233665 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Use position events to synchronize queue positions between ↵Alan Conway2012-01-195-65/+135
| | | | | | | | | | | primary and backup Previous code used dequeues to synchronize queue, but dequeue events are generated in a different thread to message delivery which led to race conditions. Position events are generated in-line with message delivery. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233664 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix bug in MessageDeque::acquire.Alan Conway2012-01-191-0/+1
| | | | | | | Acquire was returning incorrect results if the acquired position was before the first availble index. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233663 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fixed a race condition in ha_tests.pyAlan Conway2012-01-191-18/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233662 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Failover optimization removed.Alan Conway2012-01-193-77/+28
| | | | | | | | | | | There was an optimization to re-use messages already on the backup after fail-over. This optimization was removed to simplify the logic while we basic replication working. It can be re-introduced later. Last revision with the optimization was: r1213258 | QPID-3603: Fix QueueReplicator subscription parameters. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233661 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix QueueReplicator subscription parameters.Alan Conway2012-01-197-43/+96
| | | | | | | | - Queue::destroyed cleans up observers. - Clean up log messages, comments, some variable names. - Improvements to brokertest.py git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233660 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleaned up log messages, update qpid-cluster-benchmark to set ↵Alan Conway2012-01-196-21/+46
| | | | | | replicate=all git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233659 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Set bridge sync parameter to 1.Alan Conway2012-01-194-4/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233658 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA - Updated CMakeLists to support cmake build for this branch.Alan Conway2012-01-191-3/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233657 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleaned up HA log messages.Alan Conway2012-01-196-61/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233655 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix replication of dequeues.Alan Conway2012-01-196-71/+90
| | | | | | | | - Set acquire=false when creating a ReplicatingSubscription. - Cleaned up string literals & other cosmetic improvemets. - Consistent find/get for broker::QueueRegistry and ExchangeRegistry. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233654 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: fix missing includeAlan Conway2012-01-191-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233653 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleanup of HA log messages.Alan Conway2012-01-1911-71/+158
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233652 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Integrate ReplicatingSubscription into the HA code.Alan Conway2012-01-1912-70/+80
| | | | | | | HaBroker registers the ConsumerFactory, QueueReplicator sets appropriate arguments in consume command. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233651 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Renamed new HA design doc, added some user documentataion notes.Alan Conway2012-01-191-0/+31
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233650 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: In progress - integrate ReplicatingSubscription.Alan Conway2012-01-197-28/+54
| | | | | | | | The code to use ReplicatingSubscription is there but it is disabled by commenting out getConsumerFactories().add in Backup.cpp because it hangs the test. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233649 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move broker::ReplicatingSubscription to ha namespace and ha plugin.Alan Conway2012-01-1911-54/+132
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233648 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Automatic wiring and message replication.Alan Conway2012-01-1914-118/+201
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233646 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Minor refactor, got rid of WiringReplicator::initialize.Alan Conway2012-01-193-10/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233645 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move wiring-replicator creation out of SemanticState::route.Alan Conway2012-01-197-164/+161
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233644 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Replicate bindings to backup brokers.Alan Conway2012-01-193-89/+170
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233643 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Minor refactor.Alan Conway2012-01-192-75/+92
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233642 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move init code for WiringReplicator out of Bridge into ha::Backup.Alan Conway2012-01-196-75/+114
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233641 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Rename broker::NodeClone to ha::WiringReplicator.Alan Conway2012-01-197-57/+58
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233640 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Use string constants to prevent needless heap allocation.Alan Conway2012-01-191-52/+86
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233639 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Iterate over multiple QMF events.Alan Conway2012-01-191-27/+21
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233637 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Refactored NodeClone, break out create functions.Alan Conway2012-01-193-131/+167
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233636 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: added note about current lack of synchronisation of snapshot and ↵Alan Conway2012-01-191-3/+14
| | | | | | events in node propagation git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233635 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Automatic wiring replication for HA.Alan Conway2012-01-1919-103/+384
| | | | | | | | | | Automatic replication of queues an exchanges. Bidnings TBD. Get rid of long delay establishing connections: - broker/Connection.cpp: requestIOProcessing() called before connection open saves work till connection is open. - broker/Link.cpp,LinkRegistry: Fix some const correctness errors. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233634 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Updated replicating-browser-design, lifecycle, rgmanager ↵Alan Conway2012-01-191-16/+105
| | | | | | interactions. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233633 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move class ReplicatingSubscription into its own files.Alan Conway2012-01-194-229/+294
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233632 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: disable old cluster testsAlan Conway2012-01-191-9/+19
| | | | | | | | Allow us to make progress on new HA on QPID-3603 branch. We will have to re-enable them and fix the old cluster issues before merging to trunk. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233631 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Add management interface and commmand line tool to set HA status.Alan Conway2012-01-1911-4/+389
| | | | | | | | - Fixed management generation to use full name in #ifdef guards. - Added src/qpid/ha/management-schema.xml with new management interface. - Added qpid-ha-status tool to read/set HA status. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233630 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Clean up HA design doc.Alan Conway2012-01-191-7/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233629 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Initial list of limitations of current codeAlan Conway2012-01-191-1/+74
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233628 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Checked in files left out by accident in last commit to this branchAlan Conway2012-01-192-0/+273
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233627 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Initial (very rough) cut of queue and exchange propagation from ↵Alan Conway2012-01-1910-4/+79
| | | | | | one node to another git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233626 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Initial design document.Alan Conway2012-01-191-0/+151
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233625 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Prototype of replicating browser.Alan Conway2012-01-1928-277/+760
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233624 13f79535-47bb-0310-9956-ffa450edef68
* New HA solution using the replicating browserAlan Conway2012-01-190-0/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603-2@1233599 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3768: Refactor test case to avoid possibility of spurious test failureKeith Wall2012-01-181-29/+39
| | | | | | Changed impl of testGetNextWithAck() to avoid unsafe assumption that pre-fetching will mean sorting will never occur. Remove unnecessary message payloads used by some test (time in ms) as this was not contributing to test. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233125 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Replace public broker::Consumer::position variable with get/set ↵Alan Conway2012-01-181-3/+3
| | | | | | | | function pair. Fix to r1233080 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233102 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Added public broker::Connection::isLink function.Alan Conway2012-01-182-17/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233088 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Merge SemanticState unsubscribe with cancel.Alan Conway2012-01-184-9/+8
| | | | | | 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: Act on bridge cancellations before creationsAlan Conway2012-01-181-7/+9
| | | | | | This ensures that recreation of a bridge does not result in two active subscriptions (evench can cause confusion for replicators, even if they are both active only for a very short period). git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233086 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix spurious "exchange not found" error and debug messages.Alan Conway2012-01-184-66/+58
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233085 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Consistent find/get functions for Queue and Exchange registries.Alan Conway2012-01-184-5/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233084 13f79535-47bb-0310-9956-ffa450edef68