diff options
| author | Michael Klishin <michael@novemberain.com> | 2015-11-23 16:28:38 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@novemberain.com> | 2015-11-23 16:28:38 +0300 |
| commit | c42d5e571e95bf96b5933bc770ec5331dee2542f (patch) | |
| tree | b3ca46cb55db2db83d7de2562583866637e40656 /src/delegate.erl | |
| parent | 543e53c5e6519064455970f6d767dcfc1dd9e39b (diff) | |
| parent | bd31f797a1777fcbef2a16bb08ef52724422ec2c (diff) | |
| download | rabbitmq-server-git-c42d5e571e95bf96b5933bc770ec5331dee2542f.tar.gz | |
Merge pull request #442 from rabbitmq/rabbitmq-server-441
fixes various dialyzer warnings
Diffstat (limited to 'src/delegate.erl')
| -rw-r--r-- | src/delegate.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 4bf570cc27..394ebd42d9 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -131,7 +131,7 @@ invoke(Pids, FunOrMFA) when is_list(Pids) -> end, {[], BadPids}, ResultsNoNode). invoke_no_result(Pid, FunOrMFA) when is_pid(Pid) andalso node(Pid) =:= node() -> - safe_invoke(Pid, FunOrMFA), %% we don't care about any error + _ = safe_invoke(Pid, FunOrMFA), %% we don't care about any error ok; invoke_no_result(Pid, FunOrMFA) when is_pid(Pid) -> invoke_no_result([Pid], FunOrMFA); @@ -139,7 +139,7 @@ invoke_no_result(Pid, FunOrMFA) when is_pid(Pid) -> invoke_no_result([], _FunOrMFA) -> %% optimisation ok; invoke_no_result([Pid], FunOrMFA) when node(Pid) =:= node() -> %% optimisation - safe_invoke(Pid, FunOrMFA), %% must not die + _ = safe_invoke(Pid, FunOrMFA), %% must not die ok; invoke_no_result(Pids, FunOrMFA) when is_list(Pids) -> {LocalPids, Grouped} = group_pids_by_node(Pids), @@ -149,7 +149,7 @@ invoke_no_result(Pids, FunOrMFA) when is_list(Pids) -> RemoteNodes, delegate(self(), RemoteNodes), {invoke, FunOrMFA, Grouped}) end, - safe_invoke(LocalPids, FunOrMFA), %% must not die + _ = safe_invoke(LocalPids, FunOrMFA), %% must not die ok. monitor(process, Pid) when node(Pid) =:= node() -> @@ -247,7 +247,7 @@ handle_cast({demonitor, MonitoringPid, Pid}, {noreply, State#state{monitors = Monitors1}, hibernate}; handle_cast({invoke, FunOrMFA, Grouped}, State = #state{node = Node}) -> - safe_invoke(orddict:fetch(Node, Grouped), FunOrMFA), + _ = safe_invoke(orddict:fetch(Node, Grouped), FunOrMFA), {noreply, State, hibernate}. handle_info({'DOWN', Ref, process, Pid, Info}, |