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 | f33d2ab02311bfe23b7c450a8ca604b5619109a2 (patch) | |
| tree | 637fb88de541c05383f1929b558cdcca62c1435a /src | |
| parent | ea62758fb589b689a939d4da129d1e74ea8280e9 (diff) | |
| download | rabbitmq-server-git-f33d2ab02311bfe23b7c450a8ca604b5619109a2.tar.gz | |
Oops
Diffstat (limited to 'src')
| -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 0ffd208a5b..3c46c4cee2 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}; |