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 | 318b78e8b75e56cc2d726f2d1096abc52ebdd560 (patch) | |
| tree | 2a9c4ae1e6ef07b25c3644c6473fc9256ddd97b4 /src | |
| parent | d36d44d4b9b91ddf396226fdff139688c2bbabcb (diff) | |
| download | rabbitmq-server-git-318b78e8b75e56cc2d726f2d1096abc52ebdd560.tar.gz | |
fix bug
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 1ad4b34a9a..226c6bd866 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). |