summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2010-08-20 16:08:26 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2010-08-20 16:08:26 +0100
commitd6222e5f8b3d1d7bc011655a8894eee2a0007429 (patch)
tree2ff5f73151eff6da57c429871dabc1149927bcef
parent40c45e71c9f8b5516556e09f097edd71dc8b0e36 (diff)
downloadrabbitmq-server-git-d6222e5f8b3d1d7bc011655a8894eee2a0007429.tar.gz
cosmetic
-rw-r--r--src/file_handle_cache.erl16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl
index 5a83bf5076..b90f8bee33 100644
--- a/src/file_handle_cache.erl
+++ b/src/file_handle_cache.erl
@@ -947,9 +947,10 @@ reduce(State = #fhc_state { open_pending = OpenPending,
Now = now(),
{CStates, Sum, ClientCount} =
dict:fold(fun (Pid, Eldest, {CStatesAcc, SumAcc, CountAcc} = Accs) ->
- [#cstate { pending_closes = PendingCloses,
- opened = Opened, blocked = Blocked } =
- CState] = ets:lookup(Clients, Pid),
+ [#cstate { opened = Opened,
+ blocked = Blocked,
+ pending_closes = PendingCloses }] =
+ CState = ets:lookup(Clients, Pid),
case Blocked orelse PendingCloses =:= Opened of
true -> Accs;
false -> {[CState | CStatesAcc],
@@ -977,11 +978,10 @@ reduce(State = #fhc_state { open_pending = OpenPending,
end.
notify_age(CStates, AverageAge) ->
- lists:foreach(fun (#cstate { callback = undefined }) ->
- ok;
- (#cstate { callback = {M, F, A} }) ->
- apply(M, F, A ++ [AverageAge])
- end, CStates).
+ lists:foreach(
+ fun (#cstate { callback = undefined }) -> ok;
+ (#cstate { callback = {M, F, A} }) -> apply(M, F, A ++ [AverageAge])
+ end, CStates).
notify_age0(Clients, CStates, Required) ->
Notifications =