diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-14 10:48:28 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-03-14 10:48:28 +0000 |
| commit | e413f6029a199c1906e5c60f7de1f4fd0cd1cccf (patch) | |
| tree | c065e86dd5b78c900536cff10d1820fe717ebc68 /src | |
| parent | bba11517f66b618bf9d07159ee6d1c3588917e41 (diff) | |
| download | rabbitmq-server-git-e413f6029a199c1906e5c60f7de1f4fd0cd1cccf.tar.gz | |
Fix
Diffstat (limited to 'src')
| -rw-r--r-- | src/file_handle_cache.erl | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl index b26bb9884b..eed62729c9 100644 --- a/src/file_handle_cache.erl +++ b/src/file_handle_cache.erl @@ -970,12 +970,13 @@ queue_fold(Fun, Init, Q) -> filter_pending(Fun, {Count, Queue}) -> {Delta, Queue1} = - queue_fold(fun (Item, {DeltaN, QueueN}) -> - case Fun(Item) of - true -> {DeltaN, queue:in(Item, QueueN)}; - false -> {DeltaN - requested(Item), QueueN} - end - end, {0, queue:new()}, Queue), + queue_fold( + fun (Item = #pending { requested = Requested }, {DeltaN, QueueN}) -> + case Fun(Item) of + true -> {DeltaN, queue:in(Item, QueueN)}; + false -> {DeltaN - Requested, QueueN} + end + end, {0, queue:new()}, Queue), {Count + Delta, Queue1}. pending_new() -> @@ -1021,9 +1022,6 @@ adjust_alarm(OldState, NewState) -> end, NewState. -requested({_Kind, _Pid, Requested, _From}) -> - Requested. - process_pending(State = #fhc_state { limit = infinity }) -> State; process_pending(State) -> |