diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2018-11-06 13:54:47 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2018-11-06 13:54:47 +0000 |
| commit | ee7cbf53e97e59596bd1c00fd75a9cd440a7b053 (patch) | |
| tree | 603fe7b35a6b9f03d89f1d806d1523a0039cc611 /test | |
| parent | d098858a2152776ec316799d636a3ad24861fc64 (diff) | |
| download | rabbitmq-server-git-ee7cbf53e97e59596bd1c00fd75a9cd440a7b053.tar.gz | |
Cleanup data for missing quorum queues
[#161313536]
Diffstat (limited to 'test')
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 31 |
1 files changed, 30 insertions, 1 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index d983a9d396..6147215fbc 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -43,7 +43,8 @@ groups() -> delete_member_not_running, delete_member_classic, delete_member_not_found, - delete_member] + delete_member, + cleanup_data_dir] ++ all_tests()}, {cluster_size_3, [], [ declare_during_node_down, @@ -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), |