diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-25 14:12:20 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-25 14:12:20 +0200 |
| commit | 3934bbd93060e2f6cd41deec4427b085c4e28502 (patch) | |
| tree | 1db3ebbad44fed88ca51a4041bd1bbdbb897edf5 | |
| parent | 46d07781a53a983f093af6ddd11b816dfea5dc1a (diff) | |
| parent | ede194b2d5600b3214c7dfbd9310c560a1ce8add (diff) | |
| download | rabbitmq-server-git-3934bbd93060e2f6cd41deec4427b085c4e28502.tar.gz | |
Merge branch 'stable'
| -rw-r--r-- | src/file_handle_cache.erl | 18 |
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 ]. %%---------------------------------------------------------------------------- |
