diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-05-27 15:42:09 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-05-27 15:42:09 +0100 |
| commit | 4949953453c24b9dc962c1dd849534fd13ffb433 (patch) | |
| tree | 130f6bab22007a0206146bcbce441295d5f067ec /src | |
| parent | 866f6f858440473c223ea2467ff72f230e2d4f58 (diff) | |
| download | rabbitmq-server-git-4949953453c24b9dc962c1dd849534fd13ffb433.tar.gz | |
Minor refactor
Diffstat (limited to 'src')
| -rw-r--r-- | src/delegate.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 2f7bc2993e..98353453ff 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -99,13 +99,14 @@ internal_cast(Node, Thunk) when is_atom(Node) -> gen_server2:cast({remote_server(Node), Node}, {thunk, Thunk}). split_delegate_per_node(Pids) -> + LocalNode = node(), {Local, Remote} = lists:foldl( fun (Pid, {L, D}) -> Node = node(Pid), - case node() of - Node -> {[Pid|L], D}; - _ -> {L, orddict:append(node(Pid), Pid, D)} + case Node of + LocalNode -> {[Pid|L], D}; + _ -> {L, orddict:append(Node, Pid, D)} end end, {[], orddict:new()}, Pids), |
