summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* oopsbug25386Matthias Radestock2013-01-071-4/+3
|
* get rid of #tx{}Matthias Radestock2013-01-071-39/+38
| | | | and fix uncommitted_acks info item
* simplify & document orderingMatthias Radestock2013-01-071-17/+19
|
* record pending acks in a queue rather than set in queue processMatthias Radestock2013-01-072-28/+53
| | | | | | | | Just as we do in the channel; this is more efficient for the typical ack-in-order access pattern. We depend on tags being passed to the queue process in order when ack'ing/rejecting. This requires some slightly fiddly code in the channel.
* optimise ack collectionMatthias Radestock2013-01-061-3/+9
| | | | for the common case of ack'ing/reject'ing the oldest tag
* optimise rabbit_channel:ack/2Matthias Radestock2013-01-061-29/+26
| | | | | | | | - moving the ?INCR_STATS call inside the fold_per_queue fun reduces consing when stats are disabled - since this was the only call to fold_per_queue where we cared about the result, and we no longer do, we can switch the 'fold' to 'foreach'
* restrict previous optimisation, for better workingnessMatthias Radestock2013-01-061-1/+3
|
* cosmeticMatthias Radestock2013-01-061-1/+1
|
* optimise "no confirms" case of rabbit_amqqueue_process:discardMatthias Radestock2013-01-061-4/+7
|
* optimise "route to no queues" pathMatthias Radestock2013-01-061-0/+4
|
* common-case optimisations for delegate:invoke[_no_result]Matthias Radestock2013-01-061-0/+12
|
* optimise rabbit_amqqueue:qpids/1 common caseMatthias Radestock2013-01-051-0/+2
|
* optimisation: improve performance of permission cacheMatthias Radestock2013-01-051-9/+7
| | | | | | Don't update the cache when the permission is already in it. This saves list munching and a 'put' at the expense of no longer being strictly LRU, but that only affects pathological cases.
* refactor gen_server2 debug handlingMatthias Radestock2013-01-051-38/+22
| | | | | | - more uniformity - less code duplication - less closure creation -> performance increase
* optimisation: shrink gen_server2 state slightlyMatthias Radestock2013-01-051-18/+14
| | | | for a (very) modest performance gain, and slightly neater code
* refactor queue initialisationMatthias Radestock2013-01-041-34/+16
| | | | | - get rid of all the 'undefined' setting, since that's the default - extract commonality of state initialisation
* merge bug24407 into defaultMatthias Radestock2013-01-048-30/+412
|\
| * tweak loggingbug24407Matthias Radestock2013-01-041-2/+1
| |
| * cosmetic(ish)Matthias Radestock2013-01-041-1/+1
| |
| * cosmeticMatthias Radestock2013-01-031-3/+2
| |
| * simplify syncerMatthias Radestock2013-01-031-33/+23
| | | | | | | | we don't need to track monitors
| * make credit waiting less brittleMatthias Radestock2013-01-032-12/+11
| | | | | | | | | | | | | | | | | | | | | | | | We were relying on running out of credit for all slaves *simultaneously*, which requires in-depth knowledge of the credit flow logic and that no other credit-requiring messages are sent to a slave prior to this. Fortunately, since we are running in a fresh separate process we can simply handle *any* credit bumping message and *any* DOWN message. As a bonus we can revert to making the type of the bump msg opaque.
| * fix bug found by dialyzerMatthias Radestock2013-01-031-2/+2
| |
| * bring up to date with 'default'Matthias Radestock2013-01-031-1/+1
| |
| * merge default into bug24407Matthias Radestock2013-01-0325-615/+677
| |\
| * | Specs.Simon MacMullen2013-01-033-1/+22
| | |
| * | Don't use a closure for the usual cluster upgrade reasons.Simon MacMullen2013-01-031-4/+7
| | |
| * | API consistency.Simon MacMullen2013-01-032-12/+8
| | |
| * | 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
| | | | | | | | | | | | | | | | | | - more sensible arg order (a folding function should generally take the element first and the acc last) - somewhat neater handling of the acc
| * | correct docs to reflect idempotenceMatthias Radestock2012-12-301-3/+2
| | |
| * | consistencyMatthias Radestock2012-12-301-1/+1
| | |
| * | It's important to respond to this too.Simon MacMullen2012-12-141-1/+4
| | |
| * | Make syncing idempotent.Simon MacMullen2012-12-062-3/+2
| | |
| * | Add rabbitmqctl sync_queue, and make it synchronous. Also fix the fact that ↵Simon MacMullen2012-12-066-14/+67
| | | | | | | | | | | | we were treating "no queues to sync" as a 'normal' crash of the syncer, which... no.
| * | 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
| | | | | | | | | | | | | | | | | | which could previously leave the master blocked, waiting for 'next'. And move the unlinking, which allows us to ensure we don't end up with stray 'EXIT's.
| * | cosmeticMatthias Radestock2012-11-291-4/+4
| | |
| * | extract loggingMatthias Radestock2012-11-292-26/+21
| | |
| * | no more unused varsMatthias Radestock2012-11-291-1/+1
| | |
| * | Don't do anything if we decided not to do anything.Simon MacMullen2012-11-292-1/+2
| | |
| * | Merge headsSimon MacMullen2012-11-291-26/+17
| |\ \
| | * | cosmetic, plus correctly identify provenanceMatthias Radestock2012-11-291-26/+17
| | | |
| * | | Set depth_delta to undefined if something goes wrong. Or indeed if something ↵Simon MacMullen2012-11-291-4/+3
| |/ / | | | | | | | | | goes right, but in that case we are about to overwrite it.
| * | Update diagram.Simon MacMullen2012-11-291-2/+4
| | |
| * | Make sure newly-started slaves don't respond and confuse things.Simon MacMullen2012-11-292-3/+6
| | |
| * | Call get_parent/0 less often...Simon MacMullen2012-11-291-6/+6
| | |
| * | Respond to FHC.Simon MacMullen2012-11-291-1/+7
| | |