summaryrefslogtreecommitdiff
path: root/src/rabbit_mirror_queue_master.erl
Commit message (Expand)AuthorAgeFilesLines
* HA optimisation: don't broadcast 'drop' when nothing has been droppedMatthias Radestock2012-10-311-1/+4
* Since bug 25243 we can never have the situation described in that comment - s...Simon MacMullen2012-10-291-3/+3
* publish_delivered(false, ...) -> discardMatthias Radestock2012-10-161-31/+28
* cosmeticbug25202Matthias Radestock2012-10-161-4/+3
* Make sure we don't stomp on GMPids if a slave manages to get to Mnesia before...Simon MacMullen2012-10-161-3/+6
* merge default into bug25202Matthias Radestock2012-10-161-2/+4
|\
| * monitor channel on discardbug25222Matthias Radestock2012-10-121-2/+4
* | Merge in default.Simon MacMullen2012-10-101-9/+11
|\ \ | |/
| * Removing the ExtraNodes stuff unmasked another bug: we weren't cleaning up sl...bug25210Simon MacMullen2012-10-081-1/+11
* | Clean up after we stop mirroring.Simon MacMullen2012-10-101-2/+10
* | CosmeticSimon MacMullen2012-10-101-1/+1
* | Merge in bug25195.Simon MacMullen2012-10-101-0/+6
|\ \ | |/ |/|
| * Progress towards storing a GM pid -> queue pid mapping. This is dependent on ...Simon MacMullen2012-10-031-2/+9
* | Do not start slaves in init_with_existing_bq/3 since we will only get here vi...Simon MacMullen2012-10-051-6/+7
* | consistencyMatthias Radestock2012-10-031-6/+6
|/
* Merge in defaultbug25198Simon MacMullen2012-10-021-7/+11
|\
| * requeue unacked messages earlier during promotionMatthias Radestock2012-10-011-7/+11
* | Merge defaultbug24908Simon MacMullen2012-10-021-16/+29
|\ \
| * | Start new slaves in response to gm deaths a bit later, to prevent deadlock. A...Simon MacMullen2012-09-201-1/+1
| * | Merge in defaultSimon MacMullen2012-09-191-2/+5
| |\ \
| * \ \ Merge defaultSimon MacMullen2012-09-141-17/+29
| |\ \ \
| | * | | GahSimon MacMullen2012-09-051-2/+1
| | * | | No we don't. The point is that if a mirror is dropping out of the queue, does...Simon MacMullen2012-09-051-1/+0
| | * | | Add specs, remove misleading "%% temp" comment.Simon MacMullen2012-09-051-1/+3
| | * | | Merge defaultSimon MacMullen2012-08-151-17/+29
| | |\ \ \
| | | * | | Various fixes.Simon MacMullen2012-07-091-1/+1
| | | * | | Dynamic change of HA policy. Promotion from non-HA to master, and demotion fr...Simon MacMullen2012-07-061-13/+29
| | | * | | Rename function, remove utter rubbish.Simon MacMullen2012-07-061-1/+1
| | | * | | Rough sketch of dynamic queue HA-ness:Simon MacMullen2012-07-051-7/+3
* | | | | | cosmeticMatthias Radestock2012-10-011-2/+1
* | | | | | cosmetic(ish)Matthias Radestock2012-10-011-13/+4
| |_|_|_|/ |/| | | |
* | | | | merge bug25145 into defaultMatthias Radestock2012-09-271-11/+10
|\ \ \ \ \
| * | | | | improve workingnessMatthias Radestock2012-09-241-6/+5
| | |_|_|/ | |/| | |
* | | | | Let's try that again: we no longer need to use confirmed_broadcast here due t...Simon MacMullen2012-09-261-4/+1
* | | | | Mark enqueued-on-promotion messages as redeliveredSimon MacMullen2012-09-261-5/+5
|/ / / /
* | | | Merged bug25144Emile Joubert2012-09-181-1/+4
|\ \ \ \ | |/ / / |/| | |
| * | | Remove the Mnesia record after we are done with it.bug25144Simon MacMullen2012-09-131-1/+4
| |/ /
* | | cosmeticsFrancesco Mazzoli2012-09-041-2/+1
* | | track the delta of the depths, and replace `pending_ack' with `depth' in BQFrancesco Mazzoli2012-09-041-13/+6
* | | store the depth of master and slave instead of the unknown pending msgsFrancesco Mazzoli2012-09-031-5/+12
* | | `set_length' => `drop'Francesco Mazzoli2012-08-311-2/+2
* | | get the external pending acks at the beginningFrancesco Mazzoli2012-08-311-3/+4
* | | add a callback to backing queue to get the number of pending acksFrancesco Mazzoli2012-08-311-2/+5
* | | take into account requeues when setting synch state for slavesFrancesco Mazzoli2012-08-301-4/+4
|/ /
* | propagate API changeMatthias Radestock2012-08-121-3/+3
|/
* It probably makes slightly more sense to monitor before we broadcast.bug24988Simon MacMullen2012-06-261-1/+1
* And finally, have the master wait for all the slaves on deletion.Simon MacMullen2012-06-251-0/+11
* AckMsgs -> AckRequired in master:purgeFrancesco Mazzoli2012-04-231-1/+1
* merge bug24885Francesco Mazzoli2012-04-231-2/+2
|\
| * Explicitly acking/not acking when calling bq:fetch in set_length in an HA slaveFrancesco Mazzoli2012-04-191-2/+2