diff options
| author | Michael Klishin <michael@novemberain.com> | 2018-11-17 05:31:33 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-11-17 05:31:33 +0300 |
| commit | 7c1b567ae4ccd7f39eff7c6ec16c3b83bc81889d (patch) | |
| tree | f1f3e934197a6c03cebef96fe739bdc1b65ae933 /test | |
| parent | a91a4fa9024be5cd015455417feefc622a04ace5 (diff) | |
| parent | 4faedab6b56072c75a363df02c930bad3b2c8263 (diff) | |
| download | rabbitmq-server-git-7c1b567ae4ccd7f39eff7c6ec16c3b83bc81889d.tar.gz | |
Merge pull request #1761 from rabbitmq/quorum-data-cleanup
Data cleanup for quorum queues
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index d983a9d396..19f3a66a1d 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -36,6 +36,7 @@ groups() -> {cluster_size_2, [], [add_member]} ]}, {clustered, [], [ + {cluster_size_2, [], [cleanup_data_dir]}, {cluster_size_2, [], [add_member_not_running, add_member_classic, add_member_already_a_member, @@ -1586,6 +1587,34 @@ delete_member(Config) -> rpc:call(Server, rabbit_quorum_queue, delete_member, [<<"/">>, QQ, Server])). +cleanup_data_dir(Config) -> + %% This test is slow, but also checks that we handle properly errors when + %% trying to delete a queue in minority. A case clause there had gone + %% previously unnoticed. + + [Server1, Server2] = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), + Ch = rabbit_ct_client_helpers:open_channel(Config, Server1), + QQ = ?config(queue_name, Config), + ?assertEqual({'queue.declare_ok', QQ, 0, 0}, + declare(Ch, QQ, [{<<"x-queue-type">>, longstr, <<"quorum">>}])), + timer:sleep(100), + + [{_, UId}] = rpc:call(Server1, ra_directory, list_registered, []), + DataDir = rpc:call(Server1, ra_env, server_data_dir, [UId]), + ?assert(filelib:is_dir(DataDir)), + + ok = rabbit_ct_broker_helpers:stop_node(Config, Server2), + + ?assertExit({{shutdown, + {connection_closing, {server_initiated_close, 541, _}}}, _}, + amqp_channel:call(Ch, #'queue.delete'{queue = QQ})), + ?assert(filelib:is_dir(DataDir)), + + ?assertEqual(ok, + rpc:call(Server1, rabbit_quorum_queue, cleanup_data_dir, + [])), + ?assert(not filelib:is_dir(DataDir)). + basic_recover(Config) -> [Server | _] = Servers = rabbit_ct_broker_helpers:get_node_configs(Config, nodename), |