diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-05-14 01:12:09 +0800 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-05-14 01:12:09 +0800 |
| commit | 972039cc92eeb3e8e9e01e297330e7fc2ca02904 (patch) | |
| tree | b66e7b0c2c676dd0265d504065226346fbbea573 | |
| parent | b5b90e6aa88ac99682e156588eb52b3ac76ce375 (diff) | |
| parent | 5ea6f6ffdf780b014b86d7f9d0b1012360f7cc97 (diff) | |
| download | rabbitmq-server-git-972039cc92eeb3e8e9e01e297330e7fc2ca02904.tar.gz | |
Merge branch 'stable'
| -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) -> |