diff options
| author | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-05-13 12:13:43 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana.corbacho@erlang-solutions.com> | 2016-05-13 12:13:43 +0100 |
| commit | 8e9ec88fb5ad318cf636770e95bda7c70400a5fb (patch) | |
| tree | 2a54b116d7ea3f12a39cafdcd3b080e84739e602 /src | |
| parent | a1f47b536546278374c77721fb952940d5bcec03 (diff) | |
| download | rabbitmq-server-git-8e9ec88fb5ad318cf636770e95bda7c70400a5fb.tar.gz | |
Limit priority to maximum during synchronisation
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_priority_queue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_priority_queue.erl b/src/rabbit_priority_queue.erl index b58a8c535e..6141796f7b 100644 --- a/src/rabbit_priority_queue.erl +++ b/src/rabbit_priority_queue.erl @@ -563,8 +563,9 @@ findfold3(Fun, Acc, NotFound, [{P, BQSN} | Rest], BQSAcc) -> findfold3(_Fun, Acc, NotFound, [], BQSAcc) -> {NotFound, Acc, lists:reverse(BQSAcc)}. -bq_fetch(P, []) -> exit({not_found, P}); +bq_fetch(P, []) -> exit({not_found, P}); bq_fetch(P, [{P, BQSN} | _]) -> BQSN; +bq_fetch(P, [{P1, BQSN} | _]) when P > P1 -> BQSN; bq_fetch(P, [{_, _BQSN} | T]) -> bq_fetch(P, T). bq_store(P, BQS, BQSs) -> |