summaryrefslogtreecommitdiff
path: root/src/rabbit_mirror_queue_master.erl
Commit message (Expand)AuthorAgeFilesLines
* Further refactoringbug25625Emile Joubert2013-07-021-9/+9
* RefactorEmile Joubert2013-07-011-4/+5
* Correction and contractionEmile Joubert2013-07-011-3/+2
* Optimisation for handling discarded deliveriesEmile Joubert2013-06-271-15/+7
* Stem leak when master deals with discarded messagesEmile Joubert2013-06-271-11/+9
* stable to defaultSimon MacMullen2013-01-241-1/+1
|\
| * Update copyright 2013bug25343Emile Joubert2013-01-231-1/+1
* | add BQ:purge_acks/1Matthias Radestock2013-01-191-1/+3
* | Merge in bug24407.Simon MacMullen2013-01-041-5/+8
|\ \
| * | better fun namesMatthias Radestock2013-01-011-2/+2
| * | Ensure rabbitmqctl list_queues remains responsive during sync, and emit stats...Simon MacMullen2012-12-141-3/+5
* | | merge default into bug24407Matthias Radestock2013-01-031-48/+42
|\ \ \
| * | | replace bq:foreach_ack with a more versatile ackfoldMatthias Radestock2013-01-011-7/+8
| * | | merge default into bug25328Matthias Radestock2012-11-301-13/+21
| |\ \ \
| | * | | return to a simpler, better BQ:dropwhile, and introduce 'fetchwhile'Matthias Radestock2012-11-291-19/+27
| * | | | remove unused state varMatthias Radestock2012-11-301-29/+14
| |/ / /
* | | | Specs.Simon MacMullen2013-01-031-0/+2
| |/ / |/| |
* | | Make syncing idempotent.Simon MacMullen2012-12-061-1/+1
* | | Add rabbitmqctl sync_queue, and make it synchronous. Also fix the fact that w...Simon MacMullen2012-12-061-5/+6
* | | extract loggingMatthias Radestock2012-11-291-8/+9
* | | Make sure newly-started slaves don't respond and confuse things.Simon MacMullen2012-11-291-1/+1
* | | Only respond to 'EXIT's from parent / syncer.Simon MacMullen2012-11-291-4/+7
* | | Have slaves determine whether they need sync.Simon MacMullen2012-11-291-17/+9
* | | Oops, didn't even compile that last one.Simon MacMullen2012-11-291-5/+8
* | | cosmeticMatthias Radestock2012-11-281-15/+13
* | | Diagram.Simon MacMullen2012-11-281-2/+0
* | | Don't expose the BQ to the syncer.Simon MacMullen2012-11-281-2/+2
* | | Spawn a separate process to send out messages from the master. This lets us s...Simon MacMullen2012-11-281-2/+3
* | | Various QA cleanupsSimon MacMullen2012-11-281-22/+31
* | | merge default into bug24407Matthias Radestock2012-11-271-1/+19
|\ \ \ | |/ / |/| |
| * | Move the sync stuff to its own moduleSimon MacMullen2012-11-261-72/+1
| * | Don't hang on shutdownSimon MacMullen2012-11-261-0/+6
| * | Merge in defaultSimon MacMullen2012-11-261-1/+84
| |\ \
| | * | Improve progfess logging.Simon MacMullen2012-11-261-14/+18
| | * | Send the sync_start over GM to flush out any other messages that we might hav...Simon MacMullen2012-11-261-2/+5
| | * | Fix bugs in previous commit, and be rather more thorough about monitoring and...Simon MacMullen2012-11-261-22/+43
| | * | Add spec, fix API, refuse to run if there are pending acks, return status, do...Simon MacMullen2012-11-261-6/+6
| | * | Fix expirySimon MacMullen2012-11-231-2/+2
| | * | Merge bug25303Simon MacMullen2012-11-231-1/+56
| | |\ \
| | | * | Flow control for the sync process.Simon MacMullen2012-11-231-1/+14
| | | * | Log progress, and an important optimisation.Simon MacMullen2012-11-231-7/+22
| | | * | Eager mirror synchronisation.Simon MacMullen2012-11-231-1/+28
* | | | | mark all messages enqueued in the slave as 'delivered'bug25323Matthias Radestock2012-11-261-26/+13
|/ / / /
* | | | merge bug25303 into defaultMatthias Radestock2012-11-231-1/+6
|\ \ \ \ | |/ / /
| * | | Propagate API changeEmile Joubert2012-11-231-1/+6
| |/ /
* | | Merged bug25315Emile Joubert2012-11-231-4/+4
|\ \ \ | |/ /
| * | Rename backing queue foldbug25314Emile Joubert2012-11-221-4/+4
* | | bq api tweak: don't include remaining message count in fetch/drop resultMatthias Radestock2012-11-221-17/+14
|/ /
* | introduce bq:drop/2 and use it in slaves to prevent msg fetchingMatthias Radestock2012-11-201-10/+28
|/
* HA optimisation: don't broadcast 'drop' when nothing has been droppedMatthias Radestock2012-10-311-1/+4