diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-03-14 17:20:35 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-03-14 17:20:35 +0000 |
| commit | 1dd3e01cd88f91c54aae9cde43ff92f21c7332de (patch) | |
| tree | 4e6d2b0eaacd01ee7305925ee4161c8077174d6e | |
| parent | 00f507239680640c8f858456cce6942a15de8209 (diff) | |
| download | rabbitmq-server-1dd3e01cd88f91c54aae9cde43ff92f21c7332de.tar.gz | |
Hush, little dialyzer, don't cry.
| -rw-r--r-- | src/rabbit_misc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_misc.erl b/src/rabbit_misc.erl index 196d6da0..3f3aeb62 100644 --- a/src/rabbit_misc.erl +++ b/src/rabbit_misc.erl @@ -202,7 +202,7 @@ -spec(format_message_queue/2 :: (any(), priority_queue:q()) -> term()). -spec(append_rpc_all_nodes/4 :: ([node()], atom(), atom(), [any()]) -> [any()]). -spec(multi_call/2 :: - ([pid()], any()) -> [{[{pid(), any()}], [{pid(), any()}]}]). + ([pid()], any()) -> {[{pid(), any()}], [{pid(), any()}]}). -spec(quit/1 :: (integer() | string()) -> no_return()). -endif. @@ -890,7 +890,7 @@ multi_call(Pids, Req) -> MonitorPids = [start_multi_call(Pid, Req) || Pid <- Pids], receive_multi_call(MonitorPids, [], []). -start_multi_call(Pid, Req) -> +start_multi_call(Pid, Req) when is_pid(Pid) -> Mref = erlang:monitor(process, Pid), Pid ! {'$gen_call', {self(), Mref}, Req}, {Mref, Pid}. |