summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Merging default into bug 23554Matthew Sackman2010-12-2121-70/+2612
|\
| * Remove R14-ism. Also, cute feature - if you specify no nodes by name, you ↵Matthew Sackman2010-12-201-2/+6
| | | | | | | | mean all known nodes
| * Give in and have the master put the pub msgs themselves on the gm. Avoiding ↵Matthew Sackman2010-12-202-149/+159
| | | | | | | | this proves far too complex in all the failure cases (the worst being when the publishing node crashes - the master can receive the msg, but not the slaves. Worse, because of complexities like delegates, it's not even straightforward to monitor the publishers in order to be sure we're not going to receive more messages from them). We continue to have all msgs directly routed to all queues. Yes, this means that normally every slave receives every message twice, but this is genuinely the simplest and most secure route and protects against failures the best.
| * Revert the previous changeset as I've decided to solve this differentlyMatthew Sackman2010-12-202-135/+53
| |
| * Right, well the fake handling code in master is fine. The fake handling code ↵Matthew Sackman2010-12-202-53/+135
| | | | | | | | in slave is utterly wrong. However, I need to sleep
| * When you send a msg to another node, if the local node doesn't already have ↵Matthew Sackman2010-12-191-1/+5
| | | | | | | | a connection to the destination node, it has to contact epmd and try and resolve the remote node. This takes time. Thus, in the event of a distributed gm group, it's very important that we record asap when a member dies as that member might be our downstream, to which we're sending, and it might be on another node. Thus promote the DOWN messages. Because of the inherent races going on, gm is built to cope with this anyway. This has the nice benefit that promotion of slaves to master in the event of failure of master is now pretty much instantaneous
| * Fixed a bug caused by revision 454fbb9127bd in rabbit-ha from where gm.erl ↵Matthew Sackman2010-12-192-62/+66
| | | | | | | | came; Make gm_tests more robust; Avoid creating endless funs all the time for every message (substantial performance gain). Abstract use of dicts - expected use case is relatively small groups, thus orddict would normally be more appropriate
| * Merging default into bug23554Matthew Sackman2010-12-171-1/+1
| |\
| * | Ensure that promoted slaves monitor the queue's exclusive ownerMatthew Sackman2010-12-171-1/+6
| | |
| * | Fix a race condition that can occur on queue deletion. Also change boot ↵Matthew Sackman2010-12-174-25/+34
| | | | | | | | | | | | order to make sure the msg_stores are started before us (and thus stopped after us)
| * | Accidental unification going on of two things named Q; fix a bug which led ↵Matthew Sackman2010-12-171-8/+12
| | | | | | | | | | | | to repeated calls to BQ:delete_and_terminate (which turns out not to be idempotent)
| * | That might just be enough to support confirmsMatthew Sackman2010-12-171-16/+48
| | |
| * | Correct places to do confirmation stuffMatthew Sackman2010-12-171-2/+0
| | |
| * | Support maybe_run_queue_via_backing_queue in the slaves, and add some ↵Matthew Sackman2010-12-172-4/+23
| | | | | | | | | | | | comments about where to deal with confirmations. I think. Assuming my understanding of pubacks is right.
| * | Permit dynamic inspection of the current mirror queues. This isn't ↵Matthew Sackman2010-12-162-1/+11
| | | | | | | | | | | | particularly lovely because the master queue itself does not know, and thus has to do an mnesia read. However, for the time being it should do
| * | extra_pids => mirror_pids; Also rip out changes to the registry and just ↵Matthew Sackman2010-12-169-38/+20
| | | | | | | | | | | | hard code that rabbit_mnesia takes care of gm - the problem being that we need access to the table dfns even when rabbit app is stopped, thus the registry would be down
| * | Make use of the wonderful new registry.Matthew Sackman2010-12-164-25/+23
| | |
| * | Merging default into bug23554Matthew Sackman2010-12-167-41/+74
| |\ \
| * | | Move the various files from rabbit-ha to rabbit-server as the ha work can't ↵Matthew Sackman2010-12-168-0/+2383
| | | | | | | | | | | | | | | | exist as a plugin
| * | | inlineMatthew Sackman2010-12-141-3/+2
| | | |
| * | | Merging default into bug23554Matthew Sackman2010-12-1425-161/+664
| |\ \ \
| * | | | Extend state conversion functionMatthew Sackman2010-12-131-16/+24
| | | | |
| * | | | Merging default into bug 23554Matthew Sackman2010-12-1311-63/+136
| |\ \ \ \
| | * | | | Alter the result of BQ:requeue so that it also returns the guids of the ↵Matthew Sackman2010-12-124-5/+8
| | | | | | | | | | | | | | | | | | | | | | | | requeued messages. This makes it match the spec of ack closely and is more logical. Also, entirely coincidentally, happens to be necessary for HA...
| | * | | | Merging default into bug23554Matthew Sackman2010-12-1011-58/+128
| | |\ \ \ \
| | | * \ \ \ Merging in from defaultMatthew Sackman2010-12-0916-83/+89
| | | |\ \ \ \
| | | * | | | | Contract will be process is already trapping exitsMatthew Sackman2010-12-091-1/+0
| | | | | | | |
| | | * | | | | Predictions of parameter explosions are highMatthew Sackman2010-12-091-3/+3
| | | | | | | |
| | | * | | | | Turns out the memory_monitor and fhc callback registration is idempotent, ↵Matthew Sackman2010-12-091-4/+0
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and it's also just simply easier to correctly fake the amqqueue_process API. Need to then deal with rate timers and pre hibernation callbacks. Groan
| | | * | | | | Permit queue processes to be initialised with existing state. This raises ↵Matthew Sackman2010-12-091-0/+24
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | the need for the ability to change the callbacks in rabbit_memory_monitor and fhc
| | | * | | | | Increase the probability that the above worksMatthew Sackman2010-12-091-1/+13
| | | | | | | |
| | | * | | | | Allow gen_server2s to change their callback modules dynamically. That was easy.Matthew Sackman2010-12-091-0/+4
| | | | | | | |
| | | * | | | | On other node death, don't delete queues which still have some extra pids.Matthew Sackman2010-12-081-2/+4
| | | | | | | |
| | | * | | | | Add a TODOMatthew Sackman2010-12-081-0/+2
| | | | | | | |
| | | * | | | | Provide a means for plugins to add extra tables which are looked after by ↵Matthew Sackman2010-12-081-2/+14
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | rabbit_mnesia
| | | * | | | | Merge default into bug 23554Matthew Sackman2010-12-069-54/+73
| | | |\ \ \ \ \
| | | | * \ \ \ \ Merge default into bug 23554 (epic debitrot)Matthew Sackman2010-12-0617-420/+851
| | | | |\ \ \ \ \
| | | | * | | | | | Exposing the publishing chpid right through to the BQ (and tidying up ↵Matthew Sackman2010-11-307-40/+45
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | tests/types/specs)
| | | | * | | | | | Make the tests work again. Also mirror_pids => extra_pids on the basis that ↵Matthew Sackman2010-11-295-10/+14
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it could be reusable for other purposes
| | | | * | | | | | Lesser of many evils...Matthew Sackman2010-11-294-9/+13
| | | | | | | | | |
| | | | * | | | | | Present the whole amqqueue record to the BQ (remove duplicated IsDurable ↵Matthew Sackman2010-11-295-11/+9
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | flag, correct BQ callbacks)
| | | | * | | | | | Present the whole amqqueue record to the BQMatthew Sackman2010-11-293-5/+5
| | | | | | | | | |
| | | | * | | | | | Added mechanism to dynamically choose the backing queue module. Ideally, ↵Matthew Sackman2010-11-291-2/+8
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | this'll end up using the generic registry that's part of bug 23467 and allow plugins to register this stuff on boot
* | | | | | | | | | merge bug23619 into defaultMatthias Radestock2010-12-207-17/+49
|\ \ \ \ \ \ \ \ \ \
| * | | | | | | | | | OopsSimon MacMullen2010-12-201-1/+1
| | | | | | | | | | |
| * | | | | | | | | | merge headsMatthias Radestock2010-12-201-1/+1
| |\ \ \ \ \ \ \ \ \ \ | | | |_|_|_|_|_|_|_|/ | | |/| | | | | | | |
| * | | | | | | | | | Merge bug23358 into defaultSimon MacMullen2010-12-202-6/+12
| |\ \ \ \ \ \ \ \ \ \
| * | | | | | | | | | | rabbit_misc:rs/1Simon MacMullen2010-12-201-6/+3
| | | | | | | | | | | |
| * | | | | | | | | | | Legible error message.Simon MacMullen2010-12-201-3/+6
| | | | | | | | | | | |
| * | | | | | | | | | | Tone down the name a bitSimon MacMullen2010-12-201-2/+2
| | | | | | | | | | | |