root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

quorum_queue_SUITE: keep Raft state logging in force_checkpoint_on_queue

This commit is contained in:
Michael Klishin 2025-03-17 00:46:47 -04:00 committed by Diana Parra Corbacho
parent d17b085653
commit 7d3292cedd
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbit/test/quorum_queue_SUITE.erl vendored
View File

@ -1353,7 +1353,7 @@ force_checkpoint_on_queue(Config) ->
?assertEqual({'queue.declare_ok', QQ, 0, 0}, ?assertEqual({'queue.declare_ok', QQ, 0, 0},
declare(Ch, QQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}])), declare(Ch, QQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}])),
N = 17000, N = 20_000,
rabbit_ct_client_helpers:publish(Ch, QQ, N), rabbit_ct_client_helpers:publish(Ch, QQ, N),
wait_for_messages_ready([Server0], RaName, N), wait_for_messages_ready([Server0], RaName, N),
@ -1365,9 +1365,11 @@ force_checkpoint_on_queue(Config) ->
LCI =:= undefined LCI =:= undefined
end), end),
%% {ok, State0, _} = rpc:call(Server0, ra, member_overview, [{RaName, Server0}]), {ok, State0, _} = rpc:call(Server0, ra, member_overview, [{RaName, Server0}]),
%% ct:pal("Ra server state before forcing a checkpoint: ~tp~n", [State0]), ct:pal("Ra server state before forcing a checkpoint: ~tp~n", [State0]),
%% wait for longer than ?CHECK_MIN_INTERVAL_MS ms
timer:sleep(?CHECK_MIN_INTERVAL_MS + 1000),
rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_quorum_queue, rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_quorum_queue,
force_checkpoint_on_queue, [QName]), force_checkpoint_on_queue, [QName]),
@ -1375,9 +1377,9 @@ force_checkpoint_on_queue(Config) ->
rabbit_ct_helpers:await_condition( rabbit_ct_helpers:await_condition(
fun() -> fun() ->
{ok, State, _} = rpc:call(Server0, ra, member_overview, [{RaName, Server0}]), {ok, State, _} = rpc:call(Server0, ra, member_overview, [{RaName, Server0}]),
%% ct:pal("Ra server state: ~tp~n", [State]), ct:pal("Ra server state post forced checkpoint: ~tp~n", [State]),
#{log := #{latest_checkpoint_index := LCI}} = State, #{log := #{latest_checkpoint_index := LCI}} = State,
LCI >= N (LCI =/= undefined) andalso (LCI >= N)
end). end).
force_checkpoint(Config) -> force_checkpoint(Config) ->