diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-03-31 13:18:07 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-03-31 13:18:07 +0100 |
| commit | 97e12e6817e01e4fff9411eecfc777e218af9633 (patch) | |
| tree | 2a9c4ae1e6ef07b25c3644c6473fc9256ddd97b4 /src/priority_queue.erl | |
| parent | 6cb73add3a0ec8e5ce619d65e3939299fdbfb3f5 (diff) | |
| download | rabbitmq-server-97e12e6817e01e4fff9411eecfc777e218af9633.tar.gz | |
fix bug
Diffstat (limited to 'src/priority_queue.erl')
| -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 1ad4b34a..226c6bd8 100644 --- a/src/priority_queue.erl +++ b/src/priority_queue.erl @@ -81,7 +81,7 @@ len({pqueue, Queues}) -> to_list({queue, In, Out}) when is_list(In), is_list(Out) -> [{0, V} || V <- Out ++ lists:reverse(In, [])]; to_list({pqueue, Queues}) -> - [{-P, V} || {P, Q} <- Queues, V <- to_list(Q)]. + [{-P, V} || {P, Q} <- Queues, {0, V} <- to_list(Q)]. in(Item, Q) -> in(Item, 0, Q). |