mirror of
https://github.com/valitydev/riak_test.git
synced 2024-11-06 16:45:29 +00:00
144 lines
4.2 KiB
Erlang
144 lines
4.2 KiB
Erlang
%% -------------------------------------------------------------------
|
|
%%
|
|
%% Copyright (c) 2012 Basho Technologies, Inc.
|
|
%%
|
|
%% This file is provided to you under the Apache License,
|
|
%% Version 2.0 (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.apache.org/licenses/LICENSE-2.0
|
|
%%
|
|
%% Unless required by applicable law or agreed to in writing,
|
|
%% software distributed under the License is distributed on an
|
|
%% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
%% KIND, either express or implied. See the License for the
|
|
%% specific language governing permissions and limitations
|
|
%% under the License.
|
|
%%
|
|
%% -------------------------------------------------------------------
|
|
-module(basic_command_line).
|
|
-include_lib("eunit/include/eunit.hrl").
|
|
|
|
-export([confirm/0]).
|
|
|
|
confirm() ->
|
|
|
|
%% Deploy a node to test against
|
|
lager:info("Deploy node to test command line"),
|
|
[Node] = rt:deploy_nodes(1),
|
|
?assertEqual(ok, rt:wait_until_nodes_ready([Node])),
|
|
|
|
%% Verify node-up behavior
|
|
ping_up_test(Node),
|
|
attach_up_test(Node),
|
|
status_up_test(Node),
|
|
console_up_test(Node),
|
|
start_up_test(Node),
|
|
|
|
%% Stop the node, Verify node-down behavior
|
|
stop_test(Node),
|
|
ping_down_test(Node),
|
|
attach_down_test(Node),
|
|
status_down_test(Node),
|
|
console_test(Node),
|
|
start_test(Node),
|
|
|
|
pass.
|
|
|
|
console_up_test(Node) ->
|
|
lager:info("Node is already up, `riak console` should fail"),
|
|
{ok, ConsoleFail} = rt:riak(Node, ["console"]),
|
|
?assert(rt:str(ConsoleFail, "Node is already running")),
|
|
ok.
|
|
|
|
console_test(Node) ->
|
|
%% Make sure the cluster will start up with /usr/sbin/riak console, then quit
|
|
lager:info("Testing riak console on ~s", [Node]),
|
|
|
|
%% Stop node, to test console working
|
|
rt:console(Node, [{expect, "\(abort with ^G\)"},
|
|
{send, "riak_core_ring_manager:get_my_ring()."},
|
|
{expect, "dict,"},
|
|
{send, "q()."},
|
|
{expect, "ok"}]),
|
|
rt:wait_until_unpingable(Node),
|
|
ok.
|
|
|
|
start_up_test(Node) ->
|
|
%% Try starting again and check you get the node is already running message
|
|
lager:info("Testing riak start now will return 'already running'"),
|
|
{ok, StartOut} = rt:riak(Node, ["start"]),
|
|
?assert(rt:str(StartOut, "Node is already running!")),
|
|
ok.
|
|
|
|
|
|
start_test(Node) ->
|
|
%% Test starting with /bin/riak start
|
|
lager:info("Testing riak start works on ~s", [Node]),
|
|
|
|
{ok, StartPass} = rt:riak(Node, ["start"]),
|
|
?assertMatch(StartPass, ""),
|
|
rt:stop_and_wait(Node),
|
|
ok.
|
|
|
|
stop_test(Node) ->
|
|
?assert(rt:is_pingable(Node)),
|
|
|
|
{ok, "ok\n"} = rt:riak(Node, "stop"),
|
|
|
|
?assertNot(rt:is_pingable(Node)),
|
|
ok.
|
|
|
|
ping_up_test(Node) ->
|
|
|
|
%% check /usr/sbin/riak ping
|
|
lager:info("Testing riak ping on ~s", [Node]),
|
|
|
|
%% ping / pong
|
|
%% rt:start_and_wait(Node),
|
|
lager:info("Node up, should ping"),
|
|
{ok, PongOut} = rt:riak(Node, ["ping"]),
|
|
?assert(rt:str(PongOut, "pong")),
|
|
ok.
|
|
|
|
ping_down_test(Node) ->
|
|
%% ping / pang
|
|
lager:info("Node down, should pang"),
|
|
{ok, PangOut} = rt:riak(Node, ["ping"]),
|
|
?assert(rt:str(PangOut, "not responding to pings")),
|
|
ok.
|
|
|
|
attach_up_test(Node) ->
|
|
lager:info("Testing riak attach"),
|
|
|
|
rt:attach(Node, [{expect, "\(^D to exit\)"},
|
|
{send, "riak_core_ring_manager:get_my_ring()."},
|
|
{expect, "dict,"},
|
|
{send, [4]}]), %% 4 = Ctrl + D
|
|
|
|
ok.
|
|
|
|
attach_down_test(Node) ->
|
|
lager:info("Testing riak attach while down"),
|
|
{ok, AttachOut} = rt:riak(Node, ["attach"]),
|
|
?assert(rt:str(AttachOut, "Node is not running!")),
|
|
ok.
|
|
|
|
status_up_test(Node) ->
|
|
lager:info("Test riak-admin status on ~s", [Node]),
|
|
|
|
{ok, StatusOut} = rt:admin(Node, ["status"]),
|
|
io:format("Result of status: ~s", [StatusOut]),
|
|
|
|
?assert(rt:str(StatusOut, "1-minute stats")),
|
|
?assert(rt:str(StatusOut, "kernel_version")),
|
|
|
|
ok.
|
|
|
|
status_down_test(Node) ->
|
|
lager:info("Test riak-admin status while down"),
|
|
{ok, StatusOut} = rt:admin(Node, ["status"]),
|
|
?assert(rt:str(StatusOut, "Node is not running!")),
|
|
ok.
|