summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJean-Sebastien Pedron <jean-sebastien@rabbitmq.com>2014-12-10 18:20:47 +0100
committerJean-Sebastien Pedron <jean-sebastien@rabbitmq.com>2014-12-10 18:20:47 +0100
commit12bd1745c23b1a478434209fd31250b3185f0135 (patch)
treec1851f36cd91b8d760cbf1dfd775655accd4b683
parent150d2432e99f5f7fa910e07ad664cf8f6a4fedac (diff)
downloadrabbitmq-server-12bd1745c23b1a478434209fd31250b3185f0135.tar.gz
Inline the Continue() anonymous functionbug26490
-rw-r--r--src/rabbit_autoheal.erl6
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_autoheal.erl b/src/rabbit_autoheal.erl
index 8a5614ae..a277dbeb 100644
--- a/src/rabbit_autoheal.erl
+++ b/src/rabbit_autoheal.erl
@@ -136,11 +136,9 @@ handle_msg({request_start, Node},
" * Winner: ~p~n"
" * Losers: ~p~n",
[AllPartitions, Winner, Losers]),
- Continue = fun(Msg) ->
- handle_msg(Msg, not_healing, Partitions)
- end,
case node() =:= Winner of
- true -> Continue({become_winner, Losers});
+ true -> handle_msg({become_winner, Losers},
+ not_healing, Partitions);
false -> send(Winner, {become_winner, Losers}), %% [0]
case lists:member(node(), Losers) of
true -> about_to_heal;