117 lines
4.6 KiB
Erlang
117 lines
4.6 KiB
Erlang
%%--------------------------------------------------------------------
|
|
%% Copyright (c) 2020 EMQ Technologies Co., Ltd. All Rights Reserved.
|
|
%%
|
|
%% Licensed 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(emqx_recon_SUITE).
|
|
|
|
-compile(export_all).
|
|
|
|
-include_lib("eunit/include/eunit.hrl").
|
|
|
|
-define(output_patterns(V), ((V)++"")).
|
|
|
|
all() -> [{group, cli}].
|
|
|
|
groups() ->
|
|
[{cli, [sequence],
|
|
[cli_memory,
|
|
cli_allocated,
|
|
cli_bin_leak,
|
|
cli_node_stats,
|
|
cli_remote_load,
|
|
cli_usage]}
|
|
].
|
|
|
|
init_per_suite(Config) ->
|
|
DataDir = proplists:get_value(data_dir, Config),
|
|
[start_apps(App, DataDir) || App <- [emqx, emqx_recon]],
|
|
Config.
|
|
|
|
end_per_suite(_Config) ->
|
|
application:stop(emqx_recon),
|
|
application:stop(emqx).
|
|
|
|
cli_memory(_) ->
|
|
print_mock(),
|
|
Output = emqx_recon_cli:cmd(["memory"]),
|
|
Zip = lists:zip(Output, [ ?output_patterns("usage/current")
|
|
, ?output_patterns("usage/max")
|
|
, ?output_patterns("used/current")
|
|
, ?output_patterns("used/max")
|
|
, ?output_patterns("allocated/current")
|
|
, ?output_patterns("allocated/max")
|
|
, ?output_patterns("unused/current")
|
|
, ?output_patterns("unused/max")
|
|
]),
|
|
%ct:pal("=======~p", [Zip]),
|
|
[?assertMatch({match, _}, re:run(Line, Match, [{capture,all,list}]))
|
|
|| {Line, Match} <- Zip].
|
|
|
|
cli_allocated(_) ->
|
|
print_mock(),
|
|
Output = emqx_recon_cli:cmd(["allocated"]),
|
|
Zip = lists:zip(Output, [ ?output_patterns("binary_alloc/current")
|
|
, ?output_patterns("driver_alloc/current")
|
|
, ?output_patterns("eheap_alloc/current")
|
|
, ?output_patterns("ets_alloc/current")
|
|
, ?output_patterns("fix_alloc/current")
|
|
, ?output_patterns("ll_alloc/current")
|
|
, ?output_patterns("sl_alloc/current")
|
|
, ?output_patterns("std_alloc/current")
|
|
, ?output_patterns("temp_alloc/current")
|
|
, ?output_patterns("binary_alloc/max")
|
|
, ?output_patterns("driver_alloc/max")
|
|
, ?output_patterns("eheap_alloc/max")
|
|
, ?output_patterns("ets_alloc/max")
|
|
, ?output_patterns("fix_alloc/max")
|
|
, ?output_patterns("ll_alloc/max")
|
|
, ?output_patterns("sl_alloc/max")
|
|
, ?output_patterns("std_alloc/max")
|
|
, ?output_patterns("temp_alloc/max")
|
|
]),
|
|
ct:pal("=======~p", [Zip]),
|
|
[?assertMatch({match, _}, re:run(Line, Match, [{capture,all,list}]))
|
|
|| {Line, Match} <- Zip].
|
|
|
|
cli_bin_leak(_) ->
|
|
print_mock(),
|
|
Output = emqx_recon_cli:cmd(["bin_leak"]),
|
|
[?assertMatch({match, _}, re:run(Line, "current_function", [{capture,all,list}]))
|
|
|| Line <- Output].
|
|
|
|
cli_node_stats(_) ->
|
|
emqx_recon_cli:cmd(["node_stats"]).
|
|
|
|
cli_remote_load(_) ->
|
|
emqx_recon_cli:cmd(["remote_load", "emqx_recon_cli"]).
|
|
|
|
cli_usage(_) ->
|
|
emqx_recon_cli:cmd(["usage"]).
|
|
|
|
start_apps(App, DataDir) ->
|
|
Schema = cuttlefish_schema:files([filename:join([DataDir, atom_to_list(App) ++ ".schema"])]),
|
|
Conf = conf_parse:file(filename:join([DataDir, atom_to_list(App) ++ ".conf"])),
|
|
NewConfig = cuttlefish_generator:map(Schema, Conf),
|
|
Vals = proplists:get_value(App, NewConfig),
|
|
[application:set_env(App, Par, Value) || {Par, Value} <- Vals],
|
|
application:ensure_all_started(App).
|
|
|
|
print_mock() ->
|
|
meck:new(emqx_ctl, [non_strict, passthrough]),
|
|
meck:expect(emqx_ctl, print, fun(Arg) -> emqx_ctl:format(Arg) end),
|
|
meck:expect(emqx_ctl, print, fun(Msg, Arg) -> emqx_ctl:format(Msg, Arg) end),
|
|
meck:expect(emqx_ctl, usage, fun(Usages) -> emqx_ctl:format_usage(Usages) end).
|
|
|