summaryrefslogtreecommitdiff
path: root/src/delegate.erl
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2010-04-27 17:32:51 +0100
committerMatthew Sackman <matthew@lshift.net>2010-04-27 17:32:51 +0100
commit7d1e53d37adea2cf7aadf6aff2e881ca28b2ecad (patch)
tree4e0c9e493be2e1059313a64a3d5dd624538b7c3d /src/delegate.erl
parent58a35a817260cb41dec2236e52ec3e27a906cc9c (diff)
downloadrabbitmq-server-7d1e53d37adea2cf7aadf6aff2e881ca28b2ecad.tar.gz
cosmetics
Diffstat (limited to 'src/delegate.erl')
-rw-r--r--src/delegate.erl25
1 files changed, 12 insertions, 13 deletions
diff --git a/src/delegate.erl b/src/delegate.erl
index f3c3f097..5907eb09 100644
--- a/src/delegate.erl
+++ b/src/delegate.erl
@@ -94,10 +94,6 @@ call(Pid, FPid) when is_pid(Pid) ->
call(Pids, FPid) when is_list(Pids) ->
call_per_node(split_delegate_per_node(Pids), FPid).
-internal_call(Node, Thunk) when is_atom(Node) ->
- gen_server2:call({server(Node), Node}, {thunk, Thunk}, infinity).
-
-
cast(Pid, FPid) when is_pid(Pid) ->
cast_per_node([{node(Pid), [Pid]}], FPid),
ok;
@@ -106,20 +102,23 @@ cast(Pids, FPid) when is_list(Pids) ->
cast_per_node(split_delegate_per_node(Pids), FPid),
ok.
+%%----------------------------------------------------------------------------
+
+internal_call(Node, Thunk) when is_atom(Node) ->
+ gen_server2:call({server(Node), Node}, {thunk, Thunk}, infinity).
+
internal_cast(Node, Thunk) when is_atom(Node) ->
gen_server2:cast({server(Node), Node}, {thunk, Thunk}).
-%%----------------------------------------------------------------------------
-
split_delegate_per_node(Pids) ->
orddict:to_list(
- lists:foldl(
- fun (Pid, D) ->
- orddict:update(node(Pid),
- fun (Pids1) -> [Pid | Pids1] end,
- [Pid], D)
- end,
- orddict:new(), Pids)).
+ lists:foldl(
+ fun (Pid, D) ->
+ orddict:update(node(Pid),
+ fun (Pids1) -> [Pid | Pids1] end,
+ [Pid], D)
+ end,
+ orddict:new(), Pids)).
call_per_node([{Node, Pids}], FPid) when Node == node() ->
local_delegate(Pids, FPid);