diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-04-28 15:40:30 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-04-28 15:40:30 +0100 |
| commit | 95a04cb4b51a8760845900b44ef780c24e5b7a27 (patch) | |
| tree | 216904487513e24cf8b8674e31ec790ec7934398 /src/delegate.erl | |
| parent | 9b12f0c30a2f001cc99da0a9072f0a474d326ffb (diff) | |
| download | rabbitmq-server-git-95a04cb4b51a8760845900b44ef780c24e5b7a27.tar.gz | |
cosmetics
Diffstat (limited to 'src/delegate.erl')
| -rw-r--r-- | src/delegate.erl | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 8907f43aa3..6dd9d3974e 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -112,18 +112,18 @@ local_delegate(Pids, FPid) -> delegate_per_node(NodePids, FPid, DelegateFun) -> Self = self(), - [spawn(fun() -> - Self ! {result, DelegateFun(Node, + [spawn( + fun() -> Self ! {result, + DelegateFun(Node, fun() -> local_delegate(Pids, FPid) end)} - end) || {Node, Pids} <- NodePids], + end) || {Node, Pids} <- NodePids], gather_results([], length(NodePids)). gather_results(ResultsAcc, 0) -> ResultsAcc; - gather_results(ResultsAcc, ToGo) -> - receive {result, Result} -> - gather_results([Result | ResultsAcc], ToGo - 1) + receive + {result, Result} -> gather_results([Result | ResultsAcc], ToGo - 1) end. server(Node) when is_atom(Node) -> |