summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlvaro Videla <videlalvaro@gmail.com>2015-06-25 14:12:07 +0200
committerAlvaro Videla <videlalvaro@gmail.com>2015-06-25 14:12:07 +0200
commitede194b2d5600b3214c7dfbd9310c560a1ce8add (patch)
tree02eb878c7faa535bc832e28577fa97ba16933c41 /src
parent4b8bcce21475811d6525580838242e0529e0276f (diff)
downloadrabbitmq-server-git-ede194b2d5600b3214c7dfbd9310c560a1ce8add.tar.gz
applies emacs formatting to file_handle_cache.erl
Diffstat (limited to 'src')
-rw-r--r--src/file_handle_cache.erl18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl
index d8203af877..8be19e5be3 100644
--- a/src/file_handle_cache.erl
+++ b/src/file_handle_cache.erl
@@ -602,21 +602,21 @@ clear_queue_read_cache([#amqqueue{pid = MPid, slave_pids = SPids} | Rest]) ->
%% process because the read buffer is stored in the process
%% dictionary.
Fun = fun(_, State) ->
- clear_process_read_cache(),
- State
- end,
+ clear_process_read_cache(),
+ State
+ end,
[rabbit_amqqueue:run_backing_queue(Pid, rabbit_variable_queue, Fun)
|| Pid <- Pids],
clear_queue_read_cache(Rest).
clear_process_read_cache() ->
[
- begin
- Handle1 = reset_read_buffer(Handle),
- put({Ref, fhc_handle}, Handle1)
- end ||
- {{Ref, fhc_handle}, Handle} <- get(),
- size(Handle#handle.read_buffer) > 0
+ begin
+ Handle1 = reset_read_buffer(Handle),
+ put({Ref, fhc_handle}, Handle1)
+ end ||
+ {{Ref, fhc_handle}, Handle} <- get(),
+ size(Handle#handle.read_buffer) > 0
].
%%----------------------------------------------------------------------------