summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* QPID-3603: Added public broker::Connection::isLink function.qpid-3603Alan Conway2012-01-182-17/+19
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232959 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix replication of unbind events.Alan Conway2012-01-181-15/+16
| | | | | | | Old clients can omit certain map values. Previously this caused an error, now a void value is treated as an empty map. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232958 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Replicate unbind events.Alan Conway2012-01-173-14/+59
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232481 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Do case-insensitive string comparison for replication levels.Alan Conway2012-01-171-2/+5
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232480 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Rename WiringReplicator to BrokerReplicator.Alan Conway2012-01-166-29/+29
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232178 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Minor FIXME cleanup.Alan Conway2012-01-162-5/+3
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232172 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix QueueReplicator lifecycle, shared pointer cycle.Alan Conway2012-01-162-5/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232171 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Hide "queue deleted" errors detected for a ReplicatingSubscription.Alan Conway2012-01-165-4/+15
| | | | | | | This is not an error, its normal for ReplicatingSubscriptions to be still running when a queue is deleted. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232170 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Sync cmake with automakeTed Ross2012-01-161-2/+0
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232142 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Handle backup crash/shutdown.Alan Conway2012-01-1611-85/+142
| | | | | | | | If a backup crashes or shuts down any messages that have been delayed completion for that backup must be marked complete to avoid the primary hanging. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1232075 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Merge SemanticState unsubscribe with cancel.Alan Conway2012-01-132-9/+4
| | | | | | Simplyfig the code, there is no need for these to be separate functions. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1231288 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Check for gaps in sequence numbers in qpid-receive.Alan Conway2012-01-131-15/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1231287 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Act on bridge cancellations before creationsGordon Sim2012-01-121-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/branches/qpid-3603@1230488 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix spurious "exchange not found" error and debug messages.Alan Conway2012-01-114-65/+56
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230147 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Logging improvements for bridges, links and HA classes.Alan Conway2012-01-115-37/+43
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230146 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3352: Fix test for failed session to avoid confusion with as yet ↵Gordon Sim2012-01-115-7/+12
| | | | | | uninitialised session git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1230143 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Ensure listeners are notified of available messages even when a ↵Gordon Sim2012-01-101-7/+6
| | | | | | consumer also exists (note that replicating browser sees acquired messages) git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229681 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: HA logging improvements.Alan Conway2012-01-094-16/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229376 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Break infinite "detached" loop between federated brokers.Alan Conway2012-01-091-2/+4
| | | | | | | Don't reply to a "detached" in case of error. Doing so can create an infinite game of "detached tennis" between federated brokers. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1229375 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix memory management error in QueueReplicator.cppAlan Conway2012-01-063-11/+7
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1228425 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Replace public broker::Consumer::position variable with get/set ↵Alan Conway2012-01-067-12/+19
| | | | | | | | function pair. Done for the new HA work, but this is better practice in any case. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1228424 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Code cleanup to make ReplicatingSubscription more readable.Alan Conway2012-01-051-29/+23
| | | | | | Clarified deliver() and dequeued() logic and locking. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1227885 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix initialization race in QueueReplicator.Alan Conway2012-01-052-3/+6
| | | | | | | Was core dumping occasionally due to QueueReplicator being deleted before it was initialized. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1227882 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Lifecycle and locking fixes for QueueReplicatorAlan Conway2011-12-223-5/+16
| | | | | | | | | | | | Separate bridge de-activation from destruction in QueueReplicator: Only deactivate if destroyed by the WiringReplicator because of a queue delete. If destroyed for any other reason (e.g. broker destruction) don't de-activate the bridge as required resources may not exist. Added missing locks in QueueReplicator functions. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1222432 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Format static log prefixes at consutruction time.Alan Conway2011-12-224-30/+27
| | | | | | | Creating the prefix dynamically caused sporadic core dumps with trace logging on. It is also inefficient. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1222431 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Independent isDelayedCompletion for ↵Alan Conway2011-12-212-0/+2
| | | | | | | | ReplicatingSubscription::DelegatingConsumer The event messages sent to this consumer do not have delayed completion. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1221922 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Delete HA resources (QueueReplicator) along with the queues.Alan Conway2011-12-214-15/+27
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1221921 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Clean up HA log messages.Alan Conway2011-12-2111-165/+93
| | | | | | | | - 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@1221920 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Disable federation cluster tests on qpid-3603 branch.Alan Conway2011-12-151-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@1214971 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Added backup connection identifier to logging output.Alan Conway2011-12-153-8/+22
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214970 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix race condition in setting initial position of ↵Alan Conway2011-12-153-20/+8
| | | | | | ReplicatingSubscription. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214969 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Use position events to synchronize queue positions between ↵Alan Conway2011-12-145-66/+136
| | | | | | | | | | | 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@1214493 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix bug in MessageDeque::acquire.Alan Conway2011-12-141-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@1214492 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fixed a race condition in ha_tests.pyAlan Conway2011-12-141-18/+13
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1214491 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Failover optimization removed.Alan Conway2011-12-143-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@1214490 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix QueueReplicator subscription parameters.Alan Conway2011-12-127-47/+100
| | | | | | | | - 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@1213258 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleaned up log messages, update qpid-cluster-benchmark to set ↵Alan Conway2011-12-086-21/+47
| | | | | | replicate=all git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1211902 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Set bridge sync parameter to 1.Alan Conway2011-12-064-4/+18
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1210983 13f79535-47bb-0310-9956-ffa450edef68
* NO-JIRA - Updated CMakeLists to support cmake build for this branch.Ted Ross2011-12-051-3/+36
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1210616 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleaned up HA log messages.Alan Conway2011-12-026-61/+61
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1209691 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Fix replication of dequeues.Alan Conway2011-12-0210-76/+123
| | | | | | | | - 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@1209690 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: fix missing includeGordon Sim2011-11-301-0/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1208617 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Cleanup of HA log messages.Alan Conway2011-11-3011-71/+158
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1208461 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Integrate ReplicatingSubscription into the HA code.Alan Conway2011-11-2812-71/+81
| | | | | | | HaBroker registers the ConsumerFactory, QueueReplicator sets appropriate arguments in consume command. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1207544 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Renamed new HA design doc, added some user documentataion notes.Alan Conway2011-11-281-2/+33
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1207447 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: In progress - integrate ReplicatingSubscription.Alan Conway2011-11-257-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@1206353 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move broker::ReplicatingSubscription to ha namespace and ha plugin.Alan Conway2011-11-2511-58/+136
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206352 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Automatic wiring and message replication.Alan Conway2011-11-2514-118/+201
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206351 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Minor refactor, got rid of WiringReplicator::initialize.Alan Conway2011-11-253-10/+1
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206350 13f79535-47bb-0310-9956-ffa450edef68
* QPID-3603: Move wiring-replicator creation out of SemanticState::route.Alan Conway2011-11-257-164/+161
| | | | git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3603@1206349 13f79535-47bb-0310-9956-ffa450edef68