summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2015-01-30 12:35:26 +0000
committerSimon MacMullen <simon@rabbitmq.com>2015-01-30 12:35:26 +0000
commitdd20291501fbd476b88b8d8760553659956469c1 (patch)
tree28ad4529f46598cdee65d5eb8af4137bc675d372
parent5d8f492f902e2fcc00e3dd624ce5f895ca1f7b90 (diff)
downloadrabbitmq-server-git-dd20291501fbd476b88b8d8760553659956469c1.tar.gz
Move comment to a more useful place.
-rw-r--r--src/rabbit_amqqueue.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl
index 15e639f27e..05ad69cee2 100644
--- a/src/rabbit_amqqueue.erl
+++ b/src/rabbit_amqqueue.erl
@@ -725,6 +725,9 @@ forget_all_durable(Node) ->
end),
ok.
+%% Try to promote a slave while down - it should recover as a
+%% master. We try to take the oldest slave here for best chance of
+%% recovery.
forget_node_for_queue(DeadNode, Q = #amqqueue{recoverable_slaves = RS}) ->
forget_node_for_queue(DeadNode, RS, Q).
@@ -742,9 +745,6 @@ forget_node_for_queue(DeadNode, [H|T], Q) ->
case node_permits_offline_promotion(H) of
false -> forget_node_for_queue(DeadNode, T, Q);
true -> Q1 = Q#amqqueue{pid = rabbit_misc:node_to_fake_pid(H)},
- %% Promote a slave while down - it should recover as a
- %% master. We try to take the oldest slave here for best
- %% chance of recovery.
ok = mnesia:write(rabbit_durable_queue, Q1, write)
end.