diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-05-04 17:55:52 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-05-04 17:55:52 +0100 |
| commit | f78fd8fdf03f7081973bcf39e71276bf48f60a2d (patch) | |
| tree | 5faa624531a2c5cf702baea5ea630b7c92822276 /src/bpqueue.erl | |
| parent | 9f463b31b70e35f8983181f7ab9f431704fbc9a3 (diff) | |
| download | rabbitmq-server-git-f78fd8fdf03f7081973bcf39e71276bf48f60a2d.tar.gz | |
cosmetic
Diffstat (limited to 'src/bpqueue.erl')
| -rw-r--r-- | src/bpqueue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/bpqueue.erl b/src/bpqueue.erl index 7acc969754..9cd0f23021 100644 --- a/src/bpqueue.erl +++ b/src/bpqueue.erl @@ -111,7 +111,8 @@ in_q(Prefix, Queue, BPQ = {0, Q}) -> N -> {N, queue:in({Prefix, Queue}, Q)} end; in_q(Prefix, Queue, BPQ) -> - in_q1({fun queue:in/2, fun queue:out_r/1, fun queue:join/2}, + in_q1({fun queue:in/2, fun queue:out_r/1, + fun queue:join/2}, Prefix, Queue, BPQ). in_q_r(Prefix, Queue, BPQ = {0, _Q}) -> @@ -232,7 +233,8 @@ to_list1({Prefix, InnerQ}) -> map_fold_filter_l(_PFilter, _Fun, Init, BPQ = {0, _Q}) -> {BPQ, Init}; map_fold_filter_l(PFilter, Fun, Init, {N, Q}) -> - map_fold_filter1({fun queue:out/1, fun queue:in/2, fun in_q/3, fun join/2}, + map_fold_filter1({fun queue:out/1, fun queue:in/2, + fun in_q/3, fun join/2}, N, PFilter, Fun, Init, Q, new()). map_fold_filter_r(_PFilter, _Fun, Init, BPQ = {0, _Q}) -> |