summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2010-05-27 15:42:09 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2010-05-27 15:42:09 +0100
commit4949953453c24b9dc962c1dd849534fd13ffb433 (patch)
tree130f6bab22007a0206146bcbce441295d5f067ec /src
parent866f6f858440473c223ea2467ff72f230e2d4f58 (diff)
downloadrabbitmq-server-git-4949953453c24b9dc962c1dd849534fd13ffb433.tar.gz
Minor refactor
Diffstat (limited to 'src')
-rw-r--r--src/delegate.erl7
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),