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
commitaf0ce675fae7c840bf7d578dbac2339d214c8e01 (patch)
treec1851f36cd91b8d760cbf1dfd775655accd4b683
parent08b91401b6f1d61ec982880889800c408001b5a9 (diff)
downloadrabbitmq-server-git-af0ce675fae7c840bf7d578dbac2339d214c8e01.tar.gz
Inline the Continue() anonymous function
-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 8a5614ae13..a277dbeb05 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;