diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-14 11:54:54 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-14 11:54:54 +0000 |
| commit | b5d09e956ec31db9053c69a5bac6481194a920c3 (patch) | |
| tree | 92c5068af688139122f4fc09e5077a0ba7352add | |
| parent | a1d7686e12f0c2d6b9eb5c8cb53a3f49fbb1c3a4 (diff) | |
| download | rabbitmq-server-git-b5d09e956ec31db9053c69a5bac6481194a920c3.tar.gz | |
Fix stupidity, and rename.
| -rw-r--r-- | src/rabbit_autoheal.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_autoheal.erl b/src/rabbit_autoheal.erl index 7b27ac82f8..1301570e04 100644 --- a/src/rabbit_autoheal.erl +++ b/src/rabbit_autoheal.erl @@ -128,14 +128,14 @@ handle_msg({request_start, Node}, " * Losers: ~p~n", [AllPartitions, Winner, Losers]), [send(L, {winner_is, Winner}) || L <- Losers], - ShortCut = fun(Msg) -> + Continue = fun(Msg) -> handle_msg(Msg, not_healing, Partitions) end, - case {node() =:= Winner, lists:member(node(), Losers)} of - true -> ShortCut({become_winner, Losers}); + case node() =:= Winner of + true -> Continue({become_winner, Losers}); false -> send(Winner, {become_winner, Losers}), case lists:member(node(), Losers) of - true -> ShortCut({winner_is, Winner}); + true -> Continue({winner_is, Winner}); false -> {leader_waiting, Losers} end end |
