summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2010-04-28 15:40:30 +0100
committerMatthew Sackman <matthew@lshift.net>2010-04-28 15:40:30 +0100
commite5cbbcaf844b4aaea87da0622792b888fda83e97 (patch)
tree216904487513e24cf8b8674e31ec790ec7934398
parentb531d96d6ae863c6b9b52ab58a85524b8554df93 (diff)
downloadrabbitmq-server-e5cbbcaf844b4aaea87da0622792b888fda83e97.tar.gz
cosmetics
-rw-r--r--src/delegate.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/delegate.erl b/src/delegate.erl
index 8907f43a..6dd9d397 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) ->