Skip to content

Commit ea60dae

Browse files
Ayanda-Dmergify[bot]
authored andcommitted
Update QQ force-shrink logging
(cherry picked from commit dd5ec3c) (cherry picked from commit 16170d0) # Conflicts: # deps/rabbit/src/rabbit_quorum_queue.erl
1 parent 7917a8a commit ea60dae

File tree

1 file changed

+19
-0
lines changed

1 file changed

+19
-0
lines changed

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1969,31 +1969,43 @@ force_shrink_member_to_current_member(VHost, Name) ->
19691969
end,
19701970
_ = rabbit_amqqueue:update(QName, Fun),
19711971
_ = [ra:force_delete_server(?RA_SYSTEM, {RaName, N}) || N <- OtherNodes],
1972+
<<<<<<< HEAD
19721973
<<<<<<< HEAD
19731974
rabbit_log:warning("Shrinking ~ts finished", [QNameFmt]);
19741975
=======
19751976
rabbit_log:warning("Disaster recovery procedure: shrinking finished");
19761977
>>>>>>> d9de6d989c (Shutdown peer QQ FSMs on connected nodes on force-shrink execution for cluster)
1978+
=======
1979+
rabbit_log:warning("Shrinking ~ts finished", [QNameFmt]);
1980+
>>>>>>> 16170d093b (Update QQ force-shrink logging)
19771981
_ ->
19781982
rabbit_log:warning("Shrinking failed, ~ts not found", [QNameFmt]),
19791983
{error, not_found}
19801984
end.
19811985

19821986
force_vhost_queues_shrink_member_to_current_member(VHost) when is_binary(VHost) ->
1987+
<<<<<<< HEAD
19831988
<<<<<<< HEAD
19841989
rabbit_log:warning("Shrinking all quorum queues in vhost '~ts' to a single node: ~ts", [VHost, node()]),
19851990
=======
19861991
rabbit_log:warning("Disaster recovery procedure: shrinking all quorum queues in vhost ~tp to a single node cluster", [VHost]),
19871992
>>>>>>> b03637f8ec (Implement force_vhost_queues_shrink_member_to_current_member/1)
1993+
=======
1994+
rabbit_log:warning("Shrinking all quorum queues in vhost '~ts' to a single node: ~ts", [VHost, node()]),
1995+
>>>>>>> 16170d093b (Update QQ force-shrink logging)
19881996
ListQQs = fun() -> rabbit_amqqueue:list(VHost) end,
19891997
force_all_queues_shrink_member_to_current_member(ListQQs).
19901998

19911999
force_all_queues_shrink_member_to_current_member() ->
2000+
<<<<<<< HEAD
19922001
<<<<<<< HEAD
19932002
rabbit_log:warning("Shrinking all quorum queues to a single node: ~ts", [node()]),
19942003
=======
19952004
rabbit_log:warning("Disaster recovery procedure: shrinking all quorum queues to a single node cluster"),
19962005
>>>>>>> b03637f8ec (Implement force_vhost_queues_shrink_member_to_current_member/1)
2006+
=======
2007+
rabbit_log:warning("Shrinking all quorum queues to a single node: ~ts", [node()]),
2008+
>>>>>>> 16170d093b (Update QQ force-shrink logging)
19972009
ListQQs = fun() -> rabbit_amqqueue:list() end,
19982010
force_all_queues_shrink_member_to_current_member(ListQQs).
19992011

@@ -2003,11 +2015,15 @@ force_all_queues_shrink_member_to_current_member(ListQQFun) when is_function(Lis
20032015
QName = amqqueue:get_name(Q),
20042016
{RaName, _} = amqqueue:get_pid(Q),
20052017
OtherNodes = lists:delete(Node, get_nodes(Q)),
2018+
<<<<<<< HEAD
20062019
<<<<<<< HEAD
20072020
rabbit_log:warning("Shrinking queue ~ts to a single node: ~ts", [rabbit_misc:rs(QName), Node]),
20082021
=======
20092022
rabbit_log:warning("Disaster recovery procedure: shrinking queue ~p", [QName]),
20102023
>>>>>>> d9de6d989c (Shutdown peer QQ FSMs on connected nodes on force-shrink execution for cluster)
2024+
=======
2025+
rabbit_log:warning("Shrinking queue ~ts to a single node: ~ts", [rabbit_misc:rs(QName), Node]),
2026+
>>>>>>> 16170d093b (Update QQ force-shrink logging)
20112027
ok = ra_server_proc:force_shrink_members_to_current_member({RaName, Node}),
20122028
Fun = fun (QQ) ->
20132029
TS0 = amqqueue:get_type_state(QQ),
@@ -2020,13 +2036,16 @@ force_all_queues_shrink_member_to_current_member(ListQQFun) when is_function(Lis
20202036
<<<<<<< HEAD
20212037
end || Q <- ListQQFun(), amqqueue:get_type(Q) == ?MODULE],
20222038
rabbit_log:warning("Shrinking finished"),
2039+
<<<<<<< HEAD
20232040
=======
20242041
end || Q <- rabbit_amqqueue:list(), amqqueue:get_type(Q) == ?MODULE],
20252042
=======
20262043
end || Q <- ListQQFun(), amqqueue:get_type(Q) == ?MODULE],
20272044
>>>>>>> b03637f8ec (Implement force_vhost_queues_shrink_member_to_current_member/1)
20282045
rabbit_log:warning("Disaster recovery procedure: shrinking finished"),
20292046
>>>>>>> d9de6d989c (Shutdown peer QQ FSMs on connected nodes on force-shrink execution for cluster)
2047+
=======
2048+
>>>>>>> 16170d093b (Update QQ force-shrink logging)
20302049
ok.
20312050

20322051
is_minority(All, Up) ->

0 commit comments

Comments
 (0)