diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-06-07 15:27:59 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-06-07 15:27:59 +0100 |
| commit | e29f0edda8c7d7996eee79a79a466daf47ce1e88 (patch) | |
| tree | dbe379dd95542ed323f6228b4ad5a0a6a8904148 /src/delegate.erl | |
| parent | 76a634b3b2f97f08360d62920576d298b43447a0 (diff) | |
| parent | d371f89d7602ddf38b3beb532fbd7afa21fa5729 (diff) | |
| download | rabbitmq-server-git-e29f0edda8c7d7996eee79a79a466daf47ce1e88.tar.gz | |
Merged in default
Diffstat (limited to 'src/delegate.erl')
| -rw-r--r-- | src/delegate.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 98353453ff..8af2812781 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -45,8 +45,8 @@ -ifdef(use_specs). -spec(start_link/1 :: (non_neg_integer()) -> {'ok', pid()}). --spec(invoke_no_result/2 :: (pid() | [pid()], fun((pid()) -> any())) -> 'ok'). --spec(invoke/2 :: (pid() | [pid()], fun((pid()) -> A)) -> A). +-spec(invoke_no_result/2 :: (pid() | [pid()], fun ((pid()) -> any())) -> 'ok'). +-spec(invoke/2 :: (pid() | [pid()], fun ((pid()) -> A)) -> A). -spec(process_count/0 :: () -> non_neg_integer()). @@ -73,7 +73,7 @@ invoke(Pid, Fun) when is_pid(Pid) -> invoke(Pids, Fun) when is_list(Pids) -> lists:foldl( - fun({Status, Result, Pid}, {Good, Bad}) -> + fun ({Status, Result, Pid}, {Good, Bad}) -> case Status of ok -> {[{Pid, Result}|Good], Bad}; error -> {Good, [{Pid, Result}|Bad]} @@ -136,10 +136,10 @@ delegate_per_remote_node(NodePids, Fun, DelegateFun) -> %% block forever. [gen_server2:cast( local_server(Node), - {thunk, fun() -> + {thunk, fun () -> Self ! {result, DelegateFun( - Node, fun() -> safe_invoke(Pids, Fun) end)} + Node, fun () -> safe_invoke(Pids, Fun) end)} end}) || {Node, Pids} <- NodePids], [receive {result, Result} -> Result end || _ <- NodePids]. |