diff options
| -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 ]. %%---------------------------------------------------------------------------- |