summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Make sure we update Mnesia when only the gm_pids have changed (i.e. we are ↵Simon MacMullen2012-10-101-1/+1
| | | | cleaning up a spare GM pid from when we found an existing slave at startup).
* Merge in default.Simon MacMullen2012-10-104-54/+45
|\
| * Fix spec broken by bug 25212Simon MacMullen2012-10-101-1/+2
| |
| * merge bug25210 into defaultTim Watson2012-10-090-0/+0
| |\
| * | Removing the ExtraNodes stuff unmasked another bug: we weren't cleaning up ↵Simon MacMullen2012-10-081-1/+11
| | | | | | | | | | | | slave_pids when stopping mirroring.
| * | Remove debugging code.Simon MacMullen2012-10-081-5/+2
| | |
| * | WIPSimon MacMullen2012-10-083-43/+35
| |/
* | Clean up after we stop mirroring.Simon MacMullen2012-10-101-2/+10
| |
* | Nicer.Simon MacMullen2012-10-101-1/+1
| |
* | CosmeticSimon MacMullen2012-10-101-1/+1
| |
* | Merge in bug25195.Simon MacMullen2012-10-106-16/+61
|\ \
| * | Progress towards storing a GM pid -> queue pid mapping. This is dependent on ↵Simon MacMullen2012-10-036-19/+65
| | | | | | | | | | | | not feeding the process_death message into remove_from_queue - bug 25195 suggests this might be TRTTD.
| * | Merge defaultSimon MacMullen2012-10-031-0/+1
| |\ \
| | * | Don't let the GM hang around. We exit(normal) it rather than tell it to ↵Simon MacMullen2012-10-021-0/+1
| | | | | | | | | | | | | | | | leave/1 since it really shouldn't be there, we want it to stop ASAP.
* | | | Unused var.Simon MacMullen2012-10-091-1/+0
| | | |
* | | | Remove this master_changed nonsense.Simon MacMullen2012-10-092-13/+0
| | | |
* | | | Ignore process_death, explain why.Simon MacMullen2012-10-091-4/+11
| |_|/ |/| |
* | | merge bug25212Tim Watson2012-10-050-0/+0
|\ \ \
* | | | Don't fail if the queue is already mirrored, tweak return values a bit.Simon MacMullen2012-10-051-8/+7
| | | |
* | | | Do not start slaves in init_with_existing_bq/3 since we will only get here ↵Simon MacMullen2012-10-051-6/+7
|/ / / | | | | | | | | | via rabbit_mirror_queue_misc:update_mirrors/2 which will start them anyway.
* | | consistencyMatthias Radestock2012-10-033-21/+21
| | |
* | | re-merge bug25200 into defaultMatthias Radestock2012-10-031-1/+2
|\ \ \ | |/ / |/| |
| * | cosmeticMatthias Radestock2012-10-031-1/+2
| | |
* | | Merge bug25200Simon MacMullen2012-10-032-15/+37
|\ \ \ | |/ / |/| |
| * | Merge bug25199Simon MacMullen2012-10-031-16/+14
| |\ \
| | * | get rid of all but one use of run_backing_queue and inline the latterMatthias Radestock2012-10-011-16/+14
| | | |
| * | | Merged bug25193Emile Joubert2012-10-032-0/+24
| |\ \ \
| | * | | More reasons.Simon MacMullen2012-10-031-3/+4
| | | | |
| | * | | Clearer?Simon MacMullen2012-10-011-5/+17
| | | | |
| | * | | active_consumers info item.Simon MacMullen2012-09-282-0/+11
| | | | |
* | | | | ExplainSimon MacMullen2012-10-031-0/+6
| | | | |
* | | | | distinguish between deliveries to masters and slavesMatthias Radestock2012-10-033-20/+35
|/ / / / | | | | | | | | | | | | | | | | ...thus allowing us to set the 'delivered' flag correctly for messages that were in flight during a promotion
* | | | cosmeticMatthias Radestock2012-10-021-10/+7
| | | |
* | | | Merge bug25198Simon MacMullen2012-10-020-0/+0
|\ \ \ \
* \ \ \ \ Merge in defaultSimon MacMullen2012-10-023-29/+25
|\ \ \ \ \ | |/ / / / |/| | | |
| * | | | remove gratuitous ack numberingMatthias Radestock2012-10-021-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 promotionMatthias Radestock2012-10-013-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 defaultMatthias Radestock2012-10-021-9/+15
|\ \ \ \ \ | |_|_|_|/ |/| | | |
| * | | | comments, also wait for tables right after you load themFrancesco Mazzoli2012-10-021-2/+9
| | | | |
| * | | | cosmeticsFrancesco Mazzoli2012-10-021-7/+6
| | | | |
| * | | | wait for tables, not for mnesiaFrancesco Mazzoli2012-10-021-1/+1
| | | | |
| * | | | simplify `leave_cluster/0'Francesco Mazzoli2012-10-021-4/+4
|/ / / /
* | | | merge bug24908 into defaultTim Watson2012-10-0210-157/+326
|\ \ \ \
| * \ \ \ Merge defaultSimon MacMullen2012-10-0210-157/+326
| |\ \ \ \ |/ / / / /
| * | | | Don't throw, rabbit_amqqueue:with/2 will eat it.Simon MacMullen2012-09-281-1/+1
| | | | |
| * | | | Ignore if the node is down.Simon MacMullen2012-09-281-1/+9
| | | | |
| * | | | Assert a bit here too.Simon MacMullen2012-09-281-1/+1
| | | | |
| * | | | We want to catch here, if sup:start_child exits the rabbit_amqqueue:with we ↵Simon MacMullen2012-09-281-1/+1
| | | | | | | | | | | | | | | | | | | | are in will convert any exit to not_found. Which is unlikely to be helpful
| * | | | Merge in defaultSimon MacMullen2012-09-2810-155/+316
| |\ \ \ \
| | * \ \ \ Merge in defaultSimon MacMullen2012-09-2510-156/+316
| | |\ \ \ \
View Lorry Controller Status