Introduce rabbitmqctl shutdown command.

rabbitmqctl shutdown command will wait for erlang vm to terminate,
the same way as rabbitmqctl stop PIDFILE, but without a pidfile.

[finishes #142699191]

1 files changed, 104 insertions, 0 deletions

diff --git a/test/rabbitmqctl_shutdown_SUITE.erl b/test/rabbitmqctl_shutdown_SUITE.erl
new file mode 100644
index 0000000000..6f681a697b
--- /dev/null
+++ b/test/rabbitmqctl_shutdown_SUITE.erl
@@ -0,0 +1,104 @@
+%% The contents of this file are subject to the Mozilla Public License
+%% Version 1.1 (the "License"); you may not use this file except in
+%% compliance with the License. You may obtain a copy of the License
+%% at http://www.mozilla.org/MPL/
+%%
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+%% the License for the specific language governing rights and
+%% limitations under the License.
+%%
+%% The Original Code is RabbitMQ.
+%%
+%% The Initial Developer of the Original Code is GoPivotal, Inc.
+%% Copyright (c) 2016 Pivotal Software, Inc.  All rights reserved.
+%%
+-module(rabbitmqctl_shutdown_SUITE).
+
+-include_lib("common_test/include/ct.hrl").
+-include_lib("amqp_client/include/amqp_client.hrl").
+
+-compile(export_all).
+
+all() ->
+    [
+        {group, shutdown_running_node}%,
+        % {group, shutdown_not_running_node}
+    ].
+
+groups() ->
+    StopTests = [
+        shutdown_fails_if_unable_to_contact_node,
+        shutdown_fails_if_unable_to_stop
+    ],
+    [
+        {shutdown_running_node, [],
+        % StopTests ++
+        [shutdown_running_node_ok]},
+        {shutdown_not_running_node, [], StopTests}
+    ].
+
+init_per_suite(Config) ->
+    rabbit_ct_helpers:log_environment(),
+    rabbit_ct_helpers:run_setup_steps(Config).
+
+end_per_suite(Config) ->
+    rabbit_ct_helpers:run_teardown_steps(Config).
+
+init_per_group(shutdown_running_node, Config) ->
+    rabbit_ct_helpers:set_config(Config, [
+        {rmq_nodename_suffix, ?MODULE},
+        {need_start, true}
+    ]);
+init_per_group(shutdown_not_running_node, Config) ->
+    rabbit_ct_helpers:set_config(Config, [
+        {rmq_nodename_suffix, ?MODULE}
+    ]).
+
+end_per_group(shutdown_running_node, Config) ->
+    rabbit_ct_helpers:run_teardown_steps(Config, []);
+end_per_group(shutdown_not_running_node, Config) ->
+    rabbit_ct_helpers:run_teardown_steps(Config, []).
+
+init_per_testcase(Testcase, Config0) ->
+    Config1 = case ?config(need_start, Config0) of
+        true ->
+            rabbit_ct_helpers:run_setup_steps(Config0,
+                rabbit_ct_broker_helpers:setup_steps() ++
+                [fun save_node/1]);
+        _ ->
+            rabbit_ct_helpers:set_config(Config0,
+                [{node, non_existent_node@localhost}])
+    end,
+    rabbit_ct_helpers:testcase_started(Config1, Testcase).
+
+end_per_testcase(Testcase, Config0) ->
+    Config1 = case ?config(need_start, Config0) of
+        true ->
+            rabbit_ct_helpers:run_teardown_steps(Config0,
+                rabbit_ct_broker_helpers:teardown_steps());
+        _ -> Config0
+    end,
+    rabbit_ct_helpers:testcase_finished(Config1, Testcase).
+
+save_node(Config) ->
+    Node = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename),
+    rabbit_ct_helpers:set_config(Config, [{node, Node}]).
+
+shutdown_running_node_ok(Config) ->
+    Node = ?config(node, Config),
+    Pid = node_pid(Node),
+    ok = rabbit_control_main:action(shutdown, Node, [], [], fun ct:pal/2),
+    false = erlang_pid_is_running(Pid),
+    false = node_is_running(Node).
+
+node_pid(Node) ->
+    Val = rpc:call(Node, os, getpid, []),
+    true = is_list(Val),
+    list_to_integer(Val).
+
+erlang_pid_is_running(Pid) ->
+    rabbit_misc:is_os_process_alive(integer_to_list(Pid)).
+
+node_is_running(Node) ->
+    net_adm:ping(Node) == pong.