@@ -1953,9 +1953,10 @@ notify_decorators(QName, F, A) ->
1953
1953
is_stateful () -> true .
1954
1954
1955
1955
force_shrink_member_to_current_member (VHost , Name ) ->
1956
- rabbit_log :warning (" Disaster recovery procedure: shrinking ~p queue at vhost ~p to a single node cluster" , [Name , VHost ]),
1957
1956
Node = node (),
1958
1957
QName = rabbit_misc :r (VHost , queue , Name ),
1958
+ QNameFmt = rabbit_misc :rs (QName ),
1959
+ rabbit_log :warning (" Shrinking ~ts to a single node: ~ts " , [QNameFmt , Node ]),
1959
1960
case rabbit_amqqueue :lookup (QName ) of
1960
1961
{ok , Q } when ? is_amqqueue (Q ) ->
1961
1962
{RaName , _ } = amqqueue :get_pid (Q ),
@@ -1968,19 +1969,19 @@ force_shrink_member_to_current_member(VHost, Name) ->
1968
1969
end ,
1969
1970
_ = rabbit_amqqueue :update (QName , Fun ),
1970
1971
_ = [ra :force_delete_server (? RA_SYSTEM , {RaName , N }) || N <- OtherNodes ],
1971
- rabbit_log :warning (" Disaster recovery procedure: shrinking finished" );
1972
+ rabbit_log :warning (" Shrinking ~ts finished" , [ QNameFmt ] );
1972
1973
_ ->
1973
- rabbit_log :warning (" Disaster recovery procedure: shrinking failed, queue ~p not found at vhost ~p " , [Name , VHost ]),
1974
+ rabbit_log :warning (" Shrinking failed, ~ts not found" , [QNameFmt ]),
1974
1975
{error , not_found }
1975
1976
end .
1976
1977
1977
1978
force_vhost_queues_shrink_member_to_current_member (VHost ) when is_binary (VHost ) ->
1978
- rabbit_log :warning (" Disaster recovery procedure: shrinking all quorum queues in vhost ~tp to a single node cluster " , [VHost ]),
1979
+ rabbit_log :warning (" Shrinking all quorum queues in vhost ' ~ts ' to a single node: ~ts " , [VHost , node () ]),
1979
1980
ListQQs = fun () -> rabbit_amqqueue :list (VHost ) end ,
1980
1981
force_all_queues_shrink_member_to_current_member (ListQQs ).
1981
1982
1982
1983
force_all_queues_shrink_member_to_current_member () ->
1983
- rabbit_log :warning (" Disaster recovery procedure: shrinking all quorum queues to a single node cluster " ),
1984
+ rabbit_log :warning (" Shrinking all quorum queues to a single node: ~ts " , [ node ()] ),
1984
1985
ListQQs = fun () -> rabbit_amqqueue :list () end ,
1985
1986
force_all_queues_shrink_member_to_current_member (ListQQs ).
1986
1987
@@ -1990,7 +1991,7 @@ force_all_queues_shrink_member_to_current_member(ListQQFun) when is_function(Lis
1990
1991
QName = amqqueue :get_name (Q ),
1991
1992
{RaName , _ } = amqqueue :get_pid (Q ),
1992
1993
OtherNodes = lists :delete (Node , get_nodes (Q )),
1993
- rabbit_log :warning (" Disaster recovery procedure: shrinking queue ~p " , [QName ]),
1994
+ rabbit_log :warning (" Shrinking queue ~ts to a single node: ~ts " , [rabbit_misc : rs ( QName ), Node ]),
1994
1995
ok = ra_server_proc :force_shrink_members_to_current_member ({RaName , Node }),
1995
1996
Fun = fun (QQ ) ->
1996
1997
TS0 = amqqueue :get_type_state (QQ ),
@@ -2000,7 +2001,7 @@ force_all_queues_shrink_member_to_current_member(ListQQFun) when is_function(Lis
2000
2001
_ = rabbit_amqqueue :update (QName , Fun ),
2001
2002
_ = [ra :force_delete_server (? RA_SYSTEM , {RaName , N }) || N <- OtherNodes ]
2002
2003
end || Q <- ListQQFun (), amqqueue :get_type (Q ) == ? MODULE ],
2003
- rabbit_log :warning (" Disaster recovery procedure: shrinking finished" ),
2004
+ rabbit_log :warning (" Shrinking finished" ),
2004
2005
ok .
2005
2006
2006
2007
is_minority (All , Up ) ->
0 commit comments