summaryrefslogtreecommitdiff
path: root/src/rabbit_mirror_queue_sync.erl
Commit message (Expand)AuthorAgeFilesLines
* Consume and handle {run_backing_queue, _, _} messages.bug25788Simon MacMullen2014-11-141-0/+3
* Use a new function introduced on defaultSimon MacMullen2014-10-101-2/+1
* Defend against partitions at the wrong time causing badness.Simon MacMullen2014-10-081-6/+18
* Revert changes to add proc_name via gen_server2, instead do it explicitly wit...bug25910Simon MacMullen2014-01-101-1/+1
* Add queue_coordinator / queue_syncer / gm. Shift to getting gen_server2 to st...Simon MacMullen2013-12-101-4/+8
* s/VMware/GoPivotal/gSimon MacMullen2013-07-011-2/+2
* populate slave's msg_id_ack with sync'ed messages pending ackbug25394Matthias Radestock2013-01-191-21/+24
* eager sync of messages pending ackMatthias Radestock2013-01-191-10/+16
* pass 'unacked' flag to BQ:fold funMatthias Radestock2013-01-151-1/+1
* Merge defaultSimon MacMullen2013-01-071-2/+1
|\
| * tweak loggingbug24407Matthias Radestock2013-01-041-2/+1
* | Merge in bug24407.Simon MacMullen2013-01-041-13/+32
|\ \ | |/ |/|
| * refactor: extract stop_syncer functionMatthias Radestock2013-01-011-10/+9
| * oopsMatthias Radestock2013-01-011-1/+1
| * better fun namesMatthias Radestock2013-01-011-6/+6
| * merge bug24407 into bug25345Matthias Radestock2012-12-301-9/+31
| |\
| | * Emit an info item as soon as we start, for greater responsiveness.Simon MacMullen2012-12-141-6/+8
| | * Fix accidental changeSimon MacMullen2012-12-141-1/+1
| | * Cancel syncSimon MacMullen2012-12-141-4/+22
| | * ShorterSimon MacMullen2012-12-141-2/+2
| | * Ensure rabbitmqctl list_queues remains responsive during sync, and emit stats...Simon MacMullen2012-12-141-8/+10
* | | cosmetic(ish)Matthias Radestock2013-01-041-1/+1
* | | cosmeticMatthias Radestock2013-01-031-3/+2
* | | simplify syncerMatthias Radestock2013-01-031-33/+23
* | | make credit waiting less brittleMatthias Radestock2013-01-031-11/+10
* | | Specs.Simon MacMullen2013-01-031-0/+19
* | | Consistency with the real slave.Simon MacMullen2013-01-031-2/+2
* | | Explain whySimon MacMullen2013-01-031-0/+1
|/ /
* | cosmetic(ish) refactors on mq_sync:master_sendMatthias Radestock2012-12-301-10/+9
|/
* It's important to respond to this too.Simon MacMullen2012-12-141-1/+4
* Add rabbitmqctl sync_queue, and make it synchronous. Also fix the fact that w...Simon MacMullen2012-12-061-1/+10
* Normalise credit flow quantities.Simon MacMullen2012-12-051-2/+2
* correct docs for final handshakeMatthias Radestock2012-11-291-0/+1
* handle the case of the Syncer dying right at the endMatthias Radestock2012-11-291-15/+20
* cosmeticMatthias Radestock2012-11-291-4/+4
* extract loggingMatthias Radestock2012-11-291-18/+12
* no more unused varsMatthias Radestock2012-11-291-1/+1
* Don't do anything if we decided not to do anything.Simon MacMullen2012-11-291-1/+1
* Update diagram.Simon MacMullen2012-11-291-2/+4
* Call get_parent/0 less often...Simon MacMullen2012-11-291-6/+6
* Respond to FHC.Simon MacMullen2012-11-291-1/+7
* Only respond to 'EXIT's from parent / syncer.Simon MacMullen2012-11-291-6/+10
* Have slaves determine whether they need sync.Simon MacMullen2012-11-291-15/+29
* Reverse master/syncer communication.Simon MacMullen2012-11-291-5/+8
* Merge in default, and use the fold-stop thing rather than throwing.Simon MacMullen2012-11-291-12/+15
* cosmeticMatthias Radestock2012-11-281-4/+1
* There is no TRef1.Simon MacMullen2012-11-281-2/+2
* Unshorten name.Simon MacMullen2012-11-281-2/+2
* We should flush here too, to not leave a junk 'DOWN' message when the syncer ...Simon MacMullen2012-11-281-2/+1
* OopsSimon MacMullen2012-11-281-1/+1