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 | 20a7e435105443224c1f292838127ebd133ef7c7 (patch) | |
tree | 130f6bab22007a0206146bcbce441295d5f067ec | |
parent | a730ac41827344677507fa235298b9b996cd7327 (diff) | |
download | rabbitmq-server-20a7e435105443224c1f292838127ebd133ef7c7.tar.gz |
Minor refactorbug22812
-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 2f7bc299..98353453 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), |