| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Explain | Simon MacMullen | 2012-10-03 | 1 | -0/+6 |
| | | |||||
| * | distinguish between deliveries to masters and slaves | Matthias Radestock | 2012-10-03 | 3 | -20/+35 |
| | | | | | | ...thus allowing us to set the 'delivered' flag correctly for messages that were in flight during a promotion | ||||
| * | cosmetic | Matthias Radestock | 2012-10-02 | 1 | -10/+7 |
| | | |||||
| * | Merge bug25198 | Simon MacMullen | 2012-10-02 | 0 | -0/+0 |
| |\ | |||||
| * \ | Merge in default | Simon MacMullen | 2012-10-02 | 3 | -29/+25 |
| |\ \ | |/ |/| | |||||
| | * | remove gratuitous ack numbering | Matthias Radestock | 2012-10-02 | 1 | -10/+5 |
| | | | | | | | | | | | the sole purpose of which was to sort the acktags by that number, which serves no purpose whatsoever. | ||||
| | * | requeue unacked messages earlier during promotion | Matthias Radestock | 2012-10-01 | 3 | -19/+20 |
| | | | | | | | | | | | | | | | | | | | | | ...so that the set_delivered marker is set correctly. Note that - there is no need to sort AckTags - BQ:requeue doesn't care about the order in which it is given the tags. - we don't need to 'run the backing queue' / 'run the message queue' when requeuing since there are no consumers. But we *do* need to drop expired messages; process_args takes care of that already. | ||||
| * | | merge bug25184 into default | Matthias Radestock | 2012-10-02 | 1 | -9/+15 |
| |\ \ | |||||
| | * | | comments, also wait for tables right after you load them | Francesco Mazzoli | 2012-10-02 | 1 | -2/+9 |
| | | | | |||||
| | * | | cosmetics | Francesco Mazzoli | 2012-10-02 | 1 | -7/+6 |
| | | | | |||||
| | * | | wait for tables, not for mnesia | Francesco Mazzoli | 2012-10-02 | 1 | -1/+1 |
| | | | | |||||
| | * | | simplify `leave_cluster/0' | Francesco Mazzoli | 2012-10-02 | 1 | -4/+4 |
| |/ / | |||||
| * | | merge bug24908 into default | Tim Watson | 2012-10-02 | 10 | -157/+326 |
| |\ \ | |||||
| | * \ | Merge default | Simon MacMullen | 2012-10-02 | 10 | -157/+326 |
| | |\ \ |/ / / | |||||
| | * | | Don't throw, rabbit_amqqueue:with/2 will eat it. | Simon MacMullen | 2012-09-28 | 1 | -1/+1 |
| | | | | |||||
| | * | | Ignore if the node is down. | Simon MacMullen | 2012-09-28 | 1 | -1/+9 |
| | | | | |||||
| | * | | Assert a bit here too. | Simon MacMullen | 2012-09-28 | 1 | -1/+1 |
| | | | | |||||
| | * | | We want to catch here, if sup:start_child exits the rabbit_amqqueue:with we ↵ | Simon MacMullen | 2012-09-28 | 1 | -1/+1 |
| | | | | | | | | | | | | | are in will convert any exit to not_found. Which is unlikely to be helpful | ||||
| | * | | Merge in default | Simon MacMullen | 2012-09-28 | 10 | -155/+316 |
| | |\ \ | |||||
| | | * \ | Merge in default | Simon MacMullen | 2012-09-25 | 10 | -156/+316 |
| | | |\ \ | |||||
| | | | * | | Handle the case where we go from unmirrored(A) to nodes(B, C). | Simon MacMullen | 2012-09-20 | 1 | -1/+8 |
| | | | | | | |||||
| | | | * | | "nodes" policy should not suggest nodes which are not running. Also if nodes ↵ | Simon MacMullen | 2012-09-20 | 2 | -5/+19 |
| | | | | | | | | | | | | | | | | | | | | | policy is completely unconnected with reality, just keep the master alive rather than blow up. | ||||
| | | | * | | That case was originally written to cover the unmirrored case - but actually ↵ | Simon MacMullen | 2012-09-20 | 1 | -2/+0 |
| | | | | | | | | | | | | | | | | | | | | | the queue might be mirrored but with no slaves, or about to become mirrored, or whatever. And our is_process_alive() check serves the same purpose. | ||||
| | | | * | | Start new slaves in response to gm deaths a bit later, to prevent deadlock. ↵ | Simon MacMullen | 2012-09-20 | 4 | -32/+27 |
| | | | | | | | | | | | | | | | | | | | | | Also remove {add,drop}_mirror/3 as not used, and don't export drop_mirror/2 as not used outside the module. | ||||
| | | | * | | That hack should not be needed any more. | Simon MacMullen | 2012-09-19 | 1 | -13/+7 |
| | | | | | | |||||
| | | | * | | Merge in default | Simon MacMullen | 2012-09-19 | 15 | -355/+364 |
| | | | |\ \ | |||||
| | | | * | | | Pull our attempts to list all nodes out of transactions and loops. | Simon MacMullen | 2012-09-18 | 1 | -5/+15 |
| | | | | | | | |||||
| | | | * | | | Simplify | Simon MacMullen | 2012-09-17 | 1 | -5/+1 |
| | | | | | | | |||||
| | | | * | | | Cope with the fact that rabbit_mnesia:running_clustered_nodes/0 now does not ↵ | Simon MacMullen | 2012-09-17 | 1 | -2/+11 |
| | | | | | | | | | | | | | | | | | | | | | | | | | include node() during boot. | ||||
| | | | * | | | Merge default | Simon MacMullen | 2012-09-17 | 9 | -134/+271 |
| | | | |\ \ \ | |||||
| | | | | * \ \ | Merge default | Simon MacMullen | 2012-09-14 | 9 | -134/+271 |
| | | | | |\ \ \ | |||||
| | | | | | * | | | cosmetic | Matthias Radestock | 2012-09-05 | 1 | -4/+2 |
| | | | | | | | | | |||||
| | | | | | * | | | Also exclude DeadNodes from the list of new nodes to start mirrors on; we ↵ | Simon MacMullen | 2012-09-05 | 1 | -1/+1 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | have checked for running_clustered_nodes() but that could be out of date. | ||||
| | | | | | * | | | Cosmetic: give that comment room to breath. | Simon MacMullen | 2012-09-05 | 1 | -20/+21 |
| | | | | | | | | | |||||
| | | | | | * | | | Call add_mirror/2 before drop_mirror/2, and explain why. | Simon MacMullen | 2012-09-05 | 1 | -1/+11 |
| | | | | | | | | | |||||
| | | | | | * | | | Gah | Simon MacMullen | 2012-09-05 | 2 | -4/+2 |
| | | | | | | | | | |||||
| | | | | | * | | | No we don't. The point is that if a mirror is dropping out of the queue, ↵ | Simon MacMullen | 2012-09-05 | 2 | -2/+0 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | does it need to explicitly leave the GM group? The answer is no: the master is linked to the coordinator is linked to the GM / the slave is linked to the GM. | ||||
| | | | | | * | | | Add specs, remove misleading "%% temp" comment. | Simon MacMullen | 2012-09-05 | 3 | -9/+15 |
| | | | | | | | | | |||||
| | | | | | * | | | Reduce difference to default | Simon MacMullen | 2012-09-05 | 1 | -3/+3 |
| | | | | | | | | | |||||
| | | | | | * | | | merge default into bug24908 | Matthias Radestock | 2012-09-04 | 9 | -136/+262 |
| | | | | | |\ \ \ | |||||
| | | | | | | * | | | more reification, plus cosmetics | Matthias Radestock | 2012-09-04 | 1 | -18/+13 |
| | | | | | | | | | | |||||
| | | | | | | * | | | Reify a touch more. | Simon MacMullen | 2012-09-04 | 1 | -5/+6 |
| | | | | | | | | | | |||||
| | | | | | | * | | | Suggest queue nodes based on running nodes, otherwise (at the very least) we ↵ | Simon MacMullen | 2012-08-23 | 1 | -1/+2 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | can immediately try to start a mirror on a node that has just gone down. | ||||
| | | | | | | * | | | Fix broken merge | Simon MacMullen | 2012-08-23 | 1 | -2/+2 |
| | | | | | | | | | | |||||
| | | | | | | * | | | s/at-least/exactly/g | Simon MacMullen | 2012-08-22 | 2 | -12/+12 |
| | | | | | | | | | | |||||
| | | | | | | * | | | Merge default | Simon MacMullen | 2012-08-21 | 10 | -173/+169 |
| | | | | | | |\ \ \ | |||||
| | | | | | | * | | | | at-least mode can imply that we need to start slaves in response to slaves ↵ | Simon MacMullen | 2012-08-17 | 1 | -10/+30 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | dying elsewhere. So do that. | ||||
| | | | | | | * | | | | Merge default | Simon MacMullen | 2012-08-15 | 9 | -125/+234 |
| | | | | | | |\ \ \ \ | |||||
| | | | | | | | * | | | | Reify something that was previously a little bit magic. | Simon MacMullen | 2012-08-07 | 2 | -6/+13 |
| | | | | | | | | | | | | |||||
| | | | | | | | * | | | | Support changing master (umm, which actually turned out to be a lot easier ↵ | Simon MacMullen | 2012-08-07 | 1 | -10/+7 |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | than expected, thanks Matthew). | ||||
