summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2015-11-22 21:22:39 +0300
committerMichael Klishin <michael@clojurewerkz.org>2015-11-22 21:22:39 +0300
commitaf67b4714e2a318cd0afb5a4d81505523815f199 (patch)
tree5a9b510abfca0c3ca0bfea782af87a24e5658f8b
parentebdf6d5d2c0a82f28acb9a94b1d59ad86b08302f (diff)
parent543e53c5e6519064455970f6d767dcfc1dd9e39b (diff)
downloadrabbitmq-server-git-af67b4714e2a318cd0afb5a4d81505523815f199.tar.gz
Merge branch 'stable'
Conflicts: src/file_handle_cache.erl
-rw-r--r--src/file_handle_cache.erl14
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) ->