| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Merging default into bug 23554 | Matthew Sackman | 2010-12-21 | 21 | -70/+2612 |
| |\ | |||||
| | * | Remove R14-ism. Also, cute feature - if you specify no nodes by name, you ↵ | Matthew Sackman | 2010-12-20 | 1 | -2/+6 |
| | | | | | | | | | mean all known nodes | ||||
| | * | Give in and have the master put the pub msgs themselves on the gm. Avoiding ↵ | Matthew Sackman | 2010-12-20 | 2 | -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 differently | Matthew Sackman | 2010-12-20 | 2 | -135/+53 |
| | | | |||||
| | * | Right, well the fake handling code in master is fine. The fake handling code ↵ | Matthew Sackman | 2010-12-20 | 2 | -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 Sackman | 2010-12-19 | 1 | -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 Sackman | 2010-12-19 | 2 | -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 bug23554 | Matthew Sackman | 2010-12-17 | 1 | -1/+1 |
| | |\ | |||||
| | * | | Ensure that promoted slaves monitor the queue's exclusive owner | Matthew Sackman | 2010-12-17 | 1 | -1/+6 |
| | | | | |||||
| | * | | Fix a race condition that can occur on queue deletion. Also change boot ↵ | Matthew Sackman | 2010-12-17 | 4 | -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 Sackman | 2010-12-17 | 1 | -8/+12 |
| | | | | | | | | | | | | | to repeated calls to BQ:delete_and_terminate (which turns out not to be idempotent) | ||||
| | * | | That might just be enough to support confirms | Matthew Sackman | 2010-12-17 | 1 | -16/+48 |
| | | | | |||||
| | * | | Correct places to do confirmation stuff | Matthew Sackman | 2010-12-17 | 1 | -2/+0 |
| | | | | |||||
| | * | | Support maybe_run_queue_via_backing_queue in the slaves, and add some ↵ | Matthew Sackman | 2010-12-17 | 2 | -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 Sackman | 2010-12-16 | 2 | -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 Sackman | 2010-12-16 | 9 | -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 Sackman | 2010-12-16 | 4 | -25/+23 |
| | | | | |||||
| | * | | Merging default into bug23554 | Matthew Sackman | 2010-12-16 | 7 | -41/+74 |
| | |\ \ | |||||
| | * | | | Move the various files from rabbit-ha to rabbit-server as the ha work can't ↵ | Matthew Sackman | 2010-12-16 | 8 | -0/+2383 |
| | | | | | | | | | | | | | | | | | exist as a plugin | ||||
| | * | | | inline | Matthew Sackman | 2010-12-14 | 1 | -3/+2 |
| | | | | | |||||
| | * | | | Merging default into bug23554 | Matthew Sackman | 2010-12-14 | 25 | -161/+664 |
| | |\ \ \ | |||||
| | * | | | | Extend state conversion function | Matthew Sackman | 2010-12-13 | 1 | -16/+24 |
| | | | | | | |||||
| | * | | | | Merging default into bug 23554 | Matthew Sackman | 2010-12-13 | 11 | -63/+136 |
| | |\ \ \ \ | |||||
| | | * | | | | Alter the result of BQ:requeue so that it also returns the guids of the ↵ | Matthew Sackman | 2010-12-12 | 4 | -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 bug23554 | Matthew Sackman | 2010-12-10 | 11 | -58/+128 |
| | | |\ \ \ \ | |||||
| | | | * \ \ \ | Merging in from default | Matthew Sackman | 2010-12-09 | 16 | -83/+89 |
| | | | |\ \ \ \ | |||||
| | | | * | | | | | Contract will be process is already trapping exits | Matthew Sackman | 2010-12-09 | 1 | -1/+0 |
| | | | | | | | | | |||||
| | | | * | | | | | Predictions of parameter explosions are high | Matthew Sackman | 2010-12-09 | 1 | -3/+3 |
| | | | | | | | | | |||||
| | | | * | | | | | Turns out the memory_monitor and fhc callback registration is idempotent, ↵ | Matthew Sackman | 2010-12-09 | 1 | -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 Sackman | 2010-12-09 | 1 | -0/+24 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | the need for the ability to change the callbacks in rabbit_memory_monitor and fhc | ||||
| | | | * | | | | | Increase the probability that the above works | Matthew Sackman | 2010-12-09 | 1 | -1/+13 |
| | | | | | | | | | |||||
| | | | * | | | | | Allow gen_server2s to change their callback modules dynamically. That was easy. | Matthew Sackman | 2010-12-09 | 1 | -0/+4 |
| | | | | | | | | | |||||
| | | | * | | | | | On other node death, don't delete queues which still have some extra pids. | Matthew Sackman | 2010-12-08 | 1 | -2/+4 |
| | | | | | | | | | |||||
| | | | * | | | | | Add a TODO | Matthew Sackman | 2010-12-08 | 1 | -0/+2 |
| | | | | | | | | | |||||
| | | | * | | | | | Provide a means for plugins to add extra tables which are looked after by ↵ | Matthew Sackman | 2010-12-08 | 1 | -2/+14 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | rabbit_mnesia | ||||
| | | | * | | | | | Merge default into bug 23554 | Matthew Sackman | 2010-12-06 | 9 | -54/+73 |
| | | | |\ \ \ \ \ | |||||
| | | | | * \ \ \ \ | Merge default into bug 23554 (epic debitrot) | Matthew Sackman | 2010-12-06 | 17 | -420/+851 |
| | | | | |\ \ \ \ \ | |||||
| | | | | * | | | | | | Exposing the publishing chpid right through to the BQ (and tidying up ↵ | Matthew Sackman | 2010-11-30 | 7 | -40/+45 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | tests/types/specs) | ||||
| | | | | * | | | | | | Make the tests work again. Also mirror_pids => extra_pids on the basis that ↵ | Matthew Sackman | 2010-11-29 | 5 | -10/+14 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it could be reusable for other purposes | ||||
| | | | | * | | | | | | Lesser of many evils... | Matthew Sackman | 2010-11-29 | 4 | -9/+13 |
| | | | | | | | | | | | |||||
| | | | | * | | | | | | Present the whole amqqueue record to the BQ (remove duplicated IsDurable ↵ | Matthew Sackman | 2010-11-29 | 5 | -11/+9 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | flag, correct BQ callbacks) | ||||
| | | | | * | | | | | | Present the whole amqqueue record to the BQ | Matthew Sackman | 2010-11-29 | 3 | -5/+5 |
| | | | | | | | | | | | |||||
| | | | | * | | | | | | Added mechanism to dynamically choose the backing queue module. Ideally, ↵ | Matthew Sackman | 2010-11-29 | 1 | -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 default | Matthias Radestock | 2010-12-20 | 7 | -17/+49 |
| |\ \ \ \ \ \ \ \ \ \ | |||||
| | * | | | | | | | | | | Oops | Simon MacMullen | 2010-12-20 | 1 | -1/+1 |
| | | | | | | | | | | | | |||||
| | * | | | | | | | | | | merge heads | Matthias Radestock | 2010-12-20 | 1 | -1/+1 |
| | |\ \ \ \ \ \ \ \ \ \ | | | |_|_|_|_|_|_|_|/ | | |/| | | | | | | | | |||||
| | * | | | | | | | | | | Merge bug23358 into default | Simon MacMullen | 2010-12-20 | 2 | -6/+12 |
| | |\ \ \ \ \ \ \ \ \ \ | |||||
| | * | | | | | | | | | | | rabbit_misc:rs/1 | Simon MacMullen | 2010-12-20 | 1 | -6/+3 |
| | | | | | | | | | | | | | |||||
| | * | | | | | | | | | | | Legible error message. | Simon MacMullen | 2010-12-20 | 1 | -3/+6 |
| | | | | | | | | | | | | | |||||
| | * | | | | | | | | | | | Tone down the name a bit | Simon MacMullen | 2010-12-20 | 1 | -2/+2 |
| | | | | | | | | | | | | | |||||
