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
commit7acbd298d962d8d13697aa767b0614ebbd259c42 (patch)
tree2ff5f73151eff6da57c429871dabc1149927bcef
parenta8b6e3a0a492e19f51e4fa23143110b5e77a1866 (diff)
downloadrabbitmq-server-7acbd298d962d8d13697aa767b0614ebbd259c42.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 5a83bf50..b90f8bee 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 =