diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-04-16 15:25:18 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-04-16 15:25:18 +0100 |
| commit | 0ee57907ea7a0352fc6e13896e9f10e7b5268fa4 (patch) | |
| tree | 7859fcb45316898a8c6274db3112c56ae0d55a68 | |
| parent | 2bfed7413f3678c46d7f01524f596d8098b2f3b5 (diff) | |
| download | rabbitmq-server-0ee57907ea7a0352fc6e13896e9f10e7b5268fa4.tar.gz | |
Don't pass around lists of lists for no reason.
| -rw-r--r-- | src/delegate.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index a7020d9b..517f29f2 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -69,12 +69,11 @@ gs2_pcast(Pid, Pri, Msg) -> call(Pid, FPid) when is_pid(Pid) -> - [[{Status, Res, _}]] = call_per_node([{node(Pid), [Pid]}], FPid), + [{Status, Res, _}] = call_per_node([{node(Pid), [Pid]}], FPid), {Status, Res}; call(Pids, FPid) when is_list(Pids) -> - lists:flatten( - call_per_node(split_delegate_per_node(Pids), FPid)). + call_per_node(split_delegate_per_node(Pids), FPid). internal_call(Node, Thunk) when is_atom(Node) -> gen_server2:call({server(), Node}, {thunk, Thunk}, infinity). @@ -114,11 +113,12 @@ cast_per_node(NodePids, FPid) -> delegate_per_node(NodePids, FPid, fun internal_cast/2). local_delegate(Pids, FPid) -> - [[safe_invoke(FPid, Pid) || Pid <- Pids]]. + [safe_invoke(FPid, Pid) || Pid <- Pids]. delegate_per_node(NodePids, FPid, DelegateFun) -> - [DelegateFun(Node, fun() -> [safe_invoke(FPid, Pid) || Pid <- Pids] end) || - {Node, Pids} <- NodePids]. + lists:flatten( + [DelegateFun(Node, fun() -> [safe_invoke(FPid, Pid) || Pid <- Pids] end) + || {Node, Pids} <- NodePids]). server() -> server(erlang:phash(self(), ?DELEGATE_PROCESSES)). |