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

Reduce CT logging here

This commit is contained in:
Michael Klishin 2022-10-25 12:38:14 +04:00
parent e2a5ba5b78
commit 6f6e4b1acd
No known key found for this signature in database
GPG Key ID: E80EDCFA0CDB21EE
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/rabbit/test/rabbit_stream_queue_SUITE.erl vendored
View File

@ -1135,7 +1135,6 @@ receive_basic_cancel_on_queue_deletion(Config) ->
recover_after_leader_and_coordinator_kill(Config) -> recover_after_leader_and_coordinator_kill(Config) ->
[Server1 | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), [Server1 | _] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename),
Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server1), Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server1),
% Ch2 = rabbit_ct_client_helpers:open_channel(Config, Server1),
Q = ?config(queue_name, Config), Q = ?config(queue_name, Config),
?assertEqual({'queue.declare_ok', Q, 0, 0}, ?assertEqual({'queue.declare_ok', Q, 0, 0},
declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])), declare(Ch1, Q, [{<<"x-queue-type">>, longstr, <<"stream">>}])),
@ -1145,7 +1144,6 @@ recover_after_leader_and_coordinator_kill(Config) ->
QName = rabbit_misc:r(<<"/">>, queue, Q), QName = rabbit_misc:r(<<"/">>, queue, Q),
[begin [begin
Sleep = rand:uniform(10), Sleep = rand:uniform(10),
ct:pal("Attempt ~b Sleep ~b", [Num, Sleep]),
{ok, {_LeaderNode, LeaderPid}} = leader_info(Config), {ok, {_LeaderNode, LeaderPid}} = leader_info(Config),
{_, CoordNode} = get_stream_coordinator_leader(Config), {_, CoordNode} = get_stream_coordinator_leader(Config),
kill_stream_leader_then_coordinator_leader(Config, CoordNode, kill_stream_leader_then_coordinator_leader(Config, CoordNode,
@ -1158,7 +1156,7 @@ recover_after_leader_and_coordinator_kill(Config) ->
rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE, rabbit_ct_broker_helpers:rpc(Config, 0, ?MODULE,
validate_writer_pid, [QName]) validate_writer_pid, [QName])
end) end)
end || Num <- lists:seq(1, 10)], end || _Num <- lists:seq(1, 10)],
{_, Node} = get_stream_coordinator_leader(Config), {_, Node} = get_stream_coordinator_leader(Config),