Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

3012 lines (2582 sloc) 104.917 kb
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 1996-2013. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% 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.
%%
%% %CopyrightEnd%
%%
-module(application_SUITE).
-include_lib("test_server/include/test_server.hrl").
-export([all/0, suite/0,groups/0,init_per_suite/1, end_per_suite/1,
init_per_group/2,end_per_group/2
]).
-export([failover/1, failover_comp/1, permissions/1, load/1,
load_use_cache/1,
otp_1586/1, otp_2078/1, otp_2012/1, otp_2718/1, otp_2973/1,
otp_3002/1, otp_3184/1, otp_4066/1, otp_4227/1, otp_5363/1,
otp_5606/1,
start_phases/1, get_key/1, get_env/1,
permit_false_start_local/1, permit_false_start_dist/1, script_start/1,
nodedown_start/1, init2973/0, loop2973/0, loop5606/1]).
-export([config_change/1,
distr_changed_tc1/1, distr_changed_tc2/1,
ensure_started/1,
shutdown_func/1, do_shutdown/1, shutdown_timeout/1]).
-define(TESTCASE, testcase_name).
-define(testcase, ?config(?TESTCASE, Config)).
-export([init_per_testcase/2, end_per_testcase/2, start_type/0,
start_phase/0, conf_change/0]).
% Default timetrap timeout (set in init_per_testcase).
-define(default_timeout, ?t:minutes(2)).
suite() -> [{ct_hooks,[ts_install_cth]}].
all() ->
[failover, failover_comp, permissions, load,
load_use_cache, ensure_started, {group, reported_bugs}, start_phases,
script_start, nodedown_start, permit_false_start_local,
permit_false_start_dist, get_key, get_env,
{group, distr_changed}, config_change, shutdown_func, shutdown_timeout].
groups() ->
[{reported_bugs, [],
[otp_1586, otp_2078, otp_2012, otp_2718, otp_2973,
otp_3002, otp_3184, otp_4066, otp_4227, otp_5363,
otp_5606]},
{distr_changed, [],
[distr_changed_tc1, distr_changed_tc2]}].
init_per_suite(Config) ->
Config.
end_per_suite(_Config) ->
ok.
init_per_group(_GroupName, Config) ->
Config.
end_per_group(_GroupName, Config) ->
Config.
init_per_testcase(otp_2973=Case, Config) ->
code:add_path(?config(data_dir,Config)),
Dog = test_server:timetrap(?default_timeout),
[{?TESTCASE, Case}, {watchdog, Dog}|Config];
init_per_testcase(Case, Config) ->
Dog = test_server:timetrap(?default_timeout),
[{?TESTCASE, Case}, {watchdog, Dog}|Config].
end_per_testcase(otp_2973, Config) ->
code:del_path(?config(data_dir,Config)),
Dog=?config(watchdog, Config),
test_server:timetrap_cancel(Dog),
ok;
end_per_testcase(_Case, Config) ->
Dog=?config(watchdog, Config),
test_server:timetrap_cancel(Dog),
ok.
-define(UNTIL(Seq), loop_until_true(fun() -> Seq end)).
-record(st, {
normal = 0,
local = 0,
takeover = 0,
failover = 0
}).
loop_until_true(Fun) ->
case Fun() of
true ->
ok;
_ ->
timer:sleep(100),
loop_until_true(Fun)
end.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3, cp4]
%%-----------------------------------------------------------------
failover(suite) -> [];
failover(doc) ->
["Tests failover and takeover for distributed applications. Tests",
"start, load etc implicitly."];
failover(Conf) when is_list(Conf) ->
%% start a help process to check the start type
StPid = spawn_link(?MODULE, start_type, []),
yes = global:register_name(st_type, StPid),
NodeNames = [Ncp1, Ncp2, Ncp3, Ncp4]
= node_names([cp1, cp2, cp3, cp4], Conf),
Cp1NoSyncTime = config_fun_fast(config_fo1(NodeNames)),
Cp2NoSyncTime = config_fun_fast(config_fo2(NodeNames)),
Cp3NoSyncTime = config_fun_fast(config_fo3(NodeNames)),
Cp4WithSyncTime = config_fun(config_fo4(NodeNames)),
% Test [cp1, cp2, cp3, cp4]
{ok, Cp1} = start_node_config(Ncp1, Cp1NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, Cp2NoSyncTime, Conf),
{ok, Cp3} = start_node_config(Ncp3, Cp3NoSyncTime, Conf),
{ok, Cp4} = start_node_config(Ncp4, Cp4WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3, Cp4],
wait_for_ready_net(),
% Start app1 and make sure cp1 starts it
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, load, [app1()]),
?UNTIL(is_loaded(app1, [Cp1, Cp2, Cp3])),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
false = is_started(app1, Cp4),
ok = get_start_type(#st{normal = 3}),
% Start app_no and make sure cp1 & cp3 starts it
{[ok,ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app_no()]),
?UNTIL(is_loaded(app_no, Cps)),
{[ok,ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app_no, permanent]),
?UNTIL(is_started(app_no, Cp1)),
false = is_started(app_no, Cp2),
?UNTIL(is_started(app_no, Cp3)),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{normal = 6}),
% Stop cp1 and make sure cp2 starts app1 & app_no
stop_node_nice(Cp1),
?UNTIL(is_started(app1, Cp2)),
?UNTIL(is_started(app_no, Cp2)),
ok = get_start_type(#st{normal = 6}),
% make sure cp3 is still running app_no
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Restart cp1 and make sure it restarts app1 & app_no
{ok, Cp1_2} = start_node_config(Ncp1, Cp1NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp1_2, application, load, [app1()]),
ok = rpc:call(Cp1_2, application, load, [app_no()]),
ok = rpc:call(Cp1_2, application, start, [app1, permanent]),
ok = rpc:call(Cp1_2, application, start, [app_no, permanent]),
?UNTIL(is_started(app1, Cp1)),
?UNTIL(not is_started(app1, Cp2)),
?UNTIL(is_started(app_no, Cp1)),
?UNTIL(not is_started(app_no, Cp2)),
false = is_started(app1, Cp3),
ok = get_start_type(#st{takeover = 6}),
% make sure cp3 is still running app_no
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Test [{cp1, cp2}, cp3]
% Start app_sp and make sure cp2 starts it (cp1 has more apps started)
{[ok,ok,ok],[]} =
rpc:multicall([Cp1_2, Cp2, Cp3], application, load, [app_sp()]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1_2, Cp2, Cp3], application, start,[app_sp,permanent]),
?UNTIL(is_started(app_sp, Cp2)),
false = is_started(app_sp, Cp1),
false = is_started(app_sp, Cp3),
false = is_started(app_sp, Cp4),
ok = get_start_type(#st{normal = 3}),
% Stop cp2 and make sure cp1 starts app_sp
stop_node_nice(Cp2),
?UNTIL(is_started(app_sp, Cp1_2)),
ok = get_start_type(#st{failover = 3}),
% make sure cp1 & cp3 are still running app_no
true = is_started(app_no, Cp1),
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Stop cp1 and make sure cp3 starts app_sp
stop_node_nice(Cp1_2),
?UNTIL(is_started(app_sp, Cp3)),
ok = get_start_type(#st{normal = 3, failover = 3}),
% make sure cp3 is still running app_no
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Restart cp2 and make sure it restarts app_sp & app_no
{ok, Cp2_2} = start_node_config(Ncp2, Cp2NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp2_2, application, load, [app_sp()]),
ok = rpc:call(Cp2_2, application, load, [app_no()]),
ok = rpc:call(Cp2_2, application, start, [app_sp, permanent]),
ok = rpc:call(Cp2_2, application, start, [app_no, permanent]),
?UNTIL(is_started(app_sp, Cp2_2)),
?UNTIL(is_started(app_no, Cp2_2)),
?UNTIL(not is_started(app_sp, Cp3)),
ok = get_start_type(#st{takeover = 6}),
% make sure cp3 is still running app_no
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Restart cp1 and make sure it doesn't restart app_sp and does start app_no
{ok, Cp1_3} = start_node_config(Ncp1, Cp1NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp1_3, application, load, [app_sp()]),
ok = rpc:call(Cp1_3, application, load, [app_no()]),
ok = rpc:call(Cp1_3, application, start, [app_sp, permanent]),
ok = rpc:call(Cp1_3, application, start, [app_no, permanent]),
test_server:sleep(500),
false = is_started(app_sp, Cp1_3),
true = is_started(app_sp, Cp2_2),
?UNTIL(is_started(app_no, Cp1_3)),
?UNTIL(not is_started(app_no, Cp2_2)),
ok = get_start_type(#st{takeover = 3}),
% make sure cp3 is still running app_no
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
% Force app_sp takeover to cp1
ok = rpc:call(Cp1_3, application, takeover, [app_sp, permanent]),
?UNTIL(is_started(app_sp, Cp1_3)),
?UNTIL(not is_started(app_sp, Cp2_2)),
ok = get_start_type(#st{takeover = 3}),
% Force app_no takeover to cp4
ok = rpc:call(Cp4, application, takeover, [app_no, permanent]),
?UNTIL(is_started(app_no, Cp4)),
?UNTIL(not is_started(app_no, Cp3)),
ok = get_start_type(#st{takeover = 3}),
% make sure cp1 is still running app_no
true = is_started(app_no, Cp1_3),
false = is_started(app_no, Cp2_2),
%% Kill one child process and see that it is started with type local
PP = global:whereis_name({ch,3}),
exit(PP, kill),
ok = get_start_type(#st{local = 1}),
global:send(st_type, kill),
stop_node_nice(Cp1_3),
stop_node_nice(Cp2_2),
stop_node_nice(Cp3),
stop_node_nice(Cp4),
ok.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3]
%%-----------------------------------------------------------------
failover_comp(suite) -> [];
failover_comp(doc) ->
["Tests failover and takeover for distributed applications. Tests",
"start, load etc implicitly. The applications do not use start_phases,"
"i.e the failover should be trasfered to normal start type."];
failover_comp(Conf) when is_list(Conf) ->
%% start a help process to check the start type
StPid = spawn_link(?MODULE, start_type, []),
yes = global:register_name(st_type, StPid),
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config(NodeNames)),
WithSyncTime = config_fun(config(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, NoSyncTime, Conf),
{ok, Cp3} = start_node_config(Ncp3, WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3],
wait_for_ready_net(),
% Start app1 and make sure cp1 starts it
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
ok = get_start_type(#st{normal = 3}),
% Stop cp1 and make sure cp2 starts app1
stop_node_nice(Cp1),
?UNTIL(is_started(app1, Cp2)),
ok = get_start_type(#st{normal = 3}),
% Restart cp1 and make sure it restarts app1
{ok, Cp1_2} = start_node_config(Ncp1, NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp1_2, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cp1_2)),
ok = rpc:call(Cp1_2, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1_2)),
?UNTIL(not is_started(app1, Cp2)),
ok = get_start_type(#st{takeover = 3}),
% Test [{cp1, cp2}, cp3]
% Start app3 and make sure cp2 starts it (cp1 has more apps started)
{[ok,ok,ok],[]} =
rpc:multicall([Cp1_2, Cp2, Cp3], application, load, [app3()]),
?UNTIL(is_loaded(app3, [Cp1_2, Cp2, Cp3])),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1_2, Cp2, Cp3], application, start,[app3,permanent]),
?UNTIL(is_started(app3, Cp2)),
false = is_started(app3, Cp1),
false = is_started(app3, Cp3),
ok = get_start_type(#st{normal = 3}),
% Stop cp2 and make sure cp1 starts app3
stop_node_nice(Cp2),
?UNTIL(is_started(app3, Cp1_2)),
ok = get_start_type(#st{normal = 3}),
% Stop cp1 and make sure cp3 starts app3
stop_node_nice(Cp1_2),
?UNTIL(is_started(app3, Cp3)),
ok = get_start_type(#st{normal = 6}),
% Restart cp2 and make sure it restarts app3
{ok, Cp2_2} = start_node_config(Ncp2, NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp2_2, application, load, [app3()]),
?UNTIL(is_loaded(app3, Cp2_2)),
ok = rpc:call(Cp2_2, application, start, [app3, permanent]),
?UNTIL(is_started(app3, Cp2_2)),
?UNTIL(not is_started(app3, Cp3)),
ok = get_start_type(#st{takeover = 3}),
% Restart cp1 and make sure it doesn't restart app3
{ok, Cp1_3} = start_node_config(Ncp1, NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp1_3, application, load, [app3()]),
true = is_loaded(app3, Cp1_3),
ok = rpc:call(Cp1_3, application, start, [app3, permanent]),
test_server:sleep(5000),
false = is_started(app3, Cp1_3),
true = is_started(app3, Cp2_2),
% Force takeover to cp1
ok = rpc:call(Cp1_3, application, takeover, [app3, permanent]),
?UNTIL(is_started(app3, Cp1_3)),
?UNTIL(not is_started(app3, Cp2_2)),
ok = get_start_type(#st{takeover = 3}),
%% Kill one child process and see that it is started with type local
PP = global:whereis_name({ch,3}),
exit(PP, kill),
ok = get_start_type(#st{local = 1}),
global:send(st_type, kill),
stop_node_nice(Cp1_3),
stop_node_nice(Cp2_2),
stop_node_nice(Cp3),
ok.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3]
%%-----------------------------------------------------------------
permissions(suite) -> [];
permissions(doc) ->
["Tests permissions for distributed applications."];
permissions(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config2(NodeNames)),
WithSyncTime = config_fun(config2(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, NoSyncTime, Conf),
{ok, Cp3} = start_node_config(Ncp3, WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3],
wait_for_ready_net(),
% Start app1 and make sure cp1 starts it
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
% Unpermit app1 on cp1, make sure cp2 starts it
ok = rpc:call(Cp1, application, permit, [app1, false]),
false = is_started(app1, Cp1),
true = is_started(app1, Cp2),
% Unpermit app1 on cp2, make sure cp3 starts it
ok = rpc:call(Cp2, application, permit, [app1, false]),
false = is_started(app1, Cp1),
false = is_started(app1, Cp2),
true = is_started(app1, Cp3),
% Permit cp2 again
ok = rpc:call(Cp2, application, permit, [app1, true]),
false = is_started(app1, Cp1),
false = is_started(app1, Cp3),
true = is_started(app1, Cp2),
% Start app3, make sure noone starts it
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app3()]),
?UNTIL(is_loaded(app3, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app3, permanent]),
test_server:sleep(1000),
false = is_started(app3, Cp1),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
% Permit app3 on Cp3
ok = rpc:call(Cp3, application, permit, [app3, true]),
true = is_started(app3, Cp3),
% Permit app3 on Cp2, make sure it starts it
ok = rpc:call(Cp2, application, permit, [app3, true]),
true = is_started(app3, Cp2),
false = is_started(app3, Cp3),
% Permit app3 on Cp1, make sure it doesn't start it
ok = rpc:call(Cp1, application, permit, [app3, true]),
false = is_started(app3, Cp1),
true = is_started(app3, Cp2),
false = is_started(app3, Cp3),
% Stop Cp2, make sure Cp1 starts app3
stop_node_nice(Cp2),
?UNTIL(is_started(app3, Cp1)),
stop_node_nice(Cp1),
stop_node_nice(Cp3),
ok.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3]
%%-----------------------------------------------------------------
load(suite) -> [];
load(doc) ->
["Tests loading of distributed applications."];
load(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config3(NodeNames)),
WithSyncTime = config_fun(config3(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, NoSyncTime, Conf),
{ok, Cp3} = start_node_config(Ncp3, WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3],
wait_for_ready_net(),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1(), d1(NodeNames)]),
?UNTIL(is_loaded(app1, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Load app1 with different specs and make sure we get an error
{[{error,_},{error,_}],[]} =
rpc:multicall([Cp1, Cp2], application, load, [app1(), d1(NodeNames)]),
{error, _} = rpc:call(Cp3, application, load, [app1(), d2(NodeNames)]),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok.
%%-----------------------------------------------------------------
%% Same test as load/1, only with code path cache enabled.
%%-----------------------------------------------------------------
load_use_cache(suite) -> [];
load_use_cache(doc) ->
["Tests loading of distributed applications. Code path cache enabled."];
load_use_cache(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config3(NodeNames)),
WithSyncTime = config_fun(config3(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_with_cache(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_with_cache(Ncp2, NoSyncTime, Conf),
{ok, Cp3} = start_node_with_cache(Ncp3, WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3],
wait_for_ready_net(),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1(), d1(NodeNames)]),
?UNTIL(is_loaded(app1, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
% Load app1 with different specs and make sure we get an error
{[{error,_},{error,_}],[]} =
rpc:multicall([Cp1, Cp2], application, load, [app1(), d1(NodeNames)]),
{error, _} = rpc:call(Cp3, application, load, [app1(), d2(NodeNames)]),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3]
%%-----------------------------------------------------------------
start_phases(suite) -> [];
start_phases(doc) ->
["Tests new start phases and failover."];
start_phases(Conf) when is_list(Conf) ->
%% start a help process to check the start type
SpPid = spawn_link(?MODULE, start_phase, []),
yes = global:register_name(start_phase, SpPid),
NodeNames = [Ncp1, _Ncp2, _Ncp3] = node_names([cp1, cp2, cp3], Conf),
WithSyncTime = config_fun(config_sf(NodeNames)),
{ok, Cp1} = start_node_config_sf(Ncp1, WithSyncTime, Conf),
wait_for_ready_net(),
%%=============================
%%Example 1 in the user's guide
%%=============================
ok = rpc:call(Cp1, application, load, [myApp,
d_any3(myApp, NodeNames)]),
?UNTIL(is_loaded(myApp, Cp1)),
ok = rpc:call(Cp1, application, start, [myApp, permanent]),
?UNTIL(is_started(myApp, Cp1)),
ok = get_start_phase({sp, 0, 1, 0, 0, 1}),
ok = rpc:call(Cp1, application, stop, [myApp]),
%%=============================
%%Example 2 in the user's guide
%%=============================
ok = rpc:call(Cp1, application, load, [topApp,
d_any3(topApp, NodeNames)]),
?UNTIL(is_loaded(topApp, Cp1)),
ok = rpc:call(Cp1, application, start, [topApp, permanent]),
?UNTIL(is_started(topApp, Cp1)),
ok = get_start_phase({sp, 0, 1, 0, 0, 1}),
ok = rpc:call(Cp1, application, stop, [topApp]),
%%=============================
%%Example 3 in the user's guide
%%=============================
ok = rpc:call(Cp1, application, load, [topApp2,
d_any3(topApp2, NodeNames)]),
?UNTIL(is_loaded(topApp2, Cp1)),
ok = rpc:call(Cp1, application, start, [topApp2, permanent]),
?UNTIL(is_started(topApp2, Cp1)),
ok = get_start_phase({sp, 0, 2, 0, 0, 3}),
ok = rpc:call(Cp1, application, stop, [topApp2]),
%%=============================
%%Example 4 in the user's guide
%%=============================
ok = rpc:call(Cp1, application, load, [topApp3,
d_any3(topApp3, NodeNames)]),
?UNTIL(is_loaded(topApp3, Cp1)),
ok = rpc:call(Cp1, application, start, [topApp3, permanent]),
?UNTIL(is_started(topApp3, Cp1)),
ok = get_start_phase({sp, 1, 3, 3, 2, 4}),
ok = rpc:call(Cp1, application, stop, [topApp3]),
global:send(start_phase, kill),
stop_node_nice(Cp1),
ok.
script_start(doc) ->
["Start distributed applications from within a boot script. Test ",
"same as failover."];
script_start(suite) -> [];
script_start(Conf) when is_list(Conf) ->
%% start a help process to check the start type
StPid = spawn_link(?MODULE, start_type, []),
yes = global:register_name(st_type, StPid),
% Create the .app files and the boot script
ok = create_app(),
{{KernelVer,StdlibVer}, _} = create_script("latest"),
{{KernelVer,StdlibVer}, _} = create_script_no("latest_no"),
case is_real_system(KernelVer, StdlibVer) of
true ->
Options = [];
false ->
Options = [local]
end,
ok = systools:make_script("latest", Options),
ok = systools:make_script("latest_no", Options),
NodeNames = [Ncp1, Ncp2, Ncp3, Ncp4]
= node_names([cp1, cp2, cp3, cp4], Conf),
Cp1NoSyncTime = config_fun_fast(config_fo1(NodeNames)),
Cp2NoSyncTime = config_fun_fast(config_fo2(NodeNames)),
Cp3NoSyncTime = config_fun_fast(config_fo3(NodeNames)),
Cp4WithSyncTime = config_fun(config_fo4(NodeNames)),
% Test [cp1, cp2, cp3, cp4]
{ok, Cp1} = start_node_boot_config(Ncp1, Cp1NoSyncTime, Conf, latest),
{ok, Cp2} = start_node_boot_config(Ncp2, Cp2NoSyncTime, Conf, latest),
{ok, Cp3} = start_node_boot_config(Ncp3, Cp3NoSyncTime, Conf, latest),
{ok, Cp4} = start_node_boot_config(Ncp4, Cp4WithSyncTime, Conf, latest_no),
wait_for_ready_net(),
?UNTIL(is_started(app1, Cp1)),
?UNTIL(is_started(app2, Cp1)),
?UNTIL(is_started(app_sp, Cp1)),
?UNTIL(is_started(app_no, Cp1)),
?UNTIL(is_started(app_no, Cp3)),
false = is_started(app1, Cp2),
false = is_started(app2, Cp2),
false = is_started(app_sp, Cp2),
false = is_started(app_no, Cp2),
false = is_started(app1, Cp3),
false = is_started(app2, Cp3),
false = is_started(app_sp, Cp3),
false = is_started(app1, Cp4),
false = is_started(app2, Cp4),
false = is_started(app_sp, Cp4),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{normal = 12}),
% Stop cp1 and make sure cp2 starts app1 and app2 normally
% (no start_phases defined), app_sp as failover (start_phases
% defined) and app_no as takeover (no start_phases defined)
stop_node_nice(Cp1),
?UNTIL(is_started(app1, Cp2)),
?UNTIL(is_started(app2, Cp2)),
?UNTIL(is_started(app_sp, Cp2)),
?UNTIL(is_started(app_no, Cp2)),
true = is_started(app_no, Cp3),
false = is_started(app1, Cp3),
false = is_started(app2, Cp3),
false = is_started(app_sp, Cp3),
false = is_started(app1, Cp4),
false = is_started(app2, Cp4),
false = is_started(app_sp, Cp4),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{normal = 9, takeover = 3, failover = 3}),
% Restart cp1, cp1 takes over app1, app2 and app_no
{ok, Cp1_2} = start_node_boot_config(Ncp1, Cp1NoSyncTime, Conf, latest),
global:sync(),
?UNTIL(is_started(app1, Cp1_2)),
false = is_started(app1, Cp2),
?UNTIL(is_started(app2, Cp1_2)),
?UNTIL(is_started(app_no, Cp1_2)),
true = is_started(app_sp, Cp2),
?UNTIL(not is_started(app1, Cp2)),
?UNTIL(not is_started(app2, Cp2)),
?UNTIL(not is_started(app_no, Cp2)),
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{takeover = 9}),
% Stop cp2 and make sure cp1 starts app_sp.
false = is_started(app_sp, Cp1_2),
stop_node_nice(Cp2),
?UNTIL(is_started(app_sp, Cp1_2)),
ok = get_start_type(#st{failover = 3}),
% Stop cp1 and make sure cp3 starts app1, app2 and app_sp
stop_node_nice(Cp1_2),
?UNTIL(is_started(app_sp, Cp3)),
?UNTIL(is_started(app1, Cp3)),
?UNTIL(is_started(app2, Cp3)),
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{normal = 6, failover = 3}),
% Restart cp2 and make sure it takes over app1, app2, app_sp app_no
{ok, Cp2_2} = start_node_boot_config(Ncp2, Cp2NoSyncTime, Conf, latest),
global:sync(),
?UNTIL(is_started(app_sp, Cp2_2)),
?UNTIL(is_started(app1, Cp2_2)),
?UNTIL(is_started(app2, Cp2_2)),
?UNTIL(is_started(app_no, Cp2_2)),
?UNTIL(not is_started(app_sp, Cp3)),
?UNTIL(not is_started(app1, Cp3)),
?UNTIL(not is_started(app2, Cp3)),
true = is_started(app_no, Cp3),
false = is_started(app_no, Cp4),
ok = get_start_type(#st{takeover = 12}),
% Restart cp1 and make sure it takesover app1, app2 and app_no
{ok, Cp1_3} = start_node_boot_config(Ncp1, Cp1NoSyncTime, Conf, latest),
global:sync(),
?UNTIL(is_started(app1, Cp1_3)),
?UNTIL(is_started(app2, Cp1_3)),
?UNTIL(is_started(app_no, Cp1_3)),
false = is_started(app_sp, Cp1_3),
true = is_started(app_sp, Cp2_2),
?UNTIL(not is_started(app1, Cp2_2)),
?UNTIL(not is_started(app2, Cp2_2)),
?UNTIL(not is_started(app_no, Cp2_2)),
ok = get_start_type(#st{takeover = 9}),
% Force app_sp takeover to cp1
ok = rpc:call(Cp1_3, application, takeover, [app_sp, permanent]),
?UNTIL(is_started(app_sp, Cp1_3)),
?UNTIL(not is_started(app_sp, Cp2_2)),
ok = get_start_type(#st{takeover = 3}),
% Force app_no takeover to cp4
ok = rpc:call(Cp4, application, takeover, [app_no, permanent]),
?UNTIL(is_started(app_no, Cp4)),
?UNTIL(not is_started(app_no, Cp3)),
true = is_started(app_no, Cp1),
false = is_started(app_no, Cp2),
ok = get_start_type(#st{takeover = 3}),
%% Kill one child process and see that it is started with type local
PP = global:whereis_name({ch,3}),
exit(PP, kill),
ok = get_start_type(#st{local = 1}),
global:send(st_type, kill),
stop_node_nice(Cp1_3),
stop_node_nice(Cp2_2),
stop_node_nice(Cp3),
stop_node_nice(Cp4),
ok = file:delete("latest.boot"),
ok = file:delete("latest.rel"),
ok = file:delete("latest.script"),
ok.
permit_false_start_local(doc) ->
["Start local applications with permission false. Set",
"permit true on different nodes."];
permit_false_start_local(suite) -> [];
permit_false_start_local(Conf) when is_list(Conf) ->
%% This configuration does not start dist_ac.
Config = write_config_file(fun config_perm/1, Conf),
% Test [cp1, cp2, cp3]
[Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
{ok, Cp1} = start_node(Ncp1, Config),
{ok, Cp2} = start_node(Ncp2, Config),
{ok, Cp3} = start_node(Ncp3, Config),
wait_for_ready_net(),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, load, [app1()]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, start, [app1, permanent]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, load, [app2()]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, start, [app2, permanent]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, load, [app3()]),
test_server:sleep(1000),
false = is_started(app1, Cp1),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
%Permit a not started application
ok = rpc:call(Cp1, application, permit, [app3, true]),
test_server:sleep(1000),
false = is_started(app3, Cp1),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
%Permit a not loaded application
{error,{not_loaded,app_notloaded}} =
rpc:call(Cp1, application, permit, [app_notloaded, true]),
test_server:sleep(1000),
false = is_started(app_notloaded, Cp1),
false = is_started(app_notloaded, Cp2),
false = is_started(app_notloaded, Cp3),
%Unpermit a not started application
ok = rpc:call(Cp1, application, permit, [app3, false]),
test_server:sleep(1000),
false = is_started(app3, Cp1),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
%Unpermit a not loaded application
{error,{not_loaded,app_notloaded}} =
rpc:call(Cp1, application, permit, [app_notloaded, false]),
test_server:sleep(1000),
false = is_started(app_notloaded, Cp1),
false = is_started(app_notloaded, Cp2),
false = is_started(app_notloaded, Cp3),
% Permit app1 on CP1 and make sure it is started
ok = rpc:call(Cp1, application, permit, [app1, true]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Permit it again
ok = rpc:call(Cp1, application, permit, [app1, true]),
test_server:sleep(1000),
true = is_started(app1, Cp1),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Permit app2 on CP1 and make sure it is started
ok = rpc:call(Cp1, application, permit, [app2, true]),
?UNTIL(is_started(app2, Cp1)),
false = is_started(app2, Cp2),
false = is_started(app2, Cp3),
% Permit app1 on CP2 and make sure it is started
ok = rpc:call(Cp2, application, permit, [app1, true]),
?UNTIL(is_started(app1, Cp2)),
true = is_started(app1, Cp1),
false = is_started(app1, Cp3),
% Unpermit app1 on CP1 and make sure it is stopped
ok = rpc:call(Cp1, application, permit, [app1, false]),
?UNTIL(false =:= is_started(app1, Cp1)),
true = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Unpermit it agin
ok = rpc:call(Cp1, application, permit, [app1, false]),
test_server:sleep(1000),
false = is_started(app1, Cp1),
true = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Permit app1 on CP1 and make sure it is started
ok = rpc:call(Cp1, application, permit, [app1, true]),
?UNTIL(is_started(app1, Cp1)),
true = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Unpermit app1 on CP1 and make sure it is stopped
ok = rpc:call(Cp1, application, permit, [app1, false]),
?UNTIL(false =:= is_started(app1, Cp1)),
true = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Unpermit app1 on CP2 and make sure it is stopped
ok = rpc:call(Cp2, application, permit, [app1, false]),
test_server:sleep(1000),
?UNTIL(false =:= is_started(app1, Cp2)),
false = is_started(app1, Cp1),
false = is_started(app1, Cp3),
% Unpermit app2 on CP1 and make sure it is stopped
ok = rpc:call(Cp1, application, permit, [app2, false]),
?UNTIL(false =:= is_started(app2, Cp2)),
false = is_started(app2, Cp1),
false = is_started(app2, Cp3),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok.
permit_false_start_dist(doc) ->
["Start distributed applications with permission false. Set",
"permit true on different nodes."];
permit_false_start_dist(suite) -> [];
permit_false_start_dist(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config_perm2(NodeNames)),
WithSyncTime = config_fun(config_perm2(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, NoSyncTime, Conf),
{ok, Cp3} = start_node_config(Ncp3, WithSyncTime, Conf),
Cps = [Cp1, Cp2, Cp3],
wait_for_ready_net(),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app1, permanent]),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app2()]),
test_server:sleep(1000),
false = is_started(app1, Cp1),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
%Permit a not started application
ok = rpc:call(Cp1, application, permit, [app2, true]),
test_server:sleep(1000),
false = is_started(app2, Cp1),
false = is_started(app2, Cp2),
false = is_started(app2, Cp3),
%Permit a not loaded application
{error,{not_loaded,app3}} =
rpc:call(Cp1, application, permit, [app3, true]),
test_server:sleep(1000),
false = is_started(app3, Cp1),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
%Unpermit a not started application
ok = rpc:call(Cp1, application, permit, [app2, false]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3], application, start, [app2, permanent]),
test_server:sleep(1000),
false = is_started(app2, Cp1),
false = is_started(app2, Cp2),
false = is_started(app2, Cp3),
%Unpermit a not loaded application
{error,{not_loaded,app3}} =
rpc:call(Cp1, application, permit, [app3, false]),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, load, [app3()]),
?UNTIL(is_loaded(app3, Cps)),
{[ok,ok,ok],[]} =
rpc:multicall(Cps, application, start, [app3, permanent]),
test_server:sleep(1000),
false = is_started(app3, Cp1),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
% Permit app1 on CP1 and make sure it is started
ok = rpc:call(Cp1, application, permit, [app1, true]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Permit it again
ok = rpc:call(Cp1, application, permit, [app1, true]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Permit app2 on CP1 and make sure it is started
ok = rpc:call(Cp1, application, permit, [app2, true]),
?UNTIL(is_started(app2, Cp1)),
false = is_started(app2, Cp2),
false = is_started(app2, Cp3),
% Permit app1 on CP2 and make sure it is not started
ok = rpc:call(Cp2, application, permit, [app1, true]),
test_server:sleep(1000),
true = is_started(app1, Cp1),
false = is_started(app1, Cp2),
false = is_started(app1, Cp3),
% Crash CP1 and make sure app1, but not app2, is started on CP2
stop_node_nice(Cp1),
?UNTIL(is_started(app1, Cp2)),
false = is_started(app2, Cp2),
% Restart CP1 again, check nothing is running on it
{ok, Cp1_2} = start_node_config(Ncp1, NoSyncTime, Conf),
global:sync(),
ok = rpc:call(Cp1_2, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cp1_2)),
ok = rpc:call(Cp1_2, application, start, [app1, permanent]),
ok = rpc:call(Cp1_2, application, load, [app2()]),
?UNTIL(is_loaded(app2, Cp1_2)),
ok = rpc:call(Cp1_2, application, start, [app2, permanent]),
ok = rpc:call(Cp1_2, application, load, [app3()]),
?UNTIL(is_loaded(app3, Cp1_2)),
ok = rpc:call(Cp1_2, application, start, [app3, permanent]),
false = is_started(app1, Cp1_2),
false = is_started(app2, Cp1_2),
% Permit app3 on CP3 and make sure it is started
ok = rpc:call(Cp3, application, permit, [app3, true]),
?UNTIL(is_started(app3, Cp3)),
false = is_started(app3, Cp1_2),
false = is_started(app3, Cp2),
% Permit app3 on CP1 and make sure it is moved there from CP3
ok = rpc:call(Cp1_2, application, permit, [app3, true]),
?UNTIL(is_started(app3, Cp1_2)),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
% Unpermit app3 on CP3 and CP1 and make sure it is stopped
ok = rpc:call(Cp3, application, permit, [app3, false]),
ok = rpc:call(Cp1_2, application, permit, [app3, false]),
?UNTIL(false =:= is_started(app3, Cp1_2)),
false = is_started(app3, Cp2),
false = is_started(app3, Cp3),
stop_node_nice(Cp1_2),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok.
nodedown_start(doc) ->
["app1 distributed as [cp1, cp2]. Call application:start(app1) on",
"cp2, but not on cp1. Kill cp1. Make sure app1 is started on cp2."];
nodedown_start(suite) -> [];
nodedown_start(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
NoSyncTime = config_fun_fast(config4(NodeNames)),
WithSyncTime = config_fun(config4(NodeNames)),
% Test [cp1, cp2]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, WithSyncTime, Conf),
wait_for_ready_net(),
% Start app1 and make sure cp1 starts it
{[ok,ok],[]} =
rpc:multicall([Cp1, Cp2], application, load, [app1()]),
_ = rpc:cast(Cp2, application, start, [app1, permanent]),
test_server:sleep(1000),
% Crash CP1 and make sure app1 is started on CP2
stop_node_nice(Cp1),
?UNTIL(is_started(app1, Cp2)),
stop_node_nice(Cp2),
ok.
ensure_started(suite) -> [];
ensure_started(doc) -> ["Test application:ensure_started/1."];
ensure_started(Conf) ->
{ok, Fd} = file:open("app1.app", [write]),
w_app1(Fd),
file:close(Fd),
ok = application:ensure_started(app1),
ok = application:ensure_started(app1),
{error, {already_started, app1}} = application:start(app1),
ok = application:stop(app1),
{error,{"no such file or directory", _ }} = application:ensure_started(hopefully_not_an_existing_app_file),
ok = application:ensure_started(app1, permanent),
ok = application:ensure_started(app1, permanent),
ok = application:stop(app1),
ok = application:unload(app1),
ok.
%%%-----------------------------------------------------------------
%%% Testing of reported bugs and other tickets.
%%%-----------------------------------------------------------------
%%-----------------------------------------------------------------
%% Ticket: OTP-1586
%% Slogan: recursive load of applications fails
%%-----------------------------------------------------------------
otp_1586(suite) -> [];
otp_1586(doc) ->
["Test recursive load of applications."];
otp_1586(Conf) when is_list(Conf) ->
Dir = ?config(priv_dir,Conf),
{ok, Fd} = file:open(filename:join(Dir, "app5.app"), [write]),
w_app5(Fd),
file:close(Fd),
code:add_patha(Dir),
ok = application:load(app4()),
ok = application:unload(app4),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-2078
%% Slogan: start of distrib apps fails when the nodes start
%% simultaneously
%%-----------------------------------------------------------------
otp_2078(suite) -> [];
otp_2078(doc) ->
["Test start of distrib apps fails when the nodes start simultaneously."];
otp_2078(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
NoSyncTime = config_fun_fast(config4(NodeNames)),
WithSyncTime = config_fun(config4(NodeNames)),
% Test [cp1, cp2]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, WithSyncTime, Conf),
Cps = [Cp1, Cp2],
wait_for_ready_net(),
% Start app1 and make sure cp1 starts it
{[ok,ok],[]} =
rpc:multicall(Cps, application, load, [app1()]),
?UNTIL(is_loaded(app1, Cps)),
ok = rpc:call(Cp1, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
% Start app1 on cp2; make sure it works (the bug was that this start
% returned error)
ok = rpc:call(Cp2, application, start, [app1, permanent]),
true = is_started(app1, Cp1),
false = is_started(app1, Cp2),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
ok.
otp_2012(suite) -> [];
otp_2012(doc) ->
["Test change of configuration parameters without changing code."];
otp_2012(Conf) when is_list(Conf) ->
%% start a help process to check the config change
CcPid = spawn_link(?MODULE, conf_change, []),
yes = global:register_name(conf_change, CcPid),
% Write a .app file
{ok, Fd} = file:open("app1.app", [write]),
w_app1(Fd),
file:close(Fd),
{ok, Fd2} = file:open("app2.app", [write]),
w_app1(Fd2),
file:close(Fd2),
% Start app1
ok = application:load(app1()),
ok = application:start(app1, permanent),
%% Read the current configuration parameters, and change them
EnvBefore = application_controller:prep_config_change(),
application_controller:test_change_apps([app1],[[{app1,[{new1, hi},
{new2, moi}]}]]),
ok = application_controller:config_change(EnvBefore),
ok = get_conf_change([{[], [{new1, hi}, {new2, moi}], []}]),
% Start app2
ok = application:load(app2()),
ok = application:start(app2, permanent),
%% Read the current configuration parameters, and change them again
EnvBefore2 = application_controller:prep_config_change(),
application_controller:test_change_apps([app1],[[{app1,[{new1, hello},
{new3, mors}]}]]),
application_controller:test_change_apps([app2],[[{app2,[{new1, si},
{new2, no}]}]]),
_EnvBefore22 = application_controller:prep_config_change(),
ok = application_controller:config_change(EnvBefore2),
ok = get_conf_change([{[],[{new1,si},{new2,no}],[]},
{[{new1,hello}],[{new3,mors}],[new2]}]),
ok = application:stop(app1),
ok = application:stop(app2),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-2718
%% Slogan: transient app which fails during start is ignored
%%-----------------------------------------------------------------
otp_2718(suite) -> [];
otp_2718(doc) ->
["Test fail of transient app at start."];
otp_2718(Conf) when is_list(Conf) ->
{ok, Cp1} = start_node_args(cp1, "-pa " ++ ?config(data_dir,Conf)),
wait_for_ready_net(),
%% normal exit from the application
ok = rpc:call(Cp1, application, load, [app_trans_normal()]),
?UNTIL(is_loaded(trans_normal, Cp1)),
{error, {{'EXIT',normal},_}} =
rpc:call(Cp1, application, start, [trans_normal, transient]),
test_server:sleep(2000),
false = is_started(trans_normal, Cp1),
%% abnormal exit from the application
ok = rpc:call(Cp1, application, load, [app_trans_abnormal()]),
{error, {bad_return,{{trans_abnormal_sup,start,[normal,[]]},
{'EXIT',abnormal}}}} =
rpc:call(Cp1, application, start, [trans_abnormal, transient]),
test_server:sleep(3000),
{badrpc,nodedown} = which_applications(Cp1),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-2973
%% Slogan: application:start does not test if an appl is already starting...
%%-----------------------------------------------------------------
otp_2973(suite) -> [];
otp_2973(doc) ->
["Test of two processes simultanously starting the same application."];
otp_2973(Conf) when is_list(Conf) ->
% Write a .app file
{ok, Fd} = file:open("app0.app", [write]),
w_app(Fd, app0()),
file:close(Fd),
Pid1 = spawn_link(?MODULE, init2973, []),
Pid2 = spawn_link(?MODULE, init2973, []),
Pid1 ! {start, self(), app0},
Pid2 ! {start, self(), app0},
{Res1, Res2} = receive
{Pid1, res, Res1x} ->
receive
{Pid2, res, Res2x} ->
{Res1x, Res2x}
after 2000 ->
test_server:fail(timeout_pid2)
end;
{Pid2, res, Res2x} ->
receive
{Pid1, res, Res1x} ->
{Res1x, Res2x}
after 2000 ->
test_server:fail(timeout_pid1)
end
end,
%% Stop it. Inteferes with other global.
ok = application:stop(app0),
%% Test result.
case {Res1, Res2} of
{ok, ok} ->
ok;
_ ->
Txt = io_lib:format("Illegal results from start: ~p ~p ",
[Res1, Res2]),
test_server:fail(lists:flatten(Txt))
end,
% Write a .app file
{ok, Fda} = file:open("app_start_error.app", [write]),
w_app_start_error(Fda),
file:close(Fda),
Pid1 ! {start, self(), app_start_error},
Pid2 ! {start, self(), app_start_error},
{Res1a, Res2a} = receive
{Pid1, res, Res1y} ->
receive
{Pid2, res, Res2y} ->
{Res1y, Res2y}
after 2000 ->
test_server:fail(timeout_pid2)
end;
{Pid2, res, Res2y} ->
receive
{Pid1, res, Res1y} ->
{Res1y, Res2y}
after 2000 ->
test_server:fail(timeout_pid1)
end
end,
case {Res1a, Res2a} of
{{error,{'start error',{app_start_error,start,[normal,[]]}}},
{error,{'start error',{app_start_error,start,[normal,[]]}}}} ->
ok;
_ ->
Txta = io_lib:format("Illegal results from start ~p ~p ",[Res1a, Res2a]),
test_server:fail(lists:flatten(Txta))
end,
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-3184
%% Slogan: crash the node if permanent appl has illegal env parameter values
%%-----------------------------------------------------------------
otp_3184(suite) -> [];
otp_3184(doc) ->
["When a distributed application is started the permit flag is checked "
"that the permit flag is not changed during the start. "
"Te check must only be made if the application is started on the own node"];
otp_3184(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
NoSyncTime = config_fun_fast(config3184(NodeNames)),
WithSyncTime = config_fun(config3184(NodeNames)),
% Test [cp1, cp2]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, WithSyncTime, Conf),
wait_for_ready_net(),
% Start app1 and make sure it is not started
{[ok,ok],[]} =
rpc:multicall([Cp1, Cp2], application, load, [app1()]),
test_server:sleep(3000),
false = is_started(app1, Cp1),
false = is_started(app1, Cp2),
% Start app1 on cp1
ok = rpc:call(Cp1, application, permit, [app1, true]),
ok = rpc:call(Cp1, application, start, [app1, permanent]),
ok = rpc:call(Cp2, application, start, [app1, permanent]),
?UNTIL(is_started(app1, Cp1)),
false = is_started(app1, Cp2),
% Check that the application is marked as running in application_controller
X = rpc:call(Cp1, application_controller, info, []),
{value, {running, Xrunning}} = lists:keysearch(running, 1, X),
{value, Xapp1} = lists:keysearch(app1, 1, Xrunning),
{app1, _Xpid} = Xapp1,
Y = rpc:call(Cp2, application_controller, info, []),
{value, {running, Yrunning}} = lists:keysearch(running, 1, Y),
{value, Yapp1} = lists:keysearch(app1, 1, Yrunning),
{app1, {distributed, Cp1}} = Yapp1,
stop_node_nice(Cp1),
stop_node_nice(Cp2),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-3002
%% Slogan: crash the node if permanent appl has illegal env parameter values
%%-----------------------------------------------------------------
otp_3002(suite) -> [];
otp_3002(doc) ->
["crash the node if permanent appl has illegal env parameter values."];
otp_3002(Conf) when is_list(Conf) ->
% Create the boot script
{{KernelVer,StdlibVer}, {LatestDir, LatestName}} =
create_script_3002("script_3002"),
?t:format(0, "LatestDir = ~p~n", [LatestDir]),
?t:format(0, "LatestName = ~p~n", [LatestName]),
case is_real_system(KernelVer, StdlibVer) of
true ->
Options = [];
false ->
Options = [local]
end,
ok = systools:make_script("script_3002", Options),
ok = systools:script2boot("script_3002"),
{error, timeout} = start_node_boot_3002(cp1, "script_3002"),
ok = file:delete("script_3002.boot"),
ok = file:delete("script_3002.rel"),
ok = file:delete("script_3002.script"),
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-4066
%% Slogan: dist_ac crashed if a distributed application that it
%% didn't know of was stopped by another dist_ac (bad_match
%% when it received dist_ac_app_stopped).
%%-----------------------------------------------------------------
otp_4066(suite) -> [];
otp_4066(doc) -> ["Check that application stop don't cause dist_ac crash"];
otp_4066(Conf) when is_list(Conf) ->
% Write config files
[Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
Host = from($@, atom_to_list(node())),
Cp1 = list_to_atom(Ncp1 ++ "@" ++ Host),
Cp2 = list_to_atom(Ncp2 ++ "@" ++ Host),
AllNodes = [Cp1, Cp2],
App1Nodes = {app1, AllNodes},
Dir = ?config(priv_dir,Conf),
{ok, FdC} = file:open(filename:join(Dir, "otp_4066.config"), [write]),
write_config(FdC, config_4066(AllNodes, 5000, [App1Nodes])),
file:close(FdC),
% Write the app1.app file
{ok, FdA12} = file:open(filename:join(Dir, "app1.app"), [write]),
w_app1(FdA12),
file:close(FdA12),
Args1 = "-pa " ++ Dir ++ " -config " ++ filename:join(Dir, "otp_4066"),
Args2 = "-pa " ++ Dir ++ " -kernel start_dist_ac true",
{ok, Cp2} = start_node_args(Ncp2, Args2),
%% Cp1 syncs with cp2 (which is known to be up).
{ok, Cp1} = start_node_args(Ncp1, Args1),
wait_for_ready_net(),
ok = rpc:call(Cp1, application, start, [app1]),
wait_until_started(app1, [Cp1]),
test_server:format("--- App1 started at Cp1 ---~n", []),
print_dac_state(AllNodes),
% Cp2 previously crashed on this stop
ok = rpc:call(Cp1, application, stop, [app1]),
wait_until_stopped(app1, [Cp1]),
test_server:format("--- App1 stopped at Cp1 ---~n", []),
print_dac_state(AllNodes),
ok = rpc:call(Cp1, application, start, [app1]),
wait_until_started(app1, [Cp1]),
test_server:format("--- App1 started at Cp1 ---~n", []),
print_dac_state(AllNodes),
ok = rpc:call(Cp2, application, load, [app1, App1Nodes]),
ok = rpc:call(Cp2, application, start, [app1]),
test_server:format("--- App1 started at Cp2 ---~n", []),
print_dac_state(AllNodes),
stop_node_nice(Cp1),
wait_until_started(app1, [Cp2]),
test_server:format("--- Cp1 crashed; failover to Cp2 ---~n", []),
print_dac_state(Cp2),
stop_node_nice(Cp2),
ok.
config_4066(SyncNodesOptional, SyncNodesTimeout, Distributed) ->
[{kernel, [{sync_nodes_optional,SyncNodesOptional},
{sync_nodes_timeout, SyncNodesTimeout},
{distributed, Distributed}]}].
write_config(Fd, Config) ->
io:format(Fd, "~p.~n", [Config]).
print_dac_state(Node) when is_atom(Node) ->
State = gen_server:call({dist_ac, Node}, info),
test_server:format(" * dist_ac state on node ~p:~n ~p~n",
[Node, State]);
print_dac_state(Nodes) when is_list(Nodes) ->
lists:foreach(fun (N) -> print_dac_state(N) end, Nodes).
%%-----------------------------------------------------------------
%% Ticket: OTP-4227
%% Slogan: Bad return value from application.
%%-----------------------------------------------------------------
otp_4227(suite) -> [];
otp_4227(doc) ->
["Test start of depending app when required app crashed."];
otp_4227(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
NoSyncTime = config_fun_fast(config_4227(NodeNames)),
WithSyncTime = config_fun(config_4227(NodeNames)),
%% Test [cp1, cp2]
{ok, Cp1} = start_node_config(Ncp1, NoSyncTime, Conf),
{ok, Cp2} = start_node_config(Ncp2, WithSyncTime, Conf),
Cps = [Cp1, Cp2],
wait_for_ready_net(),
%% Try to start app10 which should fail since app9 is not started
{[ok,ok],[]} =
rpc:multicall(Cps, application, load, [app9()]),
?UNTIL(is_loaded(app9, Cps)),
{[ok,ok],[]} =
rpc:multicall(Cps, application, load, [app10_dep9()]),
{error, {not_started, app9}} =
rpc:call(Cp1, application, start, [app10]),
%% Start app9 and brutally kill it, then try to start app10
ok = rpc:call(Cp1, application, start, [app9]),
test_server:sleep(1000),
Pid9 = rpc:call(Cp1, erlang, whereis, [ch_sup19]),
true = erlang:is_pid(Pid9),
true = erlang:exit(Pid9, kill),
test_server:sleep(1000),
%% This gave {error, no_report} before the patch
{error, {not_running, app9}} =
rpc:call(Cp1, application, start, [app10]),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
ok.
config_4227([Ncp1, Ncp2]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd,
"[{kernel, "
" [{sync_nodes_optional, ['~s@~s','~s@~s']},"
" {sync_nodes_timeout, ~w},"
" {start_dist_ac, true},"
" {distributed, "
" [{app9, ['~s@~s','~s@~s']}, "
" {app10, ['~s@~s','~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M,
Ncp1, M, Ncp2, M])
end.
%%-----------------------------------------------------------------
%% Ticket: OTP-5363
%% Slogan: Slow termination in application_master
%%-----------------------------------------------------------------
otp_5363(Conf) when is_list(Conf) ->
%% When stopping an application, all processes having the
%% application master as group leader should get killed.
%% The killing was done in an inefficient way.
%% In this test case, we will not test the efficiency of
%% the code, but only that the correct processes ARE killed.
OldPath = code:get_path(),
code:add_patha(?config(data_dir,Conf)),
try
ok = application:load(app_group_leader()),
ok = application:start(group_leader),
case whereis(nisse) of
Pid when is_pid(Pid) ->
Mref = erlang:monitor(process, Pid),
ok = application:stop(group_leader),
receive
{'DOWN',Mref,_,_,_} -> ok
end,
undefined = whereis(nisse);
Bad ->
io:format("~p\n", [Bad]),
?t:fail()
end
after
code:set_path(OldPath)
end,
ok.
%%-----------------------------------------------------------------
%% Ticket: OTP-5606
%% Slogan: Problems with starting a distributed application
%%-----------------------------------------------------------------
otp_5606(suite) -> [];
otp_5606(doc) ->
["Test of several processes simultanously starting the same "
"distributed application."];
otp_5606(Conf) when is_list(Conf) ->
%% Write a config file
Dir = ?config(priv_dir, Conf),
{ok, Fd} = file:open(filename:join(Dir, "sys.config"), [write]),
NodeNames = [Ncp1, Ncp2] = node_names([cp1, cp2], Conf),
(config4(NodeNames))(Fd, 10000),
file:close(Fd),
Config = filename:join(Dir, "sys"),
%% Test [cp1, cp2]
{ok, Cp1} = start_node(Ncp1, Config),
{ok, Cp2} = start_node(Ncp2, Config),
Cps = [Cp1, Cp2],
wait_for_ready_net(),
%% Load app1 on both nodes
{[ok, ok], []} =
rpc:multicall(Cps, application, load, [app1()]),
%% Attempt to start app1 from different processes simultaneously
Pid11 = spawn_link(Cp1, ?MODULE, loop5606, [self()]),
Pid12 = spawn_link(Cp1, ?MODULE, loop5606, [self()]),
Pid13 = spawn_link(Cp1, ?MODULE, loop5606, [self()]),
Pid2 = spawn_link(Cp2, ?MODULE, loop5606, [self()]),
Pid2 ! start,
Pid11 ! start,
Pid12 ! start,
Pid13 ! start,
ResL = otp_5606_loop([]),
case ResL of
[ok, ok, ok, ok] ->
ok;
[Res1, Res2, Res3, Res4] ->
Txt = io_lib:format("Illegal results from start ~p ~p ~p ~p",
[Res1, Res2, Res3, Res4]),
test_server:fail(lists:flatten(Txt))
end,
{error, {already_started, app1}} =
rpc:call(Cp1, application, start, [app1]),
stop_node_nice(Cp1),
stop_node_nice(Cp2),
ok.
otp_5606_loop(ResL) when length(ResL)<4 ->
receive
{_Pid, Res} ->
otp_5606_loop([Res|ResL])
after 5000 ->
test_server:fail(timeout_waiting_for_res)
end;
otp_5606_loop(ResL) ->
ResL.
loop5606(Pid) ->
receive
start ->
Res = application:start(app1),
Pid ! {self(), Res}
end.
get_env(suite) -> [];
get_env(doc) ->
["Tests get_env/* functions"];
get_env(Conf) when is_list(Conf) ->
{ok, _} = application:get_env(kernel, error_logger),
undefined = application:get_env(undefined_app, a),
undefined = application:get_env(kernel, error_logger_xyz),
default = application:get_env(kernel, error_logger_xyz, default),
ok.
%%-----------------------------------------------------------------
%% Should be started in a CC view with:
%% erl -sname XXX -rsh ctrsh where XX not in [cp1, cp2, cp3]
%%-----------------------------------------------------------------
get_key(suite) -> [];
get_key(doc) ->
["Tests read the .app keys."];
get_key(Conf) when is_list(Conf) ->
NodeNames = [Ncp1, _Ncp2, _Ncp3] = node_names([cp1, cp2, cp3], Conf),
WithSyncTime = config_fun(config_inc(NodeNames)),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_config(Ncp1, WithSyncTime, Conf),
ok = rpc:call(Cp1, application, load, [appinc(), d3(NodeNames)]),
?UNTIL(is_loaded(appinc, Cp1)),
ok = rpc:call(Cp1, application, start, [appinc, permanent]),
?UNTIL(is_started(appinc, Cp1)),
{ok, "Test of new app file, including appnew"} =
rpc:call(Cp1, application, get_key, [appinc, description]),
{ok, "CXC 138 ai"} = rpc:call(Cp1, application, get_key, [appinc ,id]),
{ok, "2.0"} = rpc:call(Cp1, application, get_key, [appinc, vsn]),
{ok, [kernel]} = rpc:call(Cp1, application, get_key, [appinc, applications]),
{ok, [appinc1, appinc2]} =
rpc:call(Cp1, application, get_key, [appinc, included_applications]),
{ok, []} = rpc:call(Cp1, application, get_key, [appinc, registered]),
{ok, [{init, [kalle]}, {takeover, []}, {go, [sune]}]} =
rpc:call(Cp1, application, get_key, [appinc, start_phases]),
{ok, Env} = rpc:call(Cp1, application, get_key, [appinc ,env]),
[{included_applications,[appinc1,appinc2]},
{own2,val2},{own_env1,value1}] = lists:sort(Env),
{ok, []} = rpc:call(Cp1, application, get_key, [appinc, modules]),
{ok, {application_starter, [ch_sup, {appinc, 41, 43}] }} =
rpc:call(Cp1, application, get_key, [appinc, mod]),
{ok, infinity} = rpc:call(Cp1, application, get_key, [appinc, maxP]),
{ok, infinity} = rpc:call(Cp1, application, get_key, [appinc, maxT]),
undefined = rpc:call(Cp1, application, get_key, [appinc, very_unknown]),
{ok, [{description, "Test of new app file, including appnew"},
{id, "CXC 138 ai"},
{vsn, "2.0"},
{modules, []},
{maxP, infinity},
{maxT, infinity},
{registered, []},
{included_applications, [appinc1, appinc2]},
{applications, [kernel]},
{env, Env},
{mod, {application_starter, [ch_sup, {appinc, 41, 43}] }},
{start_phases, [{init, [kalle]}, {takeover, []}, {go, [sune]}]}]} =
rpc:call(Cp1, application, get_all_key, [appinc]),
[{included_applications,[appinc1,appinc2]},
{own2,val2},{own_env1,value1}] = lists:sort(Env),
{ok, "Test of new app file, including appnew"} =
gen_server:call({global, {ch,41}}, {get_pid_key, description}),
{ok, "CXC 138 ai"} =
gen_server:call({global, {ch,41}}, {get_pid_key, id}),
{ok, "2.0"} =
gen_server:call({global, {ch,41}}, {get_pid_key, vsn}),
{ok, [kernel]} =
gen_server:call({global, {ch,41}}, {get_pid_key, applications}),
{ok, [appinc1, appinc2]} =
gen_server:call({global, {ch,41}}, {get_pid_key, included_applications}),
{ok, []} =
gen_server:call({global, {ch,41}}, {get_pid_key, registered}),
{ok, [{init, [kalle]}, {takeover, []}, {go, [sune]}]} =
gen_server:call({global, {ch,41}}, {get_pid_key, start_phases}),
{ok, Env} = gen_server:call({global, {ch,41}}, {get_pid_key, env}),
[{included_applications,[appinc1,appinc2]},
{own2,val2},{own_env1,value1}] = lists:sort(Env),
{ok, []} =
gen_server:call({global, {ch,41}}, {get_pid_key, modules}),
{ok, {application_starter, [ch_sup, {appinc, 41, 43}] }} =
gen_server:call({global, {ch,41}}, {get_pid_key, mod}),
{ok, infinity} =
gen_server:call({global, {ch,41}}, {get_pid_key, maxP}),
{ok, infinity} =
gen_server:call({global, {ch,41}}, {get_pid_key, maxT}),
undefined =
gen_server:call({global, {ch,41}}, {get_pid_key, very_unknown}),
{ok, [{description, "Test of new app file, including appnew"},
{id, "CXC 138 ai"},
{vsn, "2.0"},
{modules, []},
{maxP, infinity},
{maxT, infinity},
{registered, []},
{included_applications, [appinc1, appinc2]},
{applications, [kernel]},
{env, Env},
{mod, {application_starter, [ch_sup, {appinc, 41, 43}] }},
{start_phases, [{init, [kalle]}, {takeover, []}, {go, [sune]}]}]} =
gen_server:call({global, {ch,41}}, get_pid_all_key),
[{included_applications,[appinc1,appinc2]},
{own2,val2},{own_env1,value1}] = lists:sort(Env),
stop_node_nice(Cp1),
ok.
%%%-----------------------------------------------------------------
%%% Testing of change of distributed parameter.
%%%-----------------------------------------------------------------
distr_changed_tc1(suite) -> [];
distr_changed_tc1(doc) -> ["Test change of distributed parameter."];
distr_changed_tc1(Conf) when is_list(Conf) ->
{OldKernel, OldEnv, {Cp1, Cp2, Cp3}, {_Ncp1, _Ncp2, _Ncp3}, _Config2} =
distr_changed_prep(Conf),
NewDist = {distributed, [{app1, [Cp3]},
{app2, 5000, [Cp2]},
{app3, [Cp3, {Cp1, Cp2}]},
{app6, [Cp1, {Cp3, Cp2}]},
{app7, 1000, [Cp3]},
{app8, [Cp1, {Cp2, Cp3}]}]},
NewKernel = [{kernel, lists:keyreplace(distributed, 1, OldKernel, NewDist)}],
ok = rpc:call(Cp1, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
ok = rpc:call(Cp2, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
ok = rpc:call(Cp3, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3],
application_controller, config_change, [OldEnv]),
test_server:sleep(7000),
DcInfo1 = rpc:call(Cp1, dist_ac, info, []),
DcInfo2 = rpc:call(Cp2, dist_ac, info, []),
DcInfo3 = rpc:call(Cp3, dist_ac, info, []),
DcWa1 = which_applications(Cp1),
DcWa2 = which_applications(Cp2),
DcWa3 = which_applications(Cp3),
Wa1 = lists:foldl(fun({A1, _N1, _V1}, AccIn) -> [A1 | AccIn] end,
[], DcWa1),
Wa2 = lists:foldl(fun({A2, _N2, _V2}, AccIn) -> [A2 | AccIn] end,
[], DcWa2),
Wa3 = lists:foldl(fun({A3, _N3, _V3}, AccIn) -> [A3 | AccIn] end,
[], DcWa3),
case lists:sort(Wa1) of
[app1, app2, app3, kernel, stdlib] ->
ok;
EWa1 ->
X1 = io_lib:format("distribution error: Cp1 ~p ",[EWa1]),
test_server:fail(lists:flatten(X1))
end,
case lists:sort(Wa2) of
[app6, app8, kernel, stdlib] ->
ok;
EWa2 ->
X2 = io_lib:format("distribution error: Cp2 ~p ",[EWa2]),
test_server:fail(lists:flatten(X2))
end,
case lists:sort(Wa3) of
[app7, kernel, stdlib] ->
ok;
EWa3 ->
X3 = io_lib:format("distribution error: Cp3 ~p ",[EWa3]),
test_server:fail(lists:flatten(X3))
end,
DcInfo1n = rpc:call(Cp1, dist_ac, info, []),
DcInfo2n = rpc:call(Cp2, dist_ac, info, []),
DcInfo3n = rpc:call(Cp3, dist_ac, info, []),
%% Added afterwards. Got rid of some warnings for unused variables.
true = DcInfo1 =:= DcInfo1n,
true = DcInfo2 =:= DcInfo2n,
true = DcInfo3 =:= DcInfo3n,
stop_node_nice(Cp1),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok = file:delete("dc.boot"),
ok = file:delete("dc.rel"),
ok = file:delete("dc.script"),
ok.
distr_changed_tc2(suite) -> [];
distr_changed_tc2(doc) -> ["Test change of distributed parameter, "
"move appls by crashing a node."];
distr_changed_tc2(Conf) when is_list(Conf) ->
{OldKernel, OldEnv, {Cp1, Cp2, Cp3}, {Ncp1, _Ncp2, _Ncp3}, Config2} =
distr_changed_prep(Conf),
NewDist = {distributed, [{app1, [Cp3]},
{app2, 5000, [Cp2]},
{app3, [Cp3, {Cp1, Cp2}]},
{app6, [Cp1, {Cp3, Cp2}]},
{app7, 1000, [Cp3]},
{app8, [Cp1, {Cp2, Cp3}]}]},
NewKernel = [{kernel, lists:keyreplace(distributed, 1, OldKernel, NewDist)}],
ok = rpc:call(Cp1, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
ok = rpc:call(Cp2, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
ok = rpc:call(Cp3, application_controller, test_change_apps,
[[kernel], [NewKernel]]),
{[ok,ok,ok],[]} =
rpc:multicall([Cp1, Cp2, Cp3],
application_controller, config_change, [OldEnv]),
test_server:sleep(4000),
stop_node_nice(Cp1),
test_server:sleep(10000),
% _DcInfo1 = rpc:call(Cp1, dist_ac, info, []),
_DcInfo2 = rpc:call(Cp2, dist_ac, info, []),
_DcInfo3 = rpc:call(Cp3, dist_ac, info, []),
% ?t:format(0,"#### DcInfo1 ~n~p~n",[_DcInfo1]),
% DcWa1 = which_applications(Cp1),
DcWa2 = which_applications(Cp2),
DcWa3 = which_applications(Cp3),
% Wa1 = lists:foldl(fun({A1, _N1, _V1}, AccIn) -> [A1 | AccIn] end,
% [], DcWa1),
Wa2 = lists:foldl(fun({A2, _N2, _V2}, AccIn) -> [A2 | AccIn] end,
[], DcWa2),
Wa3 = lists:foldl(fun({A3, _N3, _V3}, AccIn) -> [A3 | AccIn] end,
[], DcWa3),
case lists:sort(Wa2) of
[app2, app6, app8, kernel, stdlib] ->
ok;
EWa2 ->
X2 = io_lib:format("distribution error: Cp2 ~p ",[EWa2]),
test_server:fail(lists:flatten(X2))
end,
case lists:sort(Wa3) of
[app1, app3, app7, kernel, stdlib] ->
ok;
EWa3 ->
X3 = io_lib:format("distribution error: Cp3 ~p ",[EWa3]),
test_server:fail(lists:flatten(X3))
end,
{ok, Cp1} = start_node_boot(Ncp1, Config2, dc),
test_server:sleep(10000),
_DcInfo1rs = rpc:call(Cp1, dist_ac, info, []),
_DcInfo2rs = rpc:call(Cp2, dist_ac, info, []),
_DcInfo3rs = rpc:call(Cp3, dist_ac, info, []),
DcWa1rs = which_applications(Cp1),
DcWa2rs = which_applications(Cp2),
DcWa3rs = which_applications(Cp3),
Wa1rs = lists:foldl(fun({A1, _N1, _V1}, AccIn) -> [A1 | AccIn] end,
[], DcWa1rs),
Wa2rs = lists:foldl(fun({A2, _N2, _V2}, AccIn) -> [A2 | AccIn] end,
[], DcWa2rs),
Wa3rs = lists:foldl(fun({A3, _N3, _V3}, AccIn) -> [A3 | AccIn] end,
[], DcWa3rs),
case lists:sort(Wa1rs) of
[app6, app8, kernel, stdlib] ->
ok;
EWa1rs ->
X1rs = io_lib:format("distribution error: Cp1 ~p ",[EWa1rs]),
test_server:fail(lists:flatten(X1rs))
end,
case lists:sort(Wa2rs) of
[app2, kernel, stdlib] ->
ok;
EWa2rs ->
X2rs = io_lib:format("distribution error: Cp2 ~p ",[EWa2rs]),
test_server:fail(lists:flatten(X2rs))
end,
case lists:sort(Wa3rs) of
[app1, app3, app7, kernel, stdlib] ->
ok;
EWa3rs ->
X3rs = io_lib:format("distribution error: Cp3 ~p ",[EWa3rs]),
test_server:fail(lists:flatten(X3rs))
end,
stop_node_nice(Cp1),
stop_node_nice(Cp2),
stop_node_nice(Cp3),
ok = file:delete("dc.boot"),
ok = file:delete("dc.rel"),
ok = file:delete("dc.script"),
ok.
%%%-----------------------------------------------------------------
%%% Testing of application configuration change
%%%-----------------------------------------------------------------
config_change(suite) ->
[];
config_change(doc) ->
["Test change of application configuration"];
config_change(Conf) when is_list(Conf) ->
%% Change to data_dir
{ok, CWD} = file:get_cwd(),
DataDir = ?config(data_dir, Conf),
ok = file:set_cwd(DataDir),
%% Find out application data from boot script
Boot = filename:join([code:root_dir(), "bin", "start.boot"]),
{ok, Bin} = file:read_file(Boot),
Appls = get_appls(binary_to_term(Bin)),
%% Simulate contents of "sys.config"
Config = [{stdlib, [{par1,sys},{par2,sys}]},
"t1",
"t2.config",
filename:join([DataDir, "subdir", "t3"]),
{stdlib, [{par6,sys}]}],
%% Order application_controller to update configuration
ok = application_controller:change_application_data(Appls,
Config),
%% Check that stdlib parameters are correctly set
Env = application:get_all_env(stdlib),
{value, {par1,sys}} = lists:keysearch(par1, 1, Env),
{value, {par2,t1}} = lists:keysearch(par2, 1, Env),
{value, {par3,t1}} = lists:keysearch(par3, 1, Env),
{value, {par4,t2}} = lists:keysearch(par4, 1, Env),
{value, {par5,t3}} = lists:keysearch(par5, 1, Env),
{value, {par6,sys}} = lists:keysearch(par6, 1, Env),
ok = file:set_cwd(CWD).
%% This function is stolen from SASL module release_handler, OTP R10B
get_appls({script, _, Script}) ->
get_appls(Script, []).
%% kernel is taken care of separately
get_appls([{kernelProcess, application_controller,
{application_controller, start, [App]}} | T], Res) ->
get_appls(T, [App | Res]);
%% other applications but kernel
get_appls([{apply, {application, load, [App]}} | T], Res) ->
get_appls(T, [App | Res]);
get_appls([_ | T], Res) ->
get_appls(T, Res);
get_appls([], Res) ->
Res.
%%%-----------------------------------------------------------------
%%% Tests the 'shutdown_func' kernel config parameter
%%%-----------------------------------------------------------------
shutdown_func(suite) ->
[];
shutdown_func(doc) ->
["Tests the 'shutdown_func' kernel config parameter"];
shutdown_func(Config) when is_list(Config) ->
{ok,Cp1} = start_node(?MODULE_STRING++"_shutdown_func"),
wait_for_ready_net(),
Tag = make_ref(),
ok = rpc:call(Cp1, application, set_env,
[kernel, shutdown_func, {?MODULE, do_shutdown}]),
ok = rpc:call(Cp1, application, set_env,
[kernel, shutdown_func_test, {self(), Tag}]),
_ = rpc:call(Cp1, init, stop, []),
receive
{Pid, Tag, shutting_down, shutdown} ->
Mref = erlang:monitor(process, Pid),
Pid ! {self(), Tag, ok},
receive
{'DOWN', Mref, _, Pid, noconnection} ->
ok
after 10000 ->
test_server:fail(timeout)
end
after 10000 ->
test_server:fail(timeout)
end.
do_shutdown(Reason) ->
{ok, {Pid, Tag}} = application:get_env(kernel, shutdown_func_test),
Pid ! {self(), Tag, shutting_down, Reason},
receive
{Pid, Tag, ok} -> ok
end.
%%%-----------------------------------------------------------------
%%% Tests the 'shutdown_timeout' kernel config parameter
%%%-----------------------------------------------------------------
shutdown_timeout(Config) when is_list(Config) ->
DataDir = ?config(data_dir,Config),
{ok,Cp1} = start_node(?MODULE_STRING++"_shutdown_timeout"),
wait_for_ready_net(),
ok = rpc:call(Cp1, application, set_env, [kernel, shutdown_timeout, 1000]),
rpc:call(Cp1, code, add_path, [filename:join([DataDir,deadlock])]),
ok = rpc:call(Cp1, application, start, [sasl]),
ok = rpc:call(Cp1, application, start, [deadlock]),
rpc:call(Cp1, deadlock, restart_and_fail, []),
ok = net_kernel:monitor_nodes(true),
_ = rpc:call(Cp1, init, stop, []),
receive
{nodedown,Cp1} ->
ok
after 10000 ->
ct:fail("timeout 10 sec: node termination hangs")
end,
ok.
%%-----------------------------------------------------------------
%% Utility functions
%%-----------------------------------------------------------------
app0() ->
{application, app0,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app0, 77, 80}}}]}.
app1() ->
{application, app1,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app1, 1, 3}}}]}.
app2() ->
{application, app2,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app2, 4, 6}}}]}.
app3() ->
{application, app3,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app3, 7, 9}}}]}.
app4() ->
{application, app4,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{applications, [kernel]},
{included_applications, [app5]},
{mod, {ch_sup, {app3, 7, 9}}}]}.
app5() ->
{application, app5,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{applications, [kernel]},
{mod, {ch_sup, {app3, 7, 9}}}]}.
app6() ->
{application, app6,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app6, 10, 12}}}]}.
app7() ->
{application, app7,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app7, 13, 15}}}]}.
app8() ->
{application, app8,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app7, 16, 18}}}]}.
app9() ->
{application, app9,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {ch_sup, {app9, 19, 19}}}]}.
app10_dep9() ->
{application, app10,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel, app9]},
{mod, {ch_sup, {app10, 20, 20}}}]}.
appinc() ->
{application, appinc,
[{description, "Test of new app file, including appnew"},
{id, "CXC 138 ai"},
{vsn, "2.0"},
{applications, [kernel]},
{modules, []},
{registered, []},
{env, [{own_env1, value1}, {own2, val2}]},
{included_applications, [appinc1, appinc2]},
{start_phases, [{init, [kalle]}, {takeover, []}, {go, [sune]}]},
{mod, {application_starter, [ch_sup, {appinc, 41, 43}] }}]}.
app_sp() ->
{application, app_sp,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{start_phases, [{init, [kurt]}, {go, [sune]}]},
{applications, [kernel]},
{modules, []},
{registered, []},
{mod, {application_starter, [ch_sup, {app_sp, 31, 33}] }}]}.
app_no() ->
{application, app_no,
[{description, "Test of active/standby pairs on non overlapping nodes"},
{vsn, "1.0"},
{applications, [kernel]},
{modules, []},
{registered, []},
{mod, {ch_sup, {app_no, 34, 36}}}]}.
app_trans_normal() ->
{application, trans_normal,
[{description, "A CXC 138 11"},
{vsn, "1.0"},
{modules, [{transient, 1}, {trans_normal_sup,1}]},
{registered, [trans_normal_sup]},
{applications, [kernel, stdlib]},
{mod, {trans_normal_sup, []}}]}.
app_trans_abnormal() ->
{application, trans_abnormal,
[{description, "A CXC 138 11"},
{vsn, "1.0"},
{modules, [{transient, 1}, {trans_abnormal_sup,1}]},
{registered, [trans_abnormal_sup]},
{applications, [kernel, stdlib]},
{mod, {trans_abnormal_sup, []}}]}.
app_start_error() ->
{application, app_start_error,
[{description, "ERTS CXC 138 10"},
{vsn, "2.0"},
{modules, []},
{registered, []},
{applications, [kernel]},
{mod, {app_start_error, []}}]}.
app_group_leader() ->
{application, group_leader,
[{description, "GROUP_LEADER CXC 138 11"},
{vsn, "1.0"},
{modules, [group_leader,group_leader_sup]},
{registered, [group_leader_sup]},
{applications, [kernel,stdlib]},
{mod, {group_leader_sup, []}}]}.
d1([Ncp1, Ncp2, Ncp3]) ->
M = from($@, atom_to_list(node())),
{app1, [list_to_atom(Ncp1 ++ "@" ++ M),
list_to_atom(Ncp2 ++ "@" ++ M),
list_to_atom(Ncp3 ++ "@" ++ M)]}.
d2([Ncp1, _Ncp2, Ncp3]) ->
M = from($@, atom_to_list(node())),
{app1, [list_to_atom(Ncp1 ++ "@" ++ M),
list_to_atom(Ncp3 ++ "@" ++ M)]}.
d3([Ncp1, Ncp2, Ncp3]) ->
M = from($@, atom_to_list(node())),
{appinc, [list_to_atom(Ncp1 ++ "@" ++ M),
list_to_atom(Ncp2 ++ "@" ++ M),
list_to_atom(Ncp3 ++ "@" ++ M)]}.
d_any3(Any, [Ncp1, Ncp2, Ncp3]) ->
M = from($@, atom_to_list(node())),
{Any, [list_to_atom(Ncp1 ++ "@" ++ M),
list_to_atom(Ncp2 ++ "@" ++ M),
list_to_atom(Ncp3 ++ "@" ++ M)]}.
config([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 1000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app3, 1000, [{'~s@~s', '~s@~s'}, '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout, Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
config2([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{permissions, [{app3, false}]},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 10000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app3, 5000, [{'~s@~s', '~s@~s'}, '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
config3([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{start_dist_ac, true},"
"{permissions, [{app3, false}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout])
end.
config4([Ncp1, Ncp2]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{start_dist_ac, true},"
"{distributed, [{app1, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, SyncNodesTimeout,
Ncp1, M, Ncp2, M])
end.
config3184([Ncp1, Ncp2]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{permissions, [{app1, false}]},"
"{distributed, [{app1, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, SyncNodesTimeout,
Ncp1, M, Ncp2, M])
end.
config_perm(Fd) ->
io:format(Fd, "[{kernel, [{permissions, "
"[{app1, false}, {app2, false}, {app3, false}]} ]}].~n",[]).
config_perm2([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{permissions, [{app1, false}, {app2, false}, {app3, false}]},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 10000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app3, 5000, [{'~s@~s', '~s@~s'}, '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
config_inc([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{appinc, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 10000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app3, 5000, [{'~s@~s', '~s@~s'}, '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
config_sf([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{myApp, ['~s@~s', '~s@~s', '~s@~s']},"
"{topApp, ['~s@~s', '~s@~s', '~s@~s']},"
"{inclOne, ['~s@~s', '~s@~s', '~s@~s']},"
"{inclTwo, ['~s@~s', '~s@~s', '~s@~s']},"
"{inclTwoTop, ['~s@~s', '~s@~s', '~s@~s']},"
"{incl2A, ['~s@~s', '~s@~s', '~s@~s']},"
"{incl2B, ['~s@~s', '~s@~s', '~s@~s']},"
"{with, ['~s@~s', '~s@~s', '~s@~s']},"
"{wrapper, ['~s@~s', '~s@~s', '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
config_fo1([Ncp1, Ncp2, Ncp3, _Ncp4]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 2000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app_sp, 1000, [{'~s@~s', '~s@~s'}, '~s@~s']},"
"{app_no, 1000, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M])
end.
config_fo2([Ncp1, Ncp2, Ncp3, _Ncp4]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 2000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app_sp, 1000, [{'~s@~s', '~s@~s'}, '~s@~s']},"
"{app_no, 1000, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M])
end.
config_fo3([Ncp1, Ncp2, Ncp3, Ncp4]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{app1, ['~s@~s', '~s@~s', '~s@~s']},"
"{app2, 2000, ['~s@~s', '~s@~s', '~s@~s']},"
"{app_sp, 1000, [{'~s@~s', '~s@~s'}, '~s@~s']},"
"{app_no, 1000, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp4, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M,
Ncp3, M, Ncp4, M])
end.
config_fo4([_Ncp1, _Ncp2, Ncp3, Ncp4]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed,"
" [{app_no, 1000, ['~s@~s', '~s@~s']}]}]}].~n",
[Ncp3, M,
SyncNodesTimeout,
Ncp3, M, Ncp4, M])
end.
config_dc([Ncp1, Ncp2, Ncp3]) ->
fun(Fd, SyncNodesTimeout) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, ~w},"
"{distributed, [{app1, ['~s@~s', '~s@~s']},"
" {app2, 10000, ['~s@~s']},"
" {app3, [{'~s@~s', '~s@~s'}]}, "
" {app6, [{'~s@~s', '~s@~s'}]}, "
" {app7, ['~s@~s']}, "
" {app8, ['~s@~s', {'~s@~s', '~s@~s'}]}"
" ]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
SyncNodesTimeout,
Ncp1, M, Ncp2, M,
Ncp1, M,
Ncp1, M, Ncp2, M,
Ncp3, M, Ncp2, M,
Ncp3, M,
Ncp2, M, Ncp1, M, Ncp3, M])
end.
config_dc2([Ncp1, Ncp2, Ncp3]) ->
fun(Fd) ->
M = from($@, atom_to_list(node())),
io:format(Fd, "[{kernel, [{sync_nodes_optional, "
"['~s@~s','~s@~s','~s@~s']},"
"{sync_nodes_timeout, 10000},"
"{distributed, [{app1, ['~s@~s']},"
" {app2, 5000, ['~s@~s']},"
" {app3, ['~s@~s', {'~s@~s', '~s@~s'}]}, "
" {app6, ['~s@~s', {'~s@~s', '~s@~s'}]}, "
" {app7, 1000, ['~s@~s']}, "
" {app8, ['~s@~s', {'~s@~s', '~s@~s'}]}"
" ]}]}].~n",
[Ncp1, M, Ncp2, M, Ncp3, M,
Ncp3, M,
Ncp2, M,
Ncp3, M, Ncp1, M, Ncp2, M,
Ncp1, M, Ncp3, M, Ncp2, M,
Ncp3, M,
Ncp1, M, Ncp2, M, Ncp3, M])
end.
w_app1(Fd) ->
io:format(Fd, "~p.\n", [app1()]).
w_app2(Fd) ->
io:format(Fd, "~p.\n", [app2()]).
w_app3(Fd) ->
io:format(Fd, "~p.\n", [app3()]).
w_app5(Fd) ->
io:format(Fd, "~p.\n", [app5()]).
w_app6(Fd) ->
io:format(Fd, "~p.\n", [app6()]).
w_app7(Fd) ->
io:format(Fd, "~p.\n", [app7()]).
w_app8(Fd) ->
io:format(Fd, "~p.\n", [app8()]).
w_app_start_error(Fd) ->
io:format(Fd, "~p.\n", [app_start_error()]).
w_app(Fd, AppData) ->
io:format(Fd, "~p.\n", [AppData]).
from(H, [H | T]) -> T;
from(H, [_ | T]) -> from(H, T);
from(_H, []) -> [].
is_loaded(Name, [Node | Nodes]) ->
Apps = rpc:call(Node, application, loaded_applications, []),
case lists:keysearch(Name, 1, Apps) of
{value, _} -> is_loaded(Name, Nodes);
false -> false
end;
is_loaded(_Name, []) ->
true;
is_loaded(Name, Node) ->
is_loaded(Name, [Node]).
is_started(Name, Node) ->
Apps = which_applications(Node),
case lists:keysearch(Name, 1, Apps) of
{value, _} -> true;
false -> false
end.
% Waits until application Name is started on at least one node.
wait_until_started(Name, Nodes) ->
case lists:member(true,
lists:map(fun (N) ->
is_started(Name, N)
end,
Nodes)) of
true ->
true;
false ->
test_server:sleep(500),
wait_until_started(Name, Nodes)
end.
% Waits until application Name is stopped on all nodes.
wait_until_stopped(Name, Nodes) ->
case lists:member(true,
lists:map(fun (N) ->
is_started(Name, N)
end,
Nodes)) of
false ->
true;
true ->
test_server:sleep(500),
wait_until_stopped(Name, Nodes)
end.
%% The test server has no support for starting nodes in parallel. To
%% avoid long delays a small sync_nodes_timeout is used. Use this
%% function when starting all nodes but the last one, and when
%% restarting nodes (then use global:sync() to synchronize).
config_fun_fast(SysConfigFun) ->
fun(Fd) -> SysConfigFun(Fd, 1) end.
config_fun(SysConfigFun) ->
fun(Fd) -> SysConfigFun(Fd, 10000) end.
start_node_config(Name, SysConfigFun, Conf) ->
ConfigFile = write_config_file(SysConfigFun, Conf),
start_node(Name, ConfigFile, "").
start_node(Name) ->
Pa = filename:dirname(code:which(?MODULE)),
test_server:start_node(Name, slave, [{args, " -pa " ++ Pa}]).
start_node(Name, ConfigFile) ->
start_node(Name, ConfigFile, "").
start_node(Name, ConfigFile, ExtraArgs) ->
Pa = filename:dirname(code:which(?MODULE)),
test_server:start_node(Name, slave, [{args,
" -pa " ++ Pa ++
" -config " ++ ConfigFile ++
ExtraArgs}]).
start_node_with_cache(Name, SysConfigFun, Conf) ->
ConfigFile = write_config_file(SysConfigFun, Conf),
start_node(Name, ConfigFile, " -code_path_cache").
start_node_args(Name, Args) ->
Pa = filename:dirname(code:which(?MODULE)),
test_server:start_node(Name, slave, [{args, " -pa " ++ Pa ++ " " ++ Args}]).
start_node_boot_3002(Name, Boot) ->
Pa = filename:dirname(code:which(?MODULE)),
?t:format(0, "start_node_boot ~p~n",
[" -pa " ++ Pa ++ " -env ERL_CRASH_DUMP erl_crash_dump." ++
atom_to_list(Name) ++ " -boot " ++ Boot ++
" -sasl dummy \"missing "]),
test_server:start_node(Name, slave,
[{args, " -pa " ++ Pa ++
" -env ERL_CRASH_DUMP erl_crash_dump." ++
atom_to_list(Name) ++ " -boot " ++ Boot ++
" -sasl dummy \"missing "}]).
start_node_boot_config(Name, SysConfigFun, Conf, Boot) ->
ConfigFile = write_config_file(SysConfigFun, Conf),
start_node(Name, ConfigFile, " -boot " ++ atom_to_list(Boot)).
start_node_boot(Name, Config, Boot) ->
Pa = filename:dirname(code:which(?MODULE)),
?t:format(0, "start_node_boot ~p~n",[" -pa " ++ Pa ++ " -config " ++ Config ++
" -boot " ++ atom_to_list(Boot)]),
test_server:start_node(Name, slave, [{args, " -pa " ++ Pa ++ " -config " ++ Config ++
" -boot " ++ atom_to_list(Boot)}]).
start_node_config_sf(Name, SysConfigFun, Conf) ->
ConfigFile = write_config_file(SysConfigFun, Conf),
DataDir = ?config(data_dir, Conf), % is it used?
start_node(Name, ConfigFile, " -pa " ++ DataDir).
write_config_file(SysConfigFun, Conf) ->
Dir = ?config(priv_dir, Conf),
{ok, Fd} = file:open(filename:join(Dir, "sys.config"), [write]),
SysConfigFun(Fd),
file:close(Fd),
filename:join(Dir,"sys").
node_names(Names, Config) ->
[node_name(Name, Config) || Name <- Names].
node_name(Name, Config) ->
U = "_",
{{Y,M,D}, {H,Min,S}} = calendar:now_to_local_time(now()),
Date = io_lib:format("~4w_~2..0w_~2..0w__~2..0w_~2..0w_~2..0w",
[Y,M,D, H,Min,S]),
L = lists:flatten(Date),
lists:concat([Name,U,?testcase,U,U,L]).
stop_node_nice(Node) when is_atom(Node) ->
test_server:stop_node(Node);
stop_node_nice(Nodes) when is_list(Nodes) ->
lists:foreach(fun (N) -> stop_node_nice(N) end, Nodes).
get_start_type(Expected) ->
get_start_type(Expected, 30*5, #st{}).
get_start_type(_Expected, 0, Ack) ->
test_server:format("====== ~p ======~n", [Ack]),
test_server:fail(not_valid_start_type);
get_start_type(Expected, Times, Ack0) ->
#st{normal = N0, local = L0, takeover = T0, failover = F0} = Ack0,
global:send(st_type, {st, read, self()}),
receive
{st, N, L, T, F} ->
Ack = #st{normal = N0 + N, local = L0 + L,
takeover = T0 + T, failover = F0 + F},
if
Ack =:= Expected ->
ok;
true ->
timer:sleep(200),
get_start_type(Expected, Times-1, Ack)
end
after 30*1000 ->
get_start_type(Expected, 0, Ack0)
end.
start_type() ->
st(0, 0, 0, 0).
st(Normal, Local, Takeover, Failover) ->
receive
{st, normal} ->
st(Normal+1, Local, Takeover, Failover);
{st, local} ->
st(Normal, Local+1, Takeover, Failover);
{st, takeover} ->
st(Normal, Local, Takeover+1, Failover);
{st, failover} ->
st(Normal, Local, Takeover, Failover+1);
{st, read, From} ->
From ! {st, Normal, Local, Takeover, Failover},
st(0, 0, 0, 0);
kill ->
exit(normal)
end.
get_start_phase(Expected) ->
global:send(start_phase, {sp, read, self()}),
receive
Expected ->
ok;
{sp, T1, I1, So1, Sp1, G1} ->
test_server:format("=============== {sp,T,I,So,Sp,G} ~p ~n",[" "]),
test_server:format("=========== got ~p ~n",
[{sp, T1, I1, So1, Sp1, G1}]),
test_server:format("====== expected ~p ~n", [Expected]),
test_server:fail(not_valid_start_phase)
after 5000 ->
test_server:fail(not_valid_start_phase)
end.
start_phase() ->
sp(0, 0, 0, 0, 0).
sp(Top, Init, Some, Spec, Go) ->
receive
{sp, top} ->
sp(Top+1, Init, Some, Spec, Go);
{sp, init} ->
sp(Top, Init+1, Some, Spec, Go);
{sp, some} ->
sp(Top, Init, Some+1, Spec, Go);
{sp, spec} ->
sp(Top, Init, Some, Spec+1, Go);
{sp, go} ->
sp(Top, Init, Some, Spec, Go+1);
{sp, read, From} ->
From ! {sp, Top, Init, Some, Spec, Go},
sp(0, 0, 0, 0, 0);
kill ->
exit(normal)
end.
get_conf_change(Expected) ->
global:send(conf_change, {cc, read, self()}),
receive
{cc, Expected} ->
ok;
{cc, List} ->
test_server:format("====== ~p ======~n",[{cc, List}]),
test_server:fail(not_valid_conf_change)
after 5000 ->
test_server:fail(not_valid_conf_change_to)
end.
conf_change() ->
cc([]).
cc(List) ->
receive
{cc, New} ->
cc(List ++ New);
{cc, read, From} ->
From ! {cc, List},
cc([]);
kill ->
exit(normal)
end.
create_app() ->
Dir = "./",
App1 = Dir ++ "app1",
{ok, Fd1} = file:open(App1++".app",[write]),
io:format(Fd1, "~p. \n", [app1()]),
file:close(Fd1),
App2 = Dir ++ "app2",
{ok, Fd2} = file:open(App2++".app",[write]),
io:format(Fd2, "~p. \n", [app2()]),
file:close(Fd2),
App3 = Dir ++ "app_sp",
{ok, Fd3} = file:open(App3++".app",[write]),
io:format(Fd3, "~p. \n", [app_sp()]),
file:close(Fd3),
App4 = Dir ++ "app_no",
{ok, Fd4} = file:open(App4++".app",[write]),
io:format(Fd4, "~p. \n", [app_no()]),
file:close(Fd4),
ok.
create_script(ScriptName) ->
Dir = "./",
Name = Dir ++ ScriptName,
Apps = which_applications(),
{value,{_,_,KernelVer}} = lists:keysearch(kernel,1,Apps),
{value,{_,_,StdlibVer}} = lists:keysearch(stdlib,1,Apps),
{ok,Fd} = file:open(Name++".rel",[write]),
io:format(Fd,
"{release, {\"Test release 3\", \"LATEST\"}, \n"
" {erts, \"4.4\"}, \n"
" [{kernel, \"~s\"}, {stdlib, \"~s\"}, \n"
" {app1, \"2.0\"}, {app2, \"2.0\"}, \n"
" {app_sp, \"2.0\"}, {app_no, \"1.0\"}]}.\n",
[KernelVer,StdlibVer]),
file:close(Fd),
{{KernelVer,StdlibVer},
{filename:dirname(Name), filename:basename(Name)}}.
create_script_no(ScriptName) ->
Dir = "./",
Name = Dir ++ ScriptName,
Apps = which_applications(),
{value,{_,_,KernelVer}} = lists:keysearch(kernel,1,Apps),
{value,{_,_,StdlibVer}} = lists:keysearch(stdlib,1,Apps),
{ok,Fd} = file:open(Name++".rel",[write]),
io:format(Fd,
"{release, {\"Test release 3\", \"LATEST\"}, \n"
" {erts, \"4.4\"}, \n"
" [{kernel, \"~s\"}, {stdlib, \"~s\"}, \n"
" {app_no, \"1.0\"}]}.\n",
[KernelVer,StdlibVer]),
file:close(Fd),
{{KernelVer,StdlibVer},
{filename:dirname(Name), filename:basename(Name)}}.
create_script_dc(ScriptName) ->
Dir = "./",
Name = Dir ++ ScriptName,
Apps = which_applications(),
{value,{_,_,KernelVer}} = lists:keysearch(kernel,1,Apps),
{value,{_,_,StdlibVer}} = lists:keysearch(stdlib,1,Apps),
{ok,Fd} = file:open(Name++".rel",[write]),
io:format(Fd,
"{release, {\"Test release 3\", \"LATEST\"}, \n"
" {erts, \"4.4\"}, \n"
" [{kernel, \"~s\"}, {stdlib, \"~s\"}, \n"
" {app1, \"2.0\"}, {app2, \"2.0\"}, {app3, \"2.0\"}, \n"
" {app6, \"2.0\"}, {app7, \"2.0\"}, {app8, \"2.0\"}]}.\n",
[KernelVer,StdlibVer]),
file:close(Fd),
{{KernelVer,StdlibVer},
{filename:dirname(Name), filename:basename(Name)}}.
create_script_3002(ScriptName) ->
Dir = "./",
Name = Dir ++ ScriptName,
Apps = which_applications(),
{value,{_,_,KernelVer}} = lists:keysearch(kernel,1,Apps),
{value,{_,_,StdlibVer}} = lists:keysearch(stdlib,1,Apps),
{value,{_,_,SaslVer}} = lists:keysearch(sasl,1,Apps),
{ok,Fd} = file:open(Name++".rel",[write]),
io:format(Fd,
"{release, {\"Test release 3\", \"LATEST\"}, \n"
" {erts, \"4.4\"}, \n"
" [{kernel, \"~s\"}, {stdlib, \"~s\"}, \n"
" {sasl, \"~s\"}]}.\n",
[KernelVer, StdlibVer, SaslVer]),
file:close(Fd),
{{KernelVer,StdlibVer},
{filename:dirname(Name), filename:basename(Name)}}.
distr_changed_prep(Conf) when is_list(Conf) ->
% Write .app files
{ok, Fd1} = file:open("app1.app", [write]),
w_app1(Fd1),
file:close(Fd1),
{ok, Fd2} = file:open("app2.app", [write]),
w_app2(Fd2),
file:close(Fd2),
{ok, Fd3} = file:open("app3.app", [write]),
w_app3(Fd3),
file:close(Fd3),
{ok, Fd4} = file:open("app6.app", [write]),
w_app6(Fd4),
file:close(Fd4),
{ok, Fd5} = file:open("app7.app", [write]),
w_app7(Fd5),
file:close(Fd5),
{ok, Fd6} = file:open("app8.app", [write]),
w_app8(Fd6),
file:close(Fd6),
% Create the .app files and the boot script
{{KernelVer,StdlibVer}, _} = create_script_dc("dc"),
case is_real_system(KernelVer, StdlibVer) of
true ->
Options = [];
false ->
Options = [local]
end,
ok = systools:make_script("dc", Options),
NodeNames = [Ncp1, Ncp2, Ncp3] = node_names([cp1, cp2, cp3], Conf),
NoSyncTime = config_fun_fast(config_dc(NodeNames)),
WithSyncTime = config_fun(config_dc(NodeNames)),
Dir = ?config(priv_dir,Conf),
{ok, Fd_dc2} = file:open(filename:join(Dir, "sys2.config"), [write]),
(config_dc2(NodeNames))(Fd_dc2),
file:close(Fd_dc2),
Config2 = filename:join(Dir, "sys2"),
% Test [cp1, cp2, cp3]
{ok, Cp1} = start_node_boot_config(Ncp1, NoSyncTime, Conf, dc),
{ok, Cp2} = start_node_boot_config(Ncp2, NoSyncTime, Conf, dc),
{ok, Cp3} = start_node_boot_config(Ncp3, WithSyncTime, Conf, dc),
global:sync(),
%% Read the current configuration parameters, and change them
OldEnv = rpc:call(Cp1, application_controller, prep_config_change, []),
{value, {kernel, OldKernel}} = lists:keysearch(kernel, 1, OldEnv),
{OldKernel, OldEnv, {Cp1, Cp2, Cp3}, {Ncp1, Ncp2, Ncp3}, Config2}.
%%% Copied from init_SUITE.erl.
is_real_system(KernelVsn, StdlibVsn) ->
LibDir = code:lib_dir(),
case file:read_file_info(LibDir ++ "/kernel-" ++ KernelVsn) of
{ok, _} ->
case file:read_file_info(LibDir ++ "/stdlib-" ++ StdlibVsn) of
{ok, _} ->
true;
_ ->
false
end;
_ ->
false
end.
init2973() ->
loop2973().
loop2973() ->
receive
{start, From, App} ->
Res = application:start(App),
From ! {self(), res, Res},
loop2973();
kill ->
exit(normal)
end.
wait_for_ready_net() ->
Nodes = lists:sort([node() | nodes()]),
?UNTIL(begin
lists:all(fun(N) -> Nodes =:= get_known(N) end, Nodes) and
lists:all(fun(N) ->
LNs = rpc:call(N, erlang, nodes, []),
Nodes =:= lists:sort([N | LNs])
end, Nodes)
end).
get_known(Node) ->
case catch gen_server:call({global_name_server,Node}, get_known) of
{'EXIT', _} ->
[list, without, nodenames];
Known ->
lists:sort([Node | Known])
end.
which_applications() ->
application_controller:which_applications(infinity).
which_applications(Node) ->
rpc:call(Node, application, which_applications, [infinity]).
Jump to Line
Something went wrong with that request. Please try again.