diff options
author | Matthew Sackman <matthew@lshift.net> | 2010-04-27 17:32:51 +0100 |
---|---|---|
committer | Matthew Sackman <matthew@lshift.net> | 2010-04-27 17:32:51 +0100 |
commit | 7d1e53d37adea2cf7aadf6aff2e881ca28b2ecad (patch) | |
tree | 4e0c9e493be2e1059313a64a3d5dd624538b7c3d /src/delegate.erl | |
parent | 58a35a817260cb41dec2236e52ec3e27a906cc9c (diff) | |
download | rabbitmq-server-7d1e53d37adea2cf7aadf6aff2e881ca28b2ecad.tar.gz |
cosmetics
Diffstat (limited to 'src/delegate.erl')
-rw-r--r-- | src/delegate.erl | 25 |
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); |