summaryrefslogtreecommitdiff
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
commit20a7e435105443224c1f292838127ebd133ef7c7 (patch)
tree130f6bab22007a0206146bcbce441295d5f067ec
parenta730ac41827344677507fa235298b9b996cd7327 (diff)
downloadrabbitmq-server-bug22812.tar.gz
Minor refactorbug22812
-rw-r--r--src/delegate.erl7
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),