summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* filter out pending acks when folding over deltabug25400Matthias Radestock2013-01-151-6/+14
|
* testMatthias Radestock2013-01-151-23/+10
|
* much more thorough testing of vq:requeueMatthias Radestock2013-01-151-21/+62
| | | | improving code coverage
* improve assertion in vq:fold testMatthias Radestock2013-01-141-2/+6
|
* improve vq:fold testMatthias Radestock2013-01-141-8/+16
| | | | by placing some messages in q1
* oops; nuke unused varMatthias Radestock2013-01-121-1/+1
|
* extract a vq helper fun for constructing a msg_statusMatthias Radestock2013-01-121-21/+24
|
* cosmeticMatthias Radestock2013-01-121-6/+6
|
* unmodalise vq:read_msgMatthias Radestock2013-01-121-27/+27
|
* cosmetic renameMatthias Radestock2013-01-101-9/+8
|
* merge bug25345 into defaultMatthias Radestock2013-01-094-198/+236
|\
| * merge headsMatthias Radestock2013-01-081-11/+10
| |\
| | * merge stable into defaultMatthias Radestock2013-01-0827-1014/+1627
| | |\
| | | * merge stable into defaultMatthias Radestock2013-01-081-7/+10
| | | |\
| | * | \ merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
| | |\ \ \ | | | | |/ | | | |/|
| | | * | merge bug25353 into stableMatthias Radestock2013-01-081-1/+1
| | | |\ \
| | * | | | tidy upbug25353Matthias Radestock2013-01-081-4/+0
| | |/ / /
| | * | | copy change from rabbit_amqqueue_process to slaveMatthias Radestock2013-01-081-7/+9
| | | | | | | | | | | | | | | | | | | | for consistency
| * | | | Merged bug25327Emile Joubert2013-01-081-68/+65
| |\ \ \ \ | | |_|_|/ | |/| | |
| | * | | merge default into bug25327bug25327Matthias Radestock2013-01-0417-374/+745
| | |\ \ \
| | * | | | some more control flow abstractionMatthias Radestock2013-01-041-26/+21
| | | | | |
| | * | | | merge bug25372 into bug25327Matthias Radestock2013-01-021-64/+66
| | |\ \ \ \
| | | * | | | refactor: extract dead lettering commonalityMatthias Radestock2013-01-011-45/+35
| | | | | | |
| | | * | | | don't send dead-lettered messages to self() during 'reject' handlingMatthias Radestock2013-01-011-36/+33
| | | | | | | | | | | | | | | | | | | | | | | | | | | | since they all end up in the mailbox, consuming memory
| | | * | | | renameMatthias Radestock2013-01-011-7/+7
| | | | | | |
| | | * | | | merge default into bug25327Matthias Radestock2013-01-015-89/+101
| | | |\ \ \ \
| | | | * \ \ \ merge bug25372 into bug25327Matthias Radestock2013-01-015-43/+41
| | | | |\ \ \ \
| | | | * | | | | don't send expired messages to self() during bulk expiryMatthias Radestock2013-01-011-12/+35
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | since they all end up in the mailbox, consuming memory
| | | | * | | | | refactor: less passing around of State in dl publishingMatthias Radestock2013-01-011-14/+12
| | | | | | | | |
| | | | * | | | | merge default into bug25327Matthias Radestock2013-01-011-38/+31
| | | | |\ \ \ \ \
| | | | | * | | | | send expired messages to self() one at a timeMatthias Radestock2012-12-051-38/+31
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | which simplifies the code a fair bit and also means we don't build up a potentially huge intermediate data structure.
| * | | | | | | | | Merge bug25388Simon MacMullen2013-01-081-11/+15
| |\ \ \ \ \ \ \ \ \
| | * | | | | | | | | optimise vq:reduce_memory_use/4 invocationsMatthias Radestock2013-01-071-11/+15
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | by suppressing the call, and thus the closure creations, when target_ram_count == infinity
| * | | | | | | | | | get rid of vq's ram_ack_indexbug25388Matthias Radestock2013-01-071-59/+72
| |/ / / / / / / / / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | and instead track ram and disk acks in separate gb_trees, which is more efficient.
| * | | | | | | | | Merge bug25386Simon MacMullen2013-01-072-10/+12
| |\ \ \ \ \ \ \ \ \
| * | | | | | | | | | 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.
* | | | | | | | | | | Fix docs and specs.bug25345Simon MacMullen2013-01-082-3/+2
| | | | | | | | | | |
* | | | | | | | | | | tweak: make use of rabbit_misc:rs/1Matthias Radestock2013-01-071-3/+3
| | | | | | | | | | |
* | | | | | | | | | | merge default into bug25345Matthias Radestock2013-01-072-10/+12
|\ \ \ \ \ \ \ \ \ \ \ | | |/ / / / / / / / / | |/| | | | | | | | |
| * | | | | | | | | | tweak: make use of rabbit_misc:rs/1Matthias Radestock2013-01-071-3/+3
| | | | | | | | | | |
| * | | | | | | | | | Merge bug 25385 (into default, although it was branched from stable).Simon MacMullen2013-01-071-7/+9
| |\ \ \ \ \ \ \ \ \ \ | | |/ / / / / / / / / | |/| | | | | | | | |
| | * | | | | | | | | assert queue dlx arg equivalencebug25385Matthias Radestock2013-01-041-7/+9
| | | |_|_|_|_|_|_|/ | | |/| | | | | | | | | | | | | | | | | | | | | | | | | | | and restructure code to make future omissions less likely
* | | | | | | | | | IdempotenceSimon MacMullen2013-01-072-1/+7
| | | | | | | | | |
* | | | | | | | | | Merge defaultSimon MacMullen2013-01-077-140/+124
|\ \ \ \ \ \ \ \ \ \ | |/ / / / / / / / /
| * | | | | | | | | 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
| | | | | | | | | |
View Lorry Controller Status