diff options
| author | kjnilsson <knilsson@pivotal.io> | 2020-03-05 11:55:28 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-03-05 11:55:28 +0000 |
| commit | 34f3a0066e050f3eaaebf67d73db462e4262b699 (patch) | |
| tree | e3dca0d8d0092f972c9d24ef7e72ff156057f5ea /test/rabbit_fifo_prop_SUITE.erl | |
| parent | 23745d6a880e10836145c429518d3e5faded7c3d (diff) | |
| download | rabbitmq-server-git-34f3a0066e050f3eaaebf67d73db462e4262b699.tar.gz | |
rabbit_fifo: change release cursor calculationrabbit-fifo-release-cursor-fix
Release cursors are taken less frequently the more messages there are on
queue. This changes how this is calculated to simply use the message
count rather than some multiple of the currently captured release
cursors. This is more consistent and doesn't depend on non snapshottable
state.
Diffstat (limited to 'test/rabbit_fifo_prop_SUITE.erl')
| -rw-r--r-- | test/rabbit_fifo_prop_SUITE.erl | 21 |
1 files changed, 21 insertions, 0 deletions
diff --git a/test/rabbit_fifo_prop_SUITE.erl b/test/rabbit_fifo_prop_SUITE.erl index 2413e3391c..23522e71f9 100644 --- a/test/rabbit_fifo_prop_SUITE.erl +++ b/test/rabbit_fifo_prop_SUITE.erl @@ -45,6 +45,7 @@ all_tests() -> scenario19, scenario20, scenario21, + scenario22, single_active, single_active_01, single_active_02, @@ -376,6 +377,24 @@ scenario21(_Config) -> Commands), ok. +scenario22(_Config) -> + % C1Pid = c:pid(0,883,1), + % C1 = {<<>>, C1Pid}, + E = c:pid(0,176,1), + Commands = [ + make_enqueue(E,1,<<"1">>), + make_enqueue(E,2,<<"2">>), + make_enqueue(E,3,<<"3">>), + make_enqueue(E,4,<<"4">>), + make_enqueue(E,5,<<"5">>) + ], + run_snapshot_test(#{name => ?FUNCTION_NAME, + release_cursor_interval => 1, + max_length => 3, + dead_letter_handler => {?MODULE, banana, []}}, + Commands), + ok. + single_active_01(_Config) -> C1Pid = test_util:fake_pid(rabbit@fake_node1), C1 = {<<0>>, C1Pid}, @@ -1093,6 +1112,8 @@ run_proper(Fun, Args, NumTests) -> run_snapshot_test(Conf, Commands) -> %% create every incremental permutation of the commands lists %% and run the snapshot tests against that + ct:pal("running snapshot test with ~b commands using config ~p", + [length(Commands), Conf]), [begin % ?debugFmt("~w running command to ~w~n", [?FUNCTION_NAME, lists:last(C)]), run_snapshot_test0(Conf, C) |