summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-03-14 11:54:54 +0000
committerSimon MacMullen <simon@rabbitmq.com>2014-03-14 11:54:54 +0000
commitff66a88cdd9461b01639fc603cb0564e4d41bd2e (patch)
tree92c5068af688139122f4fc09e5077a0ba7352add
parentbb95f38c2e25e7933bfb33ef7f7b700ed2cba9dd (diff)
downloadrabbitmq-server-ff66a88cdd9461b01639fc603cb0564e4d41bd2e.tar.gz
Fix stupidity, and rename.
-rw-r--r--src/rabbit_autoheal.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_autoheal.erl b/src/rabbit_autoheal.erl
index 7b27ac82..1301570e 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