diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2015-11-22 21:22:39 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2015-11-22 21:22:39 +0300 |
| commit | af67b4714e2a318cd0afb5a4d81505523815f199 (patch) | |
| tree | 5a9b510abfca0c3ca0bfea782af87a24e5658f8b | |
| parent | ebdf6d5d2c0a82f28acb9a94b1d59ad86b08302f (diff) | |
| parent | 543e53c5e6519064455970f6d767dcfc1dd9e39b (diff) | |
| download | rabbitmq-server-git-af67b4714e2a318cd0afb5a4d81505523815f199.tar.gz | |
Merge branch 'stable'
Conflicts:
src/file_handle_cache.erl
| -rw-r--r-- | src/file_handle_cache.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/file_handle_cache.erl b/src/file_handle_cache.erl index 7ddc07b234..a7dfd748ac 100644 --- a/src/file_handle_cache.erl +++ b/src/file_handle_cache.erl @@ -621,7 +621,7 @@ 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(), + _ = clear_process_read_cache(), State end, [rabbit_amqqueue:run_backing_queue(Pid, rabbit_variable_queue, Fun) @@ -679,7 +679,7 @@ with_handles(Refs, ReadBuffer, Fun) -> end, case Fun(Handles) of {Result, Handles1} when is_list(Handles1) -> - lists:zipwith(fun put_handle/2, Refs, Handles1), + _ = lists:zipwith(fun put_handle/2, Refs, Handles1), Result; Result -> Result @@ -823,9 +823,9 @@ age_tree_change() -> case gb_trees:is_empty(Tree) of true -> Tree; false -> {{Oldest, _Ref}, _} = gb_trees:smallest(Tree), - gen_server2:cast(?SERVER, {update, self(), Oldest}) - end, - Tree + gen_server2:cast(?SERVER, {update, self(), Oldest}), + Tree + end end). oldest(Tree, DefaultFun) -> @@ -1080,7 +1080,7 @@ used(#fhc_state{open_count = C1, %%---------------------------------------------------------------------------- init([AlarmSet, AlarmClear]) -> - file_handle_cache_stats:init(), + _ = file_handle_cache_stats:init(), Limit = case application:get_env(file_handles_high_watermark) of {ok, Watermark} when (is_integer(Watermark) andalso Watermark > 0) -> @@ -1219,7 +1219,7 @@ handle_cast({transfer, N, FromPid, ToPid}, State) -> State)))}; handle_cast(clear_read_cache, State) -> - clear_process_read_cache(), + _ = clear_process_read_cache(), {noreply, State}. handle_info(check_counts, State) -> |
