summaryrefslogtreecommitdiff
path: root/src/rabbit_amqqueue_process.erl
Commit message (Collapse)AuthorAgeFilesLines
* Merge stablebug25644Simon MacMullen2013-07-231-1/+1
|\
| * Get amqqueu_process to montor via delegate too, tighten delegate specs, ↵Simon MacMullen2013-07-041-1/+1
| | | | | | | | simplify pmon parameterisation.
* | Merge bug25625Simon MacMullen2013-07-021-4/+2
|\ \
| * | Further refactoringbug25625Emile Joubert2013-07-021-3/+1
| | |
| * | RefactorEmile Joubert2013-07-011-10/+3
| | |
| * | Correction and contractionEmile Joubert2013-07-011-2/+2
| | |
| * | Optimisation for handling discarded deliveriesEmile Joubert2013-06-271-2/+9
| | |
* | | Merged bug25645 into stableEmile Joubert2013-06-281-0/+1
|\ \ \ | |/ / |/| |
| * | BQ:is_empty/1.bug25645Simon MacMullen2013-06-271-1/+1
| | |
| * | Recreate that assertion up one level in the call stack, since the callers ↵Simon MacMullen2013-06-271-0/+1
| |/ | | | | | | may still care about it even though VQ itself does not.
* | Discard previously-discarded messages correctlybug25624Emile Joubert2013-06-261-1/+1
|/
* Merge bug25599Simon MacMullen2013-06-131-14/+25
|\
| * Adjust comment locationbug25599Emile Joubert2013-06-131-1/+1
| |
| * Comments, gen_server-like termination reason and less unnecessary delete ↵Emile Joubert2013-06-131-2/+3
| | | | | | | | guarding
| * RefactorEmile Joubert2013-06-131-16/+18
| |
| * Omit emitting stats for non-existent queues on terminationEmile Joubert2013-06-111-4/+9
| |
| * Clear exclusive durable queues on bootEmile Joubert2013-06-101-3/+6
| |
* | Merge heads of stableSimon MacMullen2013-06-101-4/+17
|\ \
| * | Simplify (and don't bother parsing to integer only to convert back).bug25588Simon MacMullen2013-06-101-7/+4
| | |
| * | allows log the per-msg-ttl if it is presentTim Watson2013-06-061-4/+1
| | |
| * | Cosmetic.Simon MacMullen2013-06-061-18/+15
| | |
| * | do not attempt to parse expiration from missing propertiesTim Watson2013-06-061-7/+13
| | |
| * | add original expiration to x-death headers on per-message-ttl expiryTim Watson2013-06-061-1/+13
| | |
| * | Remove expiration property from dead lettered messagesTim Watson2013-06-041-2/+6
| |/
* | Display pretty missing exclusive owner log messageEmile Joubert2013-06-101-1/+2
|/
* Clear queue expiry timer ref when firedbug25549Emile Joubert2013-05-091-1/+1
|
* merge bug25107 into defaultMatthias Radestock2013-04-251-106/+24
|\
| * Further excisionsbug25504Emile Joubert2013-04-161-4/+2
| |
| * Minimise diffEmile Joubert2013-04-051-1/+1
| |
| * DLX without confirmsEmile Joubert2013-04-041-103/+23
| |
* | Maybe clearer?bug25107Simon MacMullen2013-04-121-3/+7
| |
* | No, the newest dead letterings are at the head.Simon MacMullen2013-04-121-1/+1
| |
* | Only ban cycles that are entirely due to expirySimon MacMullen2013-04-121-10/+27
|/
* Merged default into bug24114bug24114Emile Joubert2013-03-251-109/+211
|\
| * re-introduce state-transition optimisation for possibly_unblockMatthias Radestock2013-03-211-23/+27
| |
| * Merge in defaultSimon MacMullen2013-03-211-0/+2
| |\
| | * Merge bug25461Simon MacMullen2013-03-211-0/+2
| | |\
| | | * Merge in defaultbug23378Simon MacMullen2013-03-211-13/+52
| | | |\
| | | * \ Merge in default.Simon MacMullen2013-02-251-48/+45
| | | |\ \
| | | * \ \ Merge defaultSimon MacMullen2013-01-231-0/+2
| | | |\ \ \
| | | | * | | Emit final stats event for connections, queues and channels just before the ↵Simon MacMullen2012-12-181-0/+2
| | | | | | | | | | | | | | | | | | | | | | | | | | | | deleted event.
| * | | | | | Cosmetic, reduce distance to bug25461, remove dead commentSimon MacMullen2013-03-211-15/+11
| | | | | | |
| * | | | | | Merge the two can_sends and tidy up.Simon MacMullen2013-03-211-7/+4
| | | | | | |
| * | | | | | First attempt at merging these two bugs; this compiles at least.Simon MacMullen2013-03-201-31/+101
| |\ \ \ \ \ \ | | |/ / / / / | |/| | | | |
| | * | | | | Merge in defaultSimon MacMullen2013-03-201-35/+103
| | |\ \ \ \ \ | | | |_|_|_|/ | | |/| | | |
| | | * | | | Remove blocked_ctags, and a few knock-on simplifications.Simon MacMullen2013-02-211-3/+3
| | | | | | |
| | | * | | | simplify queue's basic_consume handlerMatthias Radestock2013-02-211-15/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - the call to update_ch_record in the is_ch_blocked(C1) == false branch was superfluos since the preceding update_consumer_count calls update_ch_record - all the checking whether the channel is blocked, and associated branching was just an optimisation. And not a particularly important one, since a) the "a new consumer comes along while its channel is blocked" case is hardly on the critical path, and b) exactly the same check is performed as part of run_message_queue (in deliver_msg_to_consumer/3). So get rid of it. - the is_empty & send_drained logic can be invoked earlier, which allows us to use the #cr we have rather than looking it up again. We can do this since the only case we need to catch here is that of a consumer coming along while the queue is empty already. If it becomes empty as part of run_message_queue then send_drained will be invoked in 'fetch'.
| | | * | | | merge default into bug23749Matthias Radestock2013-02-201-1/+1
| | | |\ \ \ \
| | | * | | | | optimise possibly_unblockMatthias Radestock2013-02-201-15/+18
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | when the channel is blocked there is no point going through the expensive consumer re-partitioning
| | | * | | | | refactorMatthias Radestock2013-02-201-9/+6
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | it's convenient for callers to have maybe_send_drained thread through the state
View Lorry Controller Status