summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlvaro Videla <videlalvaro@gmail.com>2015-06-25 14:12:20 +0200
committerAlvaro Videla <videlalvaro@gmail.com>2015-06-25 14:12:20 +0200
commit3934bbd93060e2f6cd41deec4427b085c4e28502 (patch)
tree1db3ebbad44fed88ca51a4041bd1bbdbb897edf5 /src
parent46d07781a53a983f093af6ddd11b816dfea5dc1a (diff)
parentede194b2d5600b3214c7dfbd9310c560a1ce8add (diff)
downloadrabbitmq-server-git-3934bbd93060e2f6cd41deec4427b085c4e28502.tar.gz
Merge branch 'stable'
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
].
%%----------------------------------------------------------------------------