diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2019-03-15 22:08:55 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2019-03-15 22:08:55 +0300 |
| commit | 2a26daab5997b9aa41087ea94edf02d510469521 (patch) | |
| tree | f35b53eaff99dd483e074a86e412e2ccfe96dc45 /test | |
| parent | 6dce82e7c5847bfb01c380912b4a9d53d0deb9f7 (diff) | |
| parent | 2f8053da4213e4d4d5df5c2f6dc6871b7054d844 (diff) | |
| download | rabbitmq-server-git-2a26daab5997b9aa41087ea94edf02d510469521.tar.gz | |
Merge branch 'master' into rabbitmq-server-1906
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_fifo_prop_SUITE.erl | 29 |
1 files changed, 26 insertions, 3 deletions
diff --git a/test/rabbit_fifo_prop_SUITE.erl b/test/rabbit_fifo_prop_SUITE.erl index 4ce34c8a13..76b8d7e715 100644 --- a/test/rabbit_fifo_prop_SUITE.erl +++ b/test/rabbit_fifo_prop_SUITE.erl @@ -37,7 +37,8 @@ all_tests() -> scenario13, scenario14, scenario15, - scenario16 + scenario16, + scenario17 ]. groups() -> @@ -270,6 +271,27 @@ scenario16(_Config) -> delivery_limit => 1}, Commands), ok. +scenario17(_Config) -> + C1Pid = test_util:fake_pid(rabbit@fake_node1), + C1 = {<<0>>, C1Pid}, + % C2Pid = test_util:fake_pid(fake_node1), + C2 = {<<>>, C1Pid}, + E = test_util:fake_pid(rabbit@fake_node2), + Commands = [ + make_checkout(C1, {auto,1,simple_prefetch}), + make_enqueue(E,1,<<"one">>), + make_checkout(C2, {auto,1,simple_prefetch}), + {down, C1Pid, noconnection}, + make_checkout(C2, cancel), + make_enqueue(E,2,<<"two">>), + {nodeup,rabbit@fake_node1}, + make_settle(C1, [0]), + make_settle(C1, [1]) + ], + run_snapshot_test(#{name => ?FUNCTION_NAME, + single_active_consumer_on => true + }, Commands), + ok. snapshots(_Config) -> run_proper( @@ -541,8 +563,9 @@ run_snapshot_test0(Conf, Commands) -> State -> ok; _ -> ct:pal("Snapshot tests failed run log:~n" - "~p~n from ~n~p~n Entries~n~p~n", - [Filtered, SnapState, Entries]), + "~p~n from ~n~p~n Entries~n~p~n" + "Config: ~p~n", + [Filtered, SnapState, Entries, Conf]), ct:pal("Expected~n~p~nGot:~n~p", [State, S]), ?assertEqual(State, S) end |