diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-25 14:12:07 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-25 14:12:07 +0200 |
| commit | ede194b2d5600b3214c7dfbd9310c560a1ce8add (patch) | |
| tree | 02eb878c7faa535bc832e28577fa97ba16933c41 /src | |
| parent | 4b8bcce21475811d6525580838242e0529e0276f (diff) | |
| download | rabbitmq-server-git-ede194b2d5600b3214c7dfbd9310c560a1ce8add.tar.gz | |
applies emacs formatting to file_handle_cache.erl
Diffstat (limited to 'src')
| -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 ]. %%---------------------------------------------------------------------------- |
