aboutsummaryrefslogtreecommitdiffstats
path: root/lib/kernel/test/code_SUITE.erl
diff options
context:
space:
mode:
authorErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
committerErlang/OTP <[email protected]>2009-11-20 14:54:40 +0000
commit84adefa331c4159d432d22840663c38f155cd4c1 (patch)
treebff9a9c66adda4df2106dfd0e5c053ab182a12bd /lib/kernel/test/code_SUITE.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/kernel/test/code_SUITE.erl')
-rw-r--r--lib/kernel/test/code_SUITE.erl1236
1 files changed, 1236 insertions, 0 deletions
diff --git a/lib/kernel/test/code_SUITE.erl b/lib/kernel/test/code_SUITE.erl
new file mode 100644
index 0000000000..9fda66711d
--- /dev/null
+++ b/lib/kernel/test/code_SUITE.erl
@@ -0,0 +1,1236 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 1996-2009. 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(code_SUITE).
+
+-include("test_server.hrl").
+
+-export([all/1]).
+-export([set_path/1, get_path/1, add_path/1, add_paths/1, del_path/1,
+ replace_path/1, load_file/1, load_abs/1, ensure_loaded/1,
+ delete/1, purge/1, soft_purge/1, is_loaded/1, all_loaded/1,
+ load_binary/1, dir_req/1, object_code/1, set_path_file/1,
+ sticky_dir/1, pa_pz_option/1, add_del_path/1,
+ dir_disappeared/1, ext_mod_dep/1,
+ load_cached/1, start_node_with_cache/1, add_and_rehash/1,
+ where_is_file_cached/1, where_is_file_no_cache/1,
+ purge_stacktrace/1, mult_lib_roots/1, bad_erl_libs/1,
+ code_archive/1, code_archive2/1, on_load/1,
+ on_load_embedded/1]).
+
+-export([init_per_testcase/2, fin_per_testcase/2,
+ init_per_suite/1, end_per_suite/1,
+ sticky_compiler/1]).
+
+all(suite) ->
+ [set_path, get_path, add_path, add_paths, del_path,
+ replace_path, load_file, load_abs, ensure_loaded,
+ delete, purge, soft_purge, is_loaded, all_loaded,
+ load_binary, dir_req, object_code, set_path_file,
+ pa_pz_option, add_del_path,
+ dir_disappeared, ext_mod_dep,
+ load_cached, start_node_with_cache, add_and_rehash,
+ where_is_file_no_cache, where_is_file_cached,
+ purge_stacktrace, mult_lib_roots, bad_erl_libs,
+ code_archive, code_archive2, on_load, on_load_embedded].
+
+init_per_suite(Config) ->
+ %% The compiler will no longer create a Beam file if
+ %% the module name does not match the filename, so
+ %% we must compile to a binary and write the Beam file
+ %% ourselves.
+ ?line Dir = filename:dirname(code:which(?MODULE)),
+ ?line File = filename:join(Dir, "code_a_test"),
+ ?line {ok,code_b_test,Code} = compile:file(File, [binary]),
+ ?line ok = file:write_file(File++".beam", Code),
+ Config.
+
+end_per_suite(Config) ->
+ Config.
+
+init_per_testcase(_Func, Config) ->
+ Dog=?t:timetrap(?t:minutes(5)),
+ P=code:get_path(),
+ P=code:get_path(),
+ [{watchdog, Dog}, {code_path, P}|Config].
+fin_per_testcase(_Func, Config) ->
+ Dog=?config(watchdog, Config),
+ ?t:timetrap_cancel(Dog),
+ P=?config(code_path, Config),
+ true=code:set_path(P),
+ P=code:get_path(),
+ ok.
+
+set_path(suite) -> [];
+set_path(doc) -> [];
+set_path(Config) when is_list(Config) ->
+ P = code:get_path(),
+ NonExDir = filename:join(?config(priv_dir, Config), ?t:temp_name("hej")),
+ ?line {'EXIT',_} = (catch code:set_path({a})),
+ ?line {error, bad_directory} = (catch code:set_path([{a}])),
+ ?line {error, bad_directory} = code:set_path(NonExDir),
+ ?line P = code:get_path(), % still the same path.
+ ?line true = code:set_path(P), % set the same path again.
+ ?line P = code:get_path(), % still the same path.
+ LibDir = code:lib_dir(),
+ ?line true = code:set_path([LibDir | P]),
+ ?line [LibDir | P] = code:get_path(),
+ ?line true = code:set_path([LibDir]),
+ ?line [LibDir] = code:get_path(),
+ ok.
+
+get_path(suite) -> [];
+get_path(doc) -> [];
+get_path(Config) when is_list(Config) ->
+ ?line P = code:get_path(),
+ % test that all directories are strings (lists).
+ ?line [] = lists:filter(fun(Dir) when is_list(Dir) ->
+ false;
+ (_) ->
+ true
+ end,
+ P),
+ ok.
+
+add_path(suite) -> [];
+add_path(doc) -> [];
+add_path(Config) when is_list(Config) ->
+ P = code:get_path(),
+ ?line {'EXIT',_} = (catch code:add_path({})),
+ ?line {'EXIT',_} = (catch code:add_patha({})),
+ ?line {'EXIT',_} = (catch code:add_pathz({})),
+ ?line {error, bad_directory} = code:add_path("xyz"),
+ ?line {error, bad_directory} = code:add_patha("xyz"),
+ ?line {error, bad_directory} = code:add_pathz("xyz"),
+ LibDir = code:lib_dir(),
+ ?line true = code:add_path(LibDir),
+ ?line LibDir = lists:last(code:get_path()),
+ code:set_path(P),
+ ?line true = code:add_pathz(LibDir),
+ ?line LibDir = lists:last(code:get_path()),
+ code:set_path(P),
+ ?line true = code:add_patha(LibDir),
+ ?line [LibDir|_] = code:get_path(),
+ code:set_path(P),
+ ok.
+
+add_paths(suite) -> [];
+add_paths(doc) -> [];
+add_paths(Config) when is_list(Config) ->
+ P = code:get_path(),
+ ?line ok = code:add_paths([{}]),
+ ?line ok = code:add_pathsa([{}]),
+ ?line ok = code:add_pathsz([{}]),
+ ?line ok = code:add_paths(["xyz"]),
+ ?line ok = code:add_pathsa(["xyz"]),
+ ?line ok = code:add_pathsz(["xyz"]),
+ P = code:get_path(), % check that no directory is added.
+
+ LibDir = code:lib_dir(),
+ ?line ok = code:add_paths([LibDir]),
+ ?line LibDir = lists:last(code:get_path()),
+ code:set_path(P),
+ ?line ok = code:add_pathsz([LibDir]),
+ ?line LibDir = lists:last(code:get_path()),
+ code:set_path(P),
+ ?line ok = code:add_pathsa([LibDir]),
+ ?line [LibDir|P] = code:get_path(),
+ code:set_path(P),
+
+ RootDir = code:root_dir(),
+ Res = P ++ [LibDir, RootDir],
+ ?line ok = code:add_paths([LibDir, RootDir]),
+ ?line Res = code:get_path(),
+ code:set_path(P),
+ ?line ok = code:add_pathsz([LibDir, RootDir]),
+ ?line Res = code:get_path(),
+ code:set_path(P),
+ ?line ok = code:add_pathsa([LibDir, RootDir]),
+ ?line [RootDir, LibDir|P] = code:get_path(),
+ code:set_path(P),
+
+ ?line ok = code:add_paths([LibDir, "xyz"]),
+ Res1 = P ++ [LibDir],
+ ?line Res1 = code:get_path(),
+ code:set_path(P),
+ ?line ok = code:add_pathsz([LibDir, "xyz"]),
+ ?line Res1 = code:get_path(),
+ code:set_path(P),
+ ?line ok = code:add_pathsa([LibDir, "xyz"]),
+ ?line [LibDir|P] = code:get_path(),
+ code:set_path(P),
+ ok.
+
+del_path(suite) -> [];
+del_path(doc) -> [];
+del_path(Config) when is_list(Config) ->
+ ?line P = code:get_path(),
+ test_server:format("Initial code:get_path()=~p~n",[P]),
+ ?line {'EXIT',_} = (catch code:del_path(3)),
+ ?line false = code:del_path(my_dummy_name),
+ ?line false = code:del_path("/kdlk/my_dummy_dir"),
+ Dir = filename:join([code:lib_dir(kernel),"ebin"]),
+ test_server:format("kernel dir: ~p~n",[Dir]),
+
+
+ ?line true = code:del_path(kernel),
+ NewP = code:get_path(),
+ test_server:format("Path after removing 'kernel':~p~n",[NewP]),
+ ReferenceP = lists:delete(Dir,P),
+ test_server:format("Reference path:~p~n",[ReferenceP]),
+ ?line NewP = ReferenceP, % check that dir is deleted
+
+ code:set_path(P),
+ ?line true = code:del_path(Dir),
+ NewP1 = code:get_path(),
+ ?line NewP1 = lists:delete(Dir,P), % check that dir is deleted
+ code:set_path(P),
+ ok.
+
+replace_path(suite) -> [];
+replace_path(doc) -> [];
+replace_path(Config) when is_list(Config) ->
+ ?line PrivDir = ?config(priv_dir, Config),
+ ?line P = code:get_path(),
+ ?line {'EXIT',_} = (catch code:replace_path(3,"")),
+ ?line {error, bad_name} = code:replace_path(dummy_name,""),
+ ?line {error, bad_name} = code:replace_path(kernel,
+ "/kdlk/my_dummy_dir"),
+ ?line {error, bad_directory} = code:replace_path(kernel,
+ "/kdlk/kernel-1.2"),
+ ?line P = code:get_path(), % Check that path is not changed.
+
+ ?line ok = file:set_cwd(PrivDir),
+
+ %% Replace an existing application.
+
+ file:make_dir("./kernel-2.11"),
+ {ok, Cwd} = file:get_cwd(),
+ NewDir = Cwd ++ "/kernel-2.11",
+ ?line true = code:replace_path(kernel, NewDir),
+ ?line NewDir = code:lib_dir(kernel),
+ ?line true = code:set_path(P), %Reset path
+ ?line ok = file:del_dir("./kernel-2.11"),
+
+ %% Add a completly new application.
+
+ NewAppName = "blurf_blarfer",
+ ?line NewAppDir = filename:join(Cwd, NewAppName ++ "-6.33.1"),
+ ?line ok = file:make_dir(NewAppDir),
+ ?line true = code:replace_path(NewAppName, NewAppDir),
+ ?line NewAppDir = code:lib_dir(NewAppName),
+ ?line NewAppDir = lists:last(code:get_path()),
+ ?line true = code:set_path(P), %Reset path
+ ?line ok = file:del_dir(NewAppDir),
+
+ ok.
+
+dir_disappeared(suite) -> [];
+dir_disappeared(doc) -> ["OTP-3977"];
+dir_disappeared(Config) when is_list(Config) ->
+ ?line PrivDir = ?config(priv_dir, Config),
+ ?line Dir = filename:join(PrivDir, "temp"),
+ ?line ok = file:make_dir(Dir),
+ ?line true = code:add_path(Dir),
+ ?line ok = file:del_dir(Dir),
+ ?line non_existing = code:which(bubbelskrammel),
+ ok.
+
+load_file(suite) -> [];
+load_file(doc) -> [];
+load_file(Config) when is_list(Config) ->
+ ?line {error, nofile} = code:load_file(duuuumy_mod),
+ ?line {error, badfile} = code:load_file(code_a_test),
+ ?line {'EXIT', _} = (catch code:load_file(123)),
+ ?line {module, code_b_test} = code:load_file(code_b_test),
+ TestDir = test_dir(),
+ code:stick_dir(TestDir),
+ ?line {error, sticky_directory} = code:load_file(code_b_test),
+ code:unstick_dir(TestDir),
+ ok.
+
+test_dir() ->
+ filename:dirname(code:which(?MODULE)).
+
+load_abs(suite) -> [];
+load_abs(doc) -> [];
+load_abs(Config) when is_list(Config) ->
+ TestDir = test_dir(),
+ ?line {error, nofile} = code:load_abs(TestDir ++ "/duuuumy_mod"),
+ ?line {error, badfile} = code:load_abs(TestDir ++ "/code_a_test"),
+ ?line {'EXIT', _} = (catch code:load_abs({})),
+ ?line {module, code_b_test} = code:load_abs(TestDir ++ "/code_b_test"),
+ code:stick_dir(TestDir),
+ ?line {error, sticky_directory} = code:load_abs(TestDir ++ "/code_b_test"),
+ code:unstick_dir(TestDir),
+ ok.
+
+ensure_loaded(suite) -> [];
+ensure_loaded(doc) -> [];
+ensure_loaded(Config) when is_list(Config) ->
+ ?line {module, lists} = code:ensure_loaded(lists),
+ case init:get_argument(mode) of
+ {ok, [["embedded"]]} ->
+ ?line {error, embedded} = code:ensure_loaded(code_b_test),
+ ?line {error, badarg} = code:ensure_loaded(34),
+ ok;
+ _ ->
+ ?line {error, nofile} = code:ensure_loaded(duuuumy_mod),
+ ?line {error, badfile} = code:ensure_loaded(code_a_test),
+ ?line {'EXIT', _} = (catch code:ensure_loaded(34)),
+ ?line {module, code_b_test} = code:ensure_loaded(code_b_test),
+ ?line {module, code_b_test} = code:ensure_loaded(code_b_test),
+ ok
+ end.
+
+delete(suite) -> [];
+delete(doc) -> [];
+delete(Config) when is_list(Config) ->
+ OldFlag = process_flag(trap_exit, true),
+ code:purge(code_b_test),
+ ?line Pid = code_b_test:do_spawn(),
+ ?line true = code:delete(code_b_test),
+ ?line {'EXIT',_} = (catch code:delete(122)),
+ ?line false = code_b_test:check_exit(Pid),
+ ?line false = code:delete(code_b_test),
+ ?line false = code_b_test:check_exit(Pid),
+ exit(Pid,kill),
+ ?line true = code_b_test:check_exit(Pid),
+ ?line false = code:delete(code_b_test),
+ code:purge(code_b_test),
+ process_flag(trap_exit, OldFlag),
+ ok.
+
+purge(suite) -> [];
+purge(doc) -> [];
+purge(Config) when is_list(Config) ->
+ OldFlag = process_flag(trap_exit, true),
+ code:purge(code_b_test),
+ ?line {'EXIT',_} = (catch code:purge({})),
+ ?line false = code:purge(code_b_test),
+ ?line Pid = code_b_test:do_spawn(),
+ ?line true = code:delete(code_b_test),
+ ?line false = code_b_test:check_exit(Pid),
+ ?line true = code:purge(code_b_test),
+ ?line true = code_b_test:check_exit(Pid),
+ process_flag(trap_exit, OldFlag),
+ ok.
+
+soft_purge(suite) -> [];
+soft_purge(doc) -> [];
+soft_purge(Config) when is_list(Config) ->
+ OldFlag = process_flag(trap_exit, true),
+ code:purge(code_b_test),
+ ?line {'EXIT',_} = (catch code:soft_purge(23)),
+ ?line true = code:soft_purge(code_b_test),
+ ?line Pid = code_b_test:do_spawn(),
+ ?line true = code:delete(code_b_test),
+ ?line false = code_b_test:check_exit(Pid),
+ ?line false = code:soft_purge(code_b_test),
+ ?line false = code_b_test:check_exit(Pid),
+ exit(Pid,kill),
+ ?line true = code_b_test:check_exit(Pid),
+ ?line true = code:soft_purge(code_b_test),
+ process_flag(trap_exit, OldFlag),
+ ok.
+
+is_loaded(suite) -> [];
+is_loaded(doc) -> [];
+is_loaded(Config) when is_list(Config) ->
+ code:purge(code_b_test),
+ code:delete(code_b_test),
+ ?line false = code:is_loaded(duuuuuumy_mod),
+ ?line {'EXIT',_} = (catch code:is_loaded(23)),
+ ?line {file, preloaded} = code:is_loaded(init),
+ TestDir = test_dir(),
+ ?line {module, code_b_test} = code:load_abs(TestDir ++ "/code_b_test"),
+ ?line {file, _Loaded} = code:is_loaded(code_b_test),
+ code:purge(code_b_test),
+ code:delete(code_b_test),
+ ok.
+
+all_loaded(suite) -> [];
+all_loaded(doc) -> [];
+all_loaded(Config) when is_list(Config) ->
+ case ?t:is_cover() of
+ true -> {skip,"Cover is running"};
+ false -> all_loaded_1()
+ end.
+
+all_loaded_1() ->
+ ?line Preloaded = [{M,preloaded} || M <- lists:sort(erlang:pre_loaded())],
+
+ ?line Loaded0 = lists:sort(code:all_loaded()),
+ ?line all_unique(Loaded0),
+ ?line Loaded1 = lists:keysort(2, Loaded0),
+ ?line Loaded2 = match_and_remove(Preloaded, Loaded1),
+
+ ObjExt = code:objfile_extension(),
+ ?line [] = lists:filter(fun({Mod,AbsName}) when is_atom(Mod), is_list(AbsName) ->
+ Mod =:= filename:basename(AbsName, ObjExt);
+ (_) -> true
+ end,
+ Loaded2),
+ ok.
+
+match_and_remove([], List) -> List;
+match_and_remove([X|T1], [X|T2]) -> match_and_remove(T1, T2).
+
+all_unique([]) -> ok;
+all_unique([_]) -> ok;
+all_unique([{X,_}|[{Y,_}|_]=T]) when X < Y -> all_unique(T).
+
+load_binary(suite) -> [];
+load_binary(doc) -> [];
+load_binary(Config) when is_list(Config) ->
+ TestDir = test_dir(),
+ File = TestDir ++ "/code_b_test" ++ code:objfile_extension(),
+ ?line {ok,Bin} = file:read_file(File),
+ ?line {'EXIT',_} = (catch code:load_binary(12, File, Bin)),
+ ?line {'EXIT',_} = (catch code:load_binary(code_b_test, 12, Bin)),
+ ?line {'EXIT',_} = (catch code:load_binary(code_b_test, File, 12)),
+ ?line {module, code_b_test} = code:load_binary(code_b_test, File, Bin),
+ code:stick_dir(TestDir),
+ ?line {error, sticky_directory} = code:load_binary(code_b_test, File, Bin),
+ code:unstick_dir(TestDir),
+ code:purge(code_b_test),
+ code:delete(code_b_test),
+ ok.
+
+dir_req(suite) -> [];
+dir_req(doc) -> [];
+dir_req(Config) when is_list(Config) ->
+ ?line {ok,[[Root0]]} = init:get_argument(root),
+ ?line Root = filename:join([Root0]), % Normalised form.
+ ?line Root = code:root_dir(),
+ LibDir = Root ++ "/lib",
+ ?line LibDir = code:lib_dir(),
+ ?line code:compiler_dir(),
+ ?line {error, bad_name} = code:lib_dir(duuumy),
+ ?line KernLib = code:lib_dir(kernel),
+ ?line Priv = KernLib ++ "/priv",
+ ?line Priv = code:priv_dir(kernel),
+ ?line {error, bad_name} = code:priv_dir(duuumy),
+ ok.
+
+object_code(suite) -> [];
+object_code(doc) -> [];
+object_code(Config) when is_list(Config) ->
+ TestDir = test_dir(),
+ P = code:get_path(),
+ P = code:get_path(),
+ code:add_path(TestDir),
+ ?line {module, code_b_test} = code:load_abs(TestDir ++ "/code_b_test"),
+ LoadedFile = filename:absname(TestDir ++ "/code_b_test" ++
+ code:objfile_extension()),
+ ?line case code:get_object_code(code_b_test) of
+ {code_b_test,Bin,LoadedFile} when is_binary(Bin) ->
+ ok
+ end,
+ code:purge(code_b_test),
+ code:delete(code_b_test),
+ ?line error = code:get_object_code(dddddddduuuuuuumy),
+ ?line {'EXIT',_} = (catch code:get_object_code(23)),
+ ?line code:set_path(P),
+ ?line P=code:get_path(),
+ ok.
+
+set_path_file(suite) -> [];
+set_path_file(doc) -> ["Test that set_path does not accept ",
+ "files as pathnames (known previous bug)"];
+set_path_file(Config) when is_list(Config) ->
+ File=filename:join(?config(priv_dir, Config), "testfil"),
+ ?line ok=file:write_file(File, list_to_binary("lite data")),
+ ?line {error, bad_directory}=code:set_path([File]).
+
+sticky_dir(suite) -> [];
+sticky_dir(doc) -> ["Test that a module with the same name as a module in ",
+ "a sticky directory cannot be loaded."];
+sticky_dir(Config) when is_list(Config) ->
+ MyDir=filename:dirname(code:which(?MODULE)),
+ ?line {ok, Node}=?t:start_node(sticky_dir, slave,[{args, "-pa "++MyDir}]),
+ File=filename:join([?config(data_dir, Config), "calendar"]),
+ ?line Ret=rpc:call(Node, ?MODULE, sticky_compiler, [File]),
+ case Ret of
+ fail ->
+ ?t:fail("c:c allowed a sticky module to be compiled and loaded.");
+ ok ->
+ ok;
+ Other ->
+ test_server:format("Other: ~p",[Other])
+ end,
+ ?t:stop_node(Node).
+
+sticky_compiler(File) ->
+ Compiled=File++code:objfile_extension(),
+ Dir=filename:dirname(File),
+ code:add_patha(Dir),
+ file:delete(Compiled),
+ case c:c(File, [{outdir, Dir}]) of
+ {ok, Module} ->
+ case catch Module:test(apa) of
+ {error, _} ->
+ fail;
+ {'EXIT', _} ->
+ ok
+ end;
+ Other ->
+ test_server:format("c:c(~p) returned: ~p",[File, Other]),
+ ok
+ end.
+
+pa_pz_option(suite) -> [];
+pa_pz_option(doc) -> ["Test that the -pa and -pz options work as expected"];
+pa_pz_option(Config) when is_list(Config) ->
+ case os:type() of
+ vxworks ->
+ {comment, "Slave nodes not supported on VxWorks"};
+ _ ->
+ DDir = ?config(data_dir,Config),
+ PaDir = filename:join(DDir,"pa"),
+ PzDir = filename:join(DDir,"pz"),
+ ?line {ok, Node}=?t:start_node(pa_pz1, slave,
+ [{args,
+ "-pa " ++ PaDir
+ ++ " -pz " ++ PzDir}]),
+ ?line Ret=rpc:call(Node, code, get_path, []),
+ ?line [PaDir|Paths] = Ret,
+ ?line [PzDir|_] = lists:reverse(Paths),
+ ?t:stop_node(Node),
+ ?line {ok, Node2}=?t:start_node(pa_pz2, slave,
+ [{args,
+ "-mode embedded " ++ "-pa "
+ ++ PaDir ++ " -pz " ++ PzDir}]),
+ ?line Ret2=rpc:call(Node2, code, get_path, []),
+ ?line [PaDir|Paths2] = Ret2,
+ ?line [PzDir|_] = lists:reverse(Paths2),
+ ?t:stop_node(Node2)
+ end.
+
+add_del_path(suite) ->
+ [];
+add_del_path(doc) -> ["add_path, del_path should not cause priv_dir(App) to fail"];
+add_del_path(Config) ->
+ DDir = ?config(data_dir,Config),
+ Dir1 = filename:join(DDir,"dummy_app-1.0/ebin"),
+ Dir2 = filename:join(DDir,"dummy_app-2.0/ebin"),
+ code:add_patha(Dir1),
+ ?line PrivDir1 = filename:join(DDir,"dummy_app-1.0/priv"),
+ ?line PrivDir1 = code:priv_dir(dummy_app),
+ ?line code:add_path(Dir2), % put last in path
+ ?line PrivDir1 = code:priv_dir(dummy_app),
+ ?line code:del_path(Dir2),
+ ?line PrivDir1 = code:priv_dir(dummy_app),
+ ok.
+
+
+ext_mod_dep(suite) ->
+ [];
+ext_mod_dep(doce) ->
+ ["Every module that the code_server uses should be preloaded, "
+ "this test case verifies that"];
+ext_mod_dep(Config) when is_list(Config) ->
+ xref:start(s),
+ xref:set_default(s, [{verbose,false},{warnings,false},
+ {builtins,true},{recurse,true}]),
+ xref:set_library_path(s, code:get_path()),
+ xref:add_directory(s, filename:dirname(code:which(kernel))),
+ xref:add_directory(s, filename:dirname(code:which(lists))),
+ case catch ext_mod_dep2() of
+ {'EXIT', Reason} ->
+ xref:stop(s),
+ exit(Reason);
+ Else ->
+ xref:stop(s),
+ case Else of
+ ok -> ok;
+ _ -> test_server:fail(Else)
+ end
+ end.
+
+ext_mod_dep2() ->
+ Exports0 = code_server:module_info(exports) --
+ [{module_info,0},{module_info,1}],
+ Exports = [{code_server,M,A} || {M,A} <- Exports0],
+ case analyse(Exports, [], [], 0) of
+ {_Visited,0} ->
+ ok;
+ {_Visited,ErrCnt} ->
+ {not_verified,ErrCnt}
+ end.
+
+analyse([], [], Visited, ErrCnt) ->
+ {Visited,ErrCnt};
+analyse([], [This={M,F,A}|Path], Visited, ErrCnt0) ->
+ %% The code_server has been granted to use the following modules,
+ %% These modules should be loaded by code.erl before
+ %% the code_server is started.
+ OK = [erlang, os, prim_file, erl_prim_loader, init, ets,
+ code_server, lists, lists_sort, filename, packages,
+ gb_sets, gb_trees, hipe_unified_loader, hipe_bifs,
+ prim_zip, zlib],
+ ErrCnt1 =
+ case lists:member(M, OK) or erlang:is_builtin(M,F,A) of
+ true ->
+ 0;
+ false ->
+ check_funs(This, Path)
+ end,
+ {Visited, ErrCnt1+ErrCnt0};
+analyse([MFA|R], Path, Visited0, ErrCnt0) ->
+ case lists:member(MFA,Visited0) of
+ false ->
+ {Visited,ErrCnt1} = analyse2(MFA, Path, Visited0),
+ analyse(R, Path, Visited, ErrCnt1+ErrCnt0);
+ true ->
+ analyse(R, Path, Visited0, ErrCnt0)
+ end.
+
+analyse2(MFA = {'$M_EXPR',_, _}, Path, Visited0) ->
+ analyse([], [MFA|Path], Visited0, 0);
+analyse2(MFA={_,_,_}, Path, Visited0) ->
+ {ok, FL} = xref:analyze(s,{call,MFA}),
+ analyse(FL, [MFA|Path], my_usort([MFA|Visited0]), 0).
+
+%%%% We need to check these manually...
+% fun's are ok as long as they are defined locally.
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{code_server,load_native_code,4},
+ {code_server,load_native_code_1,2},
+ {code_server,load_native_code,2},
+ {code_server,try_load_module,4},
+ {code_server,do_load_binary,4},
+ {code_server,handle_call,3},
+ {code_server,loop,1}|_]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{code_server,do_mod_call,4},
+ {code_server,handle_call,3}|_]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{lists,flatmap,2},
+ {lists,concat,1},
+ {code_server,load_abs,4},
+ {code_server,handle_call,3},
+ {code_server,loop,1}|_]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{lists,foreach,2},
+ {code_server,stick_dir,3},
+ {code_server,handle_call,3},
+ {code_server,loop,1}|_]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',1},
+ [{lists,all,2},
+ {code_server,is_numstr,1},
+ {code_server,is_vsn,1},
+ {code_server,vsn_to_num,1},
+ {code_server,create_bundle,2},
+ {code_server,choose_bundles,1},
+ {code_server,make_path,2},
+ {code_server,get_user_lib_dirs_1,1},
+ {code_server,get_user_lib_dirs,0},
+ {code_server,init,3},
+ {code_server,start_link,1}]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',1},
+ [{lists,filter,2},
+ {code_server,try_archive_subdirs,3},
+ {code_server,all_archive_subdirs,1},
+ {code_server,archive_subdirs,1},
+ {code_server,insert_name,3},
+ {code_server,replace_name,2},
+ {code_server,update,2},
+ {code_server,maybe_update,2},
+ {code_server,do_add,4},
+ {code_server,add_path,4},
+ {code_server,handle_call,3},
+ {code_server,loop,1},
+ {code_server,system_continue,3}]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{erlang,apply,2},
+ {erlang,spawn_link,1},
+ {code_server,start_link,1}]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',_},
+ [{erlang,spawn_link,1},{code_server,start_link,1}]) -> 0;
+check_funs({'$M_EXPR',module_info,1},
+ [{hipe_unified_loader,patch_to_emu_step1,1} | _]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',2},
+ [{lists,foldl,3},
+ {hipe_unified_loader,sort_and_write,4} | _]) -> 0;
+check_funs({'$M_EXPR','$F_EXPR',1},
+ [{lists,foreach,2},
+ {hipe_unified_loader,patch_consts,3} | _]) -> 0;
+%% This is cheating! /raimo
+%%
+%% check_funs(This = {M,_,_}, Path) ->
+%% case catch atom_to_list(M) of
+%% [$h,$i,$p,$e | _] ->
+%% test_server:format("hipe_module_ignored(~p, ~p)~n", [This, Path]),
+%% 0;
+%% _ ->
+%% test_server:format("not_verified(~p, ~p)~n", [This, Path]),
+%% 1
+%% end;
+check_funs(This, Path) ->
+ test_server:format("not_verified(~p, ~p)~n", [This, Path]),
+ 1.
+
+my_usort(List) ->
+ lists:reverse(uniq(lists:sort(List),[])).
+
+uniq([],A) ->
+ A;
+uniq([H|T],[]) ->
+ uniq(T,[H]);
+uniq([H|T],[H|_]=A) ->
+ uniq(T,A);
+uniq([H|T],A) ->
+ uniq(T,[H|A]).
+
+
+load_cached(suite) ->
+ [];
+load_cached(doc) ->
+ [];
+load_cached(Config) when is_list(Config) ->
+ ?line Priv = ?config(priv_dir, Config),
+ ?line WD = filename:dirname(code:which(?MODULE)),
+ ?line {ok,Node} =
+ ?t:start_node(code_cache_node, peer, [{args,
+ "-pa " ++ WD},
+ {erl, [this]}]),
+ CCTabCreated = fun(Tab) ->
+ case ets:info(Tab, name) of
+ code_cache -> true;
+ _ -> false
+ end
+ end,
+ ?line Tabs = rpc:call(Node, ets, all, []),
+ case rpc:call(Node, lists, any, [CCTabCreated,Tabs]) of
+ true ->
+ ?t:stop_node(Node),
+ ?t:fail("Code cache should not be active!");
+ false ->
+ ok
+ end,
+ ?line rpc:call(Node, code, del_path, [Priv]),
+ ?line rpc:call(Node, code, add_pathz, [Priv]),
+
+ FullModName = Priv ++ "/code_cache_test",
+ ?line {ok,Dev} = file:open(FullModName ++ ".erl", [write]),
+ ?line io:format(Dev, "-module(code_cache_test). -export([a/0]). a() -> ok.~n", []),
+ ?line ok = file:close(Dev),
+ ?line {ok,code_cache_test} = compile:file(FullModName, [{outdir,Priv}]),
+
+ F = fun load_loop/2,
+ N = 1000,
+ ?line {T0,T1} = rpc:call(Node, erlang, apply, [F, [N,code_cache_test]]),
+ TNoCache = now_diff(T1, T0),
+ ?line rpc:call(Node, code, rehash, []),
+ ?line {T2,T3} = rpc:call(Node, erlang, apply, [F, [N,code_cache_test]]),
+ ?line TCache = now_diff(T3, T2),
+ AvgNoCache = TNoCache/N,
+ AvgCache = TCache/N,
+ ?line io:format("Avg. load time (no_cache/cache): ~w/~w~n", [AvgNoCache,AvgCache]),
+ ?t:stop_node(Node),
+ if AvgNoCache =< AvgCache ->
+ ?t:fail("Cache not working properly.");
+ true ->
+ ok
+ end.
+
+load_loop(N, M) ->
+ load_loop(N, M, now()).
+load_loop(0, _M, T0) ->
+ {T0,now()};
+load_loop(N, M, T0) ->
+ code:load_file(M),
+ code:delete(M),
+ code:purge(M),
+ load_loop(N-1, M, T0).
+
+now_diff({A2, B2, C2}, {A1, B1, C1}) ->
+ ((A2-A1)*1000000 + B2-B1)*1000000 + C2-C1.
+
+start_node_with_cache(suite) ->
+ [];
+start_node_with_cache(doc) ->
+ [];
+start_node_with_cache(Config) when is_list(Config) ->
+ ?line {ok,Node} =
+ ?t:start_node(code_cache_node, peer, [{args,
+ "-code_path_cache"},
+ {erl, [this]}]),
+ ?line Tabs = rpc:call(Node, ets, all, []),
+ io:format("Tabs: ~w~n", [Tabs]),
+ CCTabCreated = fun(Tab) ->
+ case rpc:call(Node, ets, info, [Tab,name]) of
+ code_cache -> true;
+ _ -> false
+ end
+ end,
+ ?line true = lists:any(CCTabCreated, Tabs),
+ ?t:stop_node(Node),
+ ok.
+
+add_and_rehash(suite) ->
+ [];
+add_and_rehash(doc) ->
+ [];
+add_and_rehash(Config) when is_list(Config) ->
+ ?line Priv = ?config(priv_dir, Config),
+ ?line WD = filename:dirname(code:which(?MODULE)),
+ ?line {ok,Node} =
+ ?t:start_node(code_cache_node, peer, [{args,
+ "-pa " ++ WD},
+ {erl, [this]}]),
+ CCTabCreated = fun(Tab) ->
+ case ets:info(Tab, name) of
+ code_cache -> true;
+ _ -> false
+ end
+ end,
+ ?line Tabs0 = rpc:call(Node, ets, all, []),
+ case rpc:call(Node, lists, any, [CCTabCreated,Tabs0]) of
+ true ->
+ ?t:stop_node(Node),
+ ?t:fail("Code cache should not be active!");
+ false ->
+ ok
+ end,
+ ?line ok = rpc:call(Node, code, rehash, []), % create cache
+ ?line Tabs1 = rpc:call(Node, ets, all, []),
+ ?line true = rpc:call(Node, lists, any, [CCTabCreated,Tabs1]), % cache table created
+ ?line ok = rpc:call(Node, code, rehash, []),
+ OkDir = filename:join(Priv, ""),
+ BadDir = filename:join(Priv, "guggemuffsussiputt"),
+ ?line CP = [OkDir | rpc:call(Node, code, get_path, [])],
+ ?line true = rpc:call(Node, code, set_path, [CP]),
+ CP1 = [BadDir | CP],
+ ?line {error,_} = rpc:call(Node, code, set_path, [CP1]),
+ ?line true = rpc:call(Node, code, del_path, [OkDir]),
+ ?line true = rpc:call(Node, code, add_path, [OkDir]),
+ ?line true = rpc:call(Node, code, add_path, [OkDir]),
+ ?line {error,_} = rpc:call(Node, code, add_path, [BadDir]),
+ ?line ok = rpc:call(Node, code, rehash, []),
+ ok.
+
+where_is_file_no_cache(suite) ->
+ [];
+where_is_file_no_cache(doc) ->
+ [];
+where_is_file_no_cache(Config) when is_list(Config) ->
+ ?line {T,KernelBeamFile} = timer:tc(code, where_is_file, ["kernel.beam"]),
+ io:format("Load time: ~w ms~n", [T]),
+ ?line KernelEbinDir = filename:dirname(KernelBeamFile),
+ ?line AppFile = filename:join(KernelEbinDir, "kernel.app"),
+ ?line AppFile = code:where_is_file("kernel.app"),
+ ?line non_existing = code:where_is_file("kernel"), % no such file
+ ok.
+
+where_is_file_cached(suite) ->
+ [];
+where_is_file_cached(doc) ->
+ [];
+where_is_file_cached(Config) when is_list(Config) ->
+ ?line {ok,Node} =
+ ?t:start_node(code_cache_node, peer, [{args,
+ "-code_path_cache"},
+ {erl, [this]}]),
+ ?line Tabs = rpc:call(Node, ets, all, []),
+ io:format("Tabs: ~w~n", [Tabs]),
+ CCTabCreated = fun(Tab) ->
+ case rpc:call(Node, ets, info, [Tab,name]) of
+ code_cache -> true;
+ _ -> false
+ end
+ end,
+ ?line true = lists:any(CCTabCreated, Tabs),
+ ?line KernelBeamFile = rpc:call(Node, code, where_is_file, ["kernel.beam"]),
+ ?line {T,KernelBeamFile} = rpc:call(Node, timer, tc, [code,where_is_file,["kernel.beam"]]),
+ io:format("Load time: ~w ms~n", [T]),
+ ?line KernelEbinDir = rpc:call(Node, filename, dirname, [KernelBeamFile]),
+ ?line AppFile = rpc:call(Node, filename, join, [KernelEbinDir,"kernel.app"]),
+ ?line AppFile = rpc:call(Node, code, where_is_file, ["kernel.app"]),
+ ?line non_existing = rpc:call(Node, code, where_is_file, ["kernel"]), % no such file
+ ?t:stop_node(Node),
+ ok.
+
+
+purge_stacktrace(suite) ->
+ [];
+purge_stacktrace(doc) ->
+ ["Test that stacktrace is deleted when purging a referred module"];
+purge_stacktrace(Config) when is_list(Config) ->
+ ?line code:purge(code_b_test),
+ try code_b_test:call(fun(b) -> ok end, a)
+ catch
+ error:function_clause ->
+ ?line code:load_file(code_b_test),
+ ?line case erlang:get_stacktrace() of
+ [{?MODULE,_,[a]},
+ {code_b_test,call,2},
+ {?MODULE,purge_stacktrace,1}|_] ->
+ ?line false = code:purge(code_b_test),
+ ?line [] = erlang:get_stacktrace()
+ end
+ end,
+ try code_b_test:call(nofun, 2)
+ catch
+ error:function_clause ->
+ ?line code:load_file(code_b_test),
+ ?line case erlang:get_stacktrace() of
+ [{code_b_test,call,[nofun,2]},
+ {?MODULE,purge_stacktrace,1}|_] ->
+ ?line false = code:purge(code_b_test),
+ ?line [] = erlang:get_stacktrace()
+ end
+ end,
+ Args = [erlang,error,[badarg]],
+ try code_b_test:call(erlang, error, [badarg,Args])
+ catch
+ error:badarg ->
+ ?line code:load_file(code_b_test),
+ ?line case erlang:get_stacktrace() of
+ [{code_b_test,call,Args},
+ {?MODULE,purge_stacktrace,1}|_] ->
+ ?line false = code:purge(code_b_test),
+ ?line [] = erlang:get_stacktrace()
+ end
+ end,
+ ok.
+
+mult_lib_roots(Config) when is_list(Config) ->
+ ?line DataDir = filename:join(?config(data_dir, Config), "mult_lib_roots"),
+ ?line mult_lib_compile(DataDir, "my_dummy_app-b/ebin/lists"),
+ ?line mult_lib_compile(DataDir,
+ "my_dummy_app-c/ebin/code_SUITE_mult_root_module"),
+
+ %% Set up ERL_LIBS and start a slave node.
+ ErlLibs = filename:join(DataDir, first_root) ++ mult_lib_sep() ++
+ filename:join(DataDir, second_root),
+
+ ?line {ok,Node} =
+ ?t:start_node(mult_lib_roots, slave,
+ [{args,"-env ERL_LIBS "++ErlLibs}]),
+
+ ?line {ok,Cwd} = file:get_cwd(),
+ ?line Path0 = rpc:call(Node, code, get_path, []),
+ ?line [Cwd,"."|Path1] = Path0,
+ ?line [Kernel|Path2] = Path1,
+ ?line [Stdlib|Path3] = Path2,
+ ?line mult_lib_verify_lib(Kernel, "kernel"),
+ ?line mult_lib_verify_lib(Stdlib, "stdlib"),
+ ?line [Lib1,Lib2,Lib3,Lib4,Lib5|Path] = Path3,
+
+
+ ["first_root/my_dummy_app-a/ebin",
+ "first_root/my_dummy_app-b/ebin",
+ "first_root/my_dummy_app-c/ebin",
+ "second_root/my_dummy_app-d/ebin",
+ "second_root/my_dummy_app-e/ebin"] =
+ [mult_lib_remove_prefix(E, DataDir) ||
+ E <- lists:sort([Lib1,Lib2,Lib3,Lib4,Lib5])],
+ io:format("~p\n", [Path]),
+
+ ?line true = rpc:call(Node, code_SUITE_mult_root_module, works_fine, []),
+
+ ?line ?t:stop_node(Node),
+ ok.
+
+mult_lib_compile(Root, Last) ->
+ Mod = list_to_atom(filename:basename(Last)),
+ Name = filename:join([Root,"first_root",Last]),
+ Dir = filename:dirname(Name),
+ {ok,Mod} = compile:file(Name, [report,{outdir,Dir}]),
+ ok.
+
+mult_lib_sep() ->
+ case os:type() of
+ {win32,_} -> ";";
+ _ -> ":"
+ end.
+
+mult_lib_verify_lib(Path, Expected) ->
+ Dir = filename:basename(filename:dirname(Path)),
+ true = lists:prefix(Expected, Dir).
+
+mult_lib_remove_prefix([H|T1], [H|T2]) ->
+ mult_lib_remove_prefix(T1, T2);
+mult_lib_remove_prefix([$/|T], []) -> T.
+
+bad_erl_libs(Config) when is_list(Config) ->
+ ?line {ok,Node} =
+ ?t:start_node(mult_lib_roots, slave,
+ [{args,"-env ERL_LIBS "}]),
+
+ ?line ?t:stop_node(Node),
+
+ ?line {ok,Node2} =
+ ?t:start_node(mult_lib_roots, slave,
+ [{args,"-env ERL_LIBS /no/such/dir"}]),
+
+ ?line ?t:stop_node(Node2),
+ ok.
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+%% Create an archive file containing an application and make use of it.
+
+code_archive(Config) when is_list(Config) ->
+ do_code_archive(Config, "code_archive_libs", false).
+
+code_archive2(Config) when is_list(Config) ->
+ do_code_archive(Config, "code_archive_libs2", true).
+
+do_code_archive(Config, Root, StripVsn) when is_list(Config) ->
+ %% Copy the orig files to priv_dir
+ DataDir = ?config(data_dir, Config),
+ PrivDir = ?config(priv_dir, Config),
+ App = code_archive_dict,
+ VsnBase = atom_to_list(App) ++ "-1.0",
+ Base =
+ case StripVsn of
+ true -> atom_to_list(App);
+ false -> VsnBase
+ end,
+ Ext = init:archive_extension(),
+ RootDir = filename:join([PrivDir, Root]),
+ ?line ok = file:make_dir(RootDir),
+ Archive = filename:join([RootDir, VsnBase ++ Ext]),
+ ?line {ok, _} = zip:create(Archive, [VsnBase],
+ [{compress, []}, {cwd, DataDir}]),
+ ?line {ok, _} = zip:extract(Archive, [{cwd, PrivDir}]),
+
+ case StripVsn of
+ true ->
+ ?line ok = file:rename(filename:join([PrivDir, VsnBase]),
+ filename:join([PrivDir, Base]));
+ false ->
+ ok
+ end,
+
+ io:format("DEBUG: ~p\n", [?LINE]),
+ %% Compile the code
+ ?line ok = compile_app(PrivDir, Base),
+
+ %% Create the archive
+ ?line ok = file:delete(Archive),
+ ?line {ok, _} = zip:create(Archive, [Base],
+ [{compress, []}, {cwd, PrivDir}]),
+
+ %% Set up ERL_LIBS and start a slave node.
+ ?line {ok, Node} =
+ ?t:start_node(code_archive, slave,
+ [{args,"-env ERL_LIBS " ++ RootDir}]),
+ ?line CodePath = rpc:call(Node, code, get_path, []),
+ AppEbin = filename:join([Archive, Base, "ebin"]),
+ io:format("AppEbin: ~p\n", [AppEbin]),
+ io:format("CodePath: ~p\n", [CodePath]),
+ io:format("Archive: ~p\n", [erl_prim_loader:read_file_info(Archive)]),
+ ?line true = lists:member(AppEbin, CodePath),
+
+ %% Start the app
+ ?line ok = rpc:call(Node, application, start, [App]),
+
+ %% Access the app priv dir
+ AppPrivDir = rpc:call(Node, code, priv_dir, [App]),
+ ?line AppPrivFile = filename:join([AppPrivDir, "code_archive.txt"]),
+ io:format("AppPrivFile: ~p\n", [AppPrivFile]),
+ ?line {ok, _Bin, _Path} =
+ rpc:call(Node, erl_prim_loader, get_file, [AppPrivFile]),
+
+ %% Use the app
+ Tab = code_archive_tab,
+ Key = foo,
+ Val = bar,
+ {ok, _Pid} = rpc:call(Node, App, new, [Tab]),
+ error = rpc:call(Node, App, find, [Tab, Key]),
+ ok = rpc:call(Node, App, store, [Tab, Key, Val]),
+ {ok, Val} = rpc:call(Node, App, find, [Tab, Key]),
+ ok = rpc:call(Node, App, erase, [Tab, Key]),
+ error = rpc:call(Node, App, find, [Tab, Key]),
+ ok = rpc:call(Node, App, erase, [Tab]),
+
+ ?line ?t:stop_node(Node),
+ ok.
+
+compile_app(TopDir, AppName) ->
+ AppDir = filename:join([TopDir, AppName]),
+ SrcDir = filename:join([AppDir, "src"]),
+ OutDir = filename:join([AppDir, "ebin"]),
+ ?line {ok, Files} = file:list_dir(SrcDir),
+ compile_files(Files, SrcDir, OutDir).
+
+compile_files([File | Files], SrcDir, OutDir) ->
+ case filename:extension(File) of
+ ".erl" ->
+ AbsFile = filename:join([SrcDir, File]),
+ case compile:file(AbsFile, [{outdir, OutDir}]) of
+ {ok, _Mod} ->
+ compile_files(Files, SrcDir, OutDir);
+ Error ->
+ {compilation_error, AbsFile, OutDir, Error}
+ end;
+ _ ->
+ compile_files(Files, SrcDir, OutDir)
+ end;
+compile_files([], _, _) ->
+ ok.
+
+on_load(Config) when is_list(Config) ->
+ Master = on_load_test_case_process,
+
+ ?line Data = filename:join([?config(data_dir, Config),"on_load"]),
+ ?line ok = file:set_cwd(Data),
+ ?line up_to_date = make:all([{d,'MASTER',Master}]),
+
+ %% Register a name for this process.
+ ?line register(Master, self()),
+
+ ?line {_,Ref} = spawn_monitor(fun() ->
+ exit(on_load_a:data())
+ end),
+ receive
+ {on_load_a,start} -> ok
+ end,
+ receive
+ {on_load_b,start} -> ok
+ end,
+ receive
+ {on_load_c,PidC} -> ok
+ end,
+
+ ?line Refs = on_load_massive_spawn(lists:seq(1, 50)),
+ receive after 7 -> ok end,
+
+ PidC ! go,
+
+ KernelLibDir = code:lib_dir(kernel),
+ receive
+ {on_load_c,done} -> ok
+ end,
+ receive
+ {on_load_b,done} -> ok
+ end,
+ receive
+ {on_load_a,KernelLibDir} -> ok
+ end,
+
+ receive
+ {'DOWN',Ref,process,_,Res} ->
+ ?line [a,b,c] = Res
+ end,
+
+ on_load_wait_for_all(Refs),
+ receive
+ Any ->
+ ?line ?t:fail({unexpected,Any})
+ after 10 ->
+ ok
+ end.
+
+on_load_massive_spawn([_|T]) ->
+ {_,Ra} = spawn_monitor(fun() -> [a,b,c] = on_load_a:data() end),
+ {_,Rb} = spawn_monitor(fun() -> [b,c] = on_load_b:data() end),
+ {_,Rc} = spawn_monitor(fun() -> [c] = on_load_c:data() end),
+ [Ra,Rb,Rc|on_load_massive_spawn(T)];
+on_load_massive_spawn([]) -> [].
+
+on_load_wait_for_all([Ref|T]) ->
+ receive
+ {'DOWN',Ref,process,_,normal} ->
+ on_load_wait_for_all(T)
+ end;
+on_load_wait_for_all([]) -> ok.
+
+on_load_embedded(Config) when is_list(Config) ->
+ try
+ on_load_embedded_1(Config)
+ catch
+ throw:{skip,_}=Skip ->
+ Skip
+ end.
+
+on_load_embedded_1(Config) ->
+ ?line DataDir = ?config(data_dir, Config),
+
+ %% Link the on_load_app application into the lib directory.
+ ?line LibRoot = code:lib_dir(),
+ ?line LinkName = filename:join(LibRoot, "on_load_app-1.0"),
+ ?line OnLoadApp = filename:join(DataDir, "on_load_app-1.0"),
+ ?line file:delete(LinkName),
+ case file:make_symlink(OnLoadApp, LinkName) of
+ {error,enotsup} ->
+ throw({skip,"Support for symlinks required"});
+ ok -> ok
+ end,
+
+ %% Compile the code.
+ ?line OnLoadAppEbin = filename:join(LinkName, "ebin"),
+ ?line {ok,_ } = compile:file(filename:join([OnLoadApp,"src",
+ "on_load_embedded"]),
+ [{outdir,OnLoadAppEbin}]),
+
+ %% Create and compile a boot file.
+ ?line true = code:add_pathz(OnLoadAppEbin),
+ Options = case is_source_dir() of
+ true -> [local];
+ false -> []
+ end,
+ ?line BootScript = create_boot(Config, Options),
+ ?line true = code:del_path(OnLoadAppEbin),
+
+ %% Start the node and check that the on_load function was run.
+ ?line {ok,Node} = start_node(on_load_embedded,
+ "-mode embedded -boot " ++ BootScript),
+ ok = rpc:call(Node, on_load_embedded, status, []),
+
+ %% Clean up.
+ ?line stop_node(Node),
+ ?line ok = file:delete(LinkName).
+
+create_boot(Config, Options) ->
+ ?line {ok, OldDir} = file:get_cwd(),
+ ?line {LatestDir,LatestName} = create_script(Config),
+ ?line ok = file:set_cwd(LatestDir),
+ ?line ok = systools:make_script(LatestName, Options),
+ ?line ok = file:set_cwd(OldDir),
+ filename:join(LatestDir, LatestName).
+
+create_script(Config) ->
+ ?line PrivDir = ?config(priv_dir, Config),
+ ?line Name = PrivDir ++ "on_load_test",
+ ?line Apps = application_controller:which_applications(),
+ ?line {value,{_,_,KernelVer}} = lists:keysearch(kernel, 1, Apps),
+ ?line {value,{_,_,StdlibVer}} = lists:keysearch(stdlib, 1, Apps),
+ ?line {ok,Fd} = file:open(Name ++ ".rel", write),
+ ?line io:format(Fd,
+ "{release, {\"Test release 3\", \"P2A\"}, \n"
+ " {erts, \"9.42\"}, \n"
+ " [{kernel, \"~s\"}, {stdlib, \"~s\"},"
+ " {on_load_app, \"1.0\"}]}.\n",
+ [KernelVer,StdlibVer]),
+ ?line file:close(Fd),
+ {filename:dirname(Name),filename:basename(Name)}.
+
+is_source_dir() ->
+ filename:basename(code:lib_dir(kernel)) =:= "kernel" andalso
+ filename:basename(code:lib_dir(stdlib)) =:= "stdlib".
+
+start_node(Name, Param) ->
+ ?t:start_node(Name, slave, [{args, Param}]).
+
+stop_node(Node) ->
+ ?t:stop_node(Node).