diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2014-02-24 12:55:37 +0000 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2014-02-24 12:55:37 +0000 |
commit | bc88561e6016b6c933d3cc73ff2a66693aedf4cd (patch) | |
tree | c487bfcd84c87f9a6a2f9ecbee0ef1fb10abe57a | |
parent | e5801702650cde6962eff9fdc2a54a5287828787 (diff) | |
download | rabbitmq-server-bug25994.tar.gz |
Sort by descending priority order, and add a comment.bug25994
-rw-r--r-- | src/rabbit_amqqueue_process.erl | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 11aabcd5..ec1a977d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -859,12 +859,21 @@ prioritise_cast(Msg, _Len, State) -> {set_ram_duration_target, _Duration} -> 8; {set_maximum_since_use, _Age} -> 8; {run_backing_queue, _Mod, _Fun} -> 6; - {ack, _AckTags, _ChPid} -> 3; - {notify_sent, _ChPid, _Credit} -> consumer_bias(State); + {ack, _AckTags, _ChPid} -> 3; %% [1] {resume, _ChPid} -> 2; + {notify_sent, _ChPid, _Credit} -> consumer_bias(State); _ -> 0 end. +%% [1] It should be safe to always prioritise ack / resume since they +%% will be rate limited by how fast consumers receive messages - +%% i.e. by notify_sent. We prioritise ack and resume to discourage +%% starvation caused by prioritising notify_sent. We don't vary their +%% prioritiy since acks should stay in order (some parts of the queue +%% stack are optimised for that) and to make things easier to reason +%% about. Finally, we prioritise ack over resume since it should +%% always reduce memory use. + consumer_bias(#q{backing_queue = BQ, backing_queue_state = BQS}) -> case BQ:msg_rates(BQS) of {0.0, _} -> 0; |