diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-06-26 16:39:09 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-06-26 16:39:09 +0100 |
| commit | d8b3b025dee868c68a77774916d8549f3838a32d (patch) | |
| tree | 637fb88de541c05383f1929b558cdcca62c1435a | |
| parent | 7745cbd876ae61344a3a8485c9456b39a10605cc (diff) | |
| download | rabbitmq-server-d8b3b025dee868c68a77774916d8549f3838a32d.tar.gz | |
Oops
| -rw-r--r-- | src/priority_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/priority_queue.erl b/src/priority_queue.erl index 0ffd208a..3c46c4ce 100644 --- a/src/priority_queue.erl +++ b/src/priority_queue.erl @@ -154,7 +154,7 @@ out({pqueue, [{P, Q} | Queues]}) -> {R, NewQ}. out_p({queue, _, _, _} = Q) -> add_p(out(Q), 0); -out_p({pqueue, [{P, _} | _]} = Q) -> add_p(out(Q), P). +out_p({pqueue, [{P, _} | _]} = Q) -> add_p(out(Q), maybe_negate_priority(P)). add_p(R, P) -> case R of {empty, Q} -> {empty, Q}; |