aboutsummaryrefslogtreecommitdiffstats
path: root/erts/emulator/test/trace_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 /erts/emulator/test/trace_SUITE.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'erts/emulator/test/trace_SUITE.erl')
-rw-r--r--erts/emulator/test/trace_SUITE.erl1496
1 files changed, 1496 insertions, 0 deletions
diff --git a/erts/emulator/test/trace_SUITE.erl b/erts/emulator/test/trace_SUITE.erl
new file mode 100644
index 0000000000..2c60ba6838
--- /dev/null
+++ b/erts/emulator/test/trace_SUITE.erl
@@ -0,0 +1,1496 @@
+%%
+%% %CopyrightBegin%
+%%
+%% Copyright Ericsson AB 1997-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(trace_SUITE).
+
+%%%
+%%% Tests the trace BIF.
+%%%
+
+-export([all/1, receive_trace/1, self_send/1,
+ timeout_trace/1, send_trace/1,
+ procs_trace/1, dist_procs_trace/1,
+ suspend/1, mutual_suspend/1, suspend_exit/1, suspender_exit/1,
+ suspend_system_limit/1, suspend_opts/1, suspend_waiting/1,
+ new_clear/1, existing_clear/1,
+ set_on_spawn/1, set_on_first_spawn/1, cpu_timestamp/1,
+ system_monitor_args/1, more_system_monitor_args/1,
+ system_monitor_long_gc_1/1, system_monitor_long_gc_2/1,
+ system_monitor_large_heap_1/1, system_monitor_large_heap_2/1,
+ bad_flag/1, trace_delivered/1]).
+
+-include("test_server.hrl").
+
+%%% Internal exports
+-export([process/1]).
+
+all(suite) ->
+ [cpu_timestamp, receive_trace, self_send, timeout_trace, send_trace,
+ procs_trace, dist_procs_trace,
+ suspend, mutual_suspend, suspend_exit, suspender_exit,
+ suspend_system_limit, suspend_opts, suspend_waiting,
+ new_clear, existing_clear,
+ set_on_spawn, set_on_first_spawn,
+ system_monitor_args, more_system_monitor_args,
+ system_monitor_long_gc_1, system_monitor_long_gc_2,
+ system_monitor_large_heap_1, system_monitor_large_heap_2,
+ bad_flag, trace_delivered].
+
+
+%% No longer testing anything, just reporting whether cpu_timestamp
+%% is enabled or not.
+cpu_timestamp(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+
+ %% Test whether cpu_timestamp is implemented on this platform.
+ ?line Works = try erlang:trace(all, true, [cpu_timestamp]) of
+ _ ->
+ ?line erlang:trace(all, false, [cpu_timestamp]),
+ true
+ catch
+ error:badarg -> false
+ end,
+
+ ?line test_server:timetrap_cancel(Dog),
+ {comment,case Works of
+ false -> "cpu_timestamp is NOT implemented/does not work";
+ true -> "cpu_timestamp works"
+ end}.
+
+
+%% Tests that trace(Pid, How, ['receive']) works.
+
+receive_trace(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Receiver = fun_spawn(fun receiver/0),
+ ?line process_flag(trap_exit, true),
+
+ %% Trace the process; make sure that we receive the trace messages.
+ ?line 1 = erlang:trace(Receiver, true, ['receive']),
+ ?line Hello = {hello, world},
+ ?line Receiver ! Hello,
+ ?line {trace, Receiver, 'receive', Hello} = receive_first(),
+ ?line Hello2 = {hello, again, world},
+ ?line Receiver ! Hello2,
+ ?line {trace, Receiver, 'receive', Hello2} = receive_first(),
+ ?line receive_nothing(),
+
+ %% Another process should not be able to trace Receiver.
+ ?line Intruder = fun_spawn(fun() -> erlang:trace(Receiver, true, ['receive']) end),
+ ?line {'EXIT', Intruder, {badarg, _}} = receive_first(),
+
+ %% Untrace the process; we should not receive anything.
+ ?line 1 = erlang:trace(Receiver, false, ['receive']),
+ ?line Receiver ! {hello, there},
+ ?line Receiver ! any_garbage,
+ ?line receive_nothing(),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+self_send(doc) -> ["Test that traces are generated for messages sent ",
+ "and received to/from self()."];
+self_send(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Fun =
+ fun(Self, Parent) -> receive
+ go_ahead ->
+ self() ! from_myself,
+ Self(Self, Parent);
+ from_myself ->
+ Parent ! done
+ end
+ end,
+ ?line Self = self(),
+ ?line SelfSender = fun_spawn(Fun, [Fun, Self]),
+ ?line erlang:trace(SelfSender, true, ['receive', 'send']),
+ ?line SelfSender ! go_ahead,
+ ?line receive {trace, SelfSender, 'receive', go_ahead} -> ok end,
+ ?line receive {trace, SelfSender, 'receive', from_myself} -> ok end,
+ ?line receive
+ {trace,SelfSender,send,from_myself,SelfSender} -> ok
+ end,
+ ?line receive {trace,SelfSender,send,done,Self} -> ok end,
+ ?line receive done -> ok end,
+
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+%% Test that we can receive timeout traces.
+timeout_trace(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+
+ ?line Process = fun_spawn(fun process/0),
+ ?line 1 = erlang:trace(Process, true, ['receive']),
+ ?line Process ! timeout_please,
+ ?line {trace, Process, 'receive', timeout_please} = receive_first(),
+ ?line {trace, Process, 'receive', timeout} = receive_first(),
+ ?line receive_nothing(),
+
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+%% Tests that trace(Pid, How, [send]) works.
+
+send_trace(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line process_flag(trap_exit, true),
+ ?line Sender = fun_spawn(fun sender/0),
+ ?line Receiver = fun_spawn(fun receiver/0),
+
+ %% Check that a message sent to another process is traced.
+ ?line 1 = erlang:trace(Sender, true, [send]),
+ ?line Sender ! {send_please, Receiver, to_receiver},
+ ?line {trace, Sender, send, to_receiver, Receiver} = receive_first(),
+ ?line receive_nothing(),
+
+ %% Check that a message sent to this process is traced.
+ ?line Sender ! {send_please, self(), to_myself},
+ ?line receive to_myself -> ok end,
+ ?line Self = self(),
+ ?line {trace, Sender, send, to_myself, Self} = receive_first(),
+ ?line receive_nothing(),
+
+ %% Another process should not be able to trace Sender.
+ ?line Intruder = fun_spawn(fun() -> erlang:trace(Sender, true, [send]) end),
+ ?line {'EXIT', Intruder, {badarg, _}} = receive_first(),
+
+ %% Untrace the sender process and make sure that we receive no more
+ %% trace messages.
+ ?line 1 = erlang:trace(Sender, false, [send]),
+ ?line Sender ! {send_please, Receiver, to_receiver},
+ ?line Sender ! {send_please, self(), to_myself_again},
+ ?line receive to_myself_again -> ok end,
+ ?line receive_nothing(),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+%% Test trace(Pid, How, [procs]).
+procs_trace(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Name = list_to_atom(atom_to_list(?MODULE)++"_procs_trace"),
+ ?line Self = self(),
+ ?line process_flag(trap_exit, true),
+ %%
+ ?line Proc1 = spawn_link(?MODULE, process, [Self]),
+ ?line io:format("Proc1 = ~p ~n", [Proc1]),
+ ?line Proc2 = spawn(?MODULE, process, [Self]),
+ ?line io:format("Proc2 = ~p ~n", [Proc2]),
+ %%
+ ?line 1 = erlang:trace(Proc1, true, [procs]),
+ ?line MFA = {?MODULE, process, [Self]},
+ %%
+ %% spawn, link
+ ?line Proc1 ! {spawn_link_please, Self, MFA},
+ ?line Proc3 = receive {spawned, Proc1, P3} -> P3 end,
+ ?line {trace, Proc1, spawn, Proc3, MFA} = receive_first(),
+ ?line io:format("Proc3 = ~p ~n", [Proc3]),
+ ?line {trace, Proc1, link, Proc3} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% getting_unlinked by exit()
+ ?line Proc1 ! {trap_exit_please, true},
+ ?line Reason3 = make_ref(),
+ ?line Proc1 ! {send_please, Proc3, {exit_please, Reason3}},
+ ?line receive {Proc1, {'EXIT', Proc3, Reason3}} -> ok end,
+ ?line {trace, Proc1, getting_unlinked, Proc3} = receive_first(),
+ ?line Proc1 ! {trap_exit_please, false},
+ ?line receive_nothing(),
+ %%
+ %% link
+ ?line Proc1 ! {link_please, Proc2},
+ ?line {trace, Proc1, link, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% unlink
+ ?line Proc1 ! {unlink_please, Proc2},
+ ?line {trace, Proc1, unlink, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% getting_linked
+ ?line Proc2 ! {link_please, Proc1},
+ ?line {trace, Proc1, getting_linked, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% getting_unlinked
+ ?line Proc2 ! {unlink_please, Proc1},
+ ?line {trace, Proc1, getting_unlinked, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% register
+ ?line true = register(Name, Proc1),
+ ?line {trace, Proc1, register, Name} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% unregister
+ ?line true = unregister(Name),
+ ?line {trace, Proc1, unregister, Name} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% exit (with registered name, due to link)
+ ?line Reason4 = make_ref(),
+ ?line Proc1 ! {spawn_link_please, Self, MFA},
+ ?line Proc4 = receive {spawned, Proc1, P4} -> P4 end,
+ ?line {trace, Proc1, spawn, Proc4, MFA} = receive_first(),
+ ?line io:format("Proc4 = ~p ~n", [Proc4]),
+ ?line {trace, Proc1, link, Proc4} = receive_first(),
+ ?line Proc1 ! {register_please, Name, Proc1},
+ ?line {trace, Proc1, register, Name} = receive_first(),
+ ?line Proc4 ! {exit_please, Reason4},
+ ?line receive {'EXIT', Proc1, Reason4} -> ok end,
+ ?line {trace, Proc1, exit, Reason4} = receive_first(),
+ ?line {trace, Proc1, unregister, Name} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% exit (not linked to tracing process)
+ ?line 1 = erlang:trace(Proc2, true, [procs]),
+ ?line Reason2 = make_ref(),
+ ?line Proc2 ! {exit_please, Reason2},
+ ?line {trace, Proc2, exit, Reason2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+
+dist_procs_trace(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(15)),
+ ?line OtherName = atom_to_list(?MODULE)++"_dist_procs_trace",
+ ?line {ok, OtherNode} = start_node(OtherName),
+ ?line Self = self(),
+ ?line process_flag(trap_exit, true),
+ %%
+ ?line Proc1 = spawn_link(?MODULE, process, [Self]),
+ ?line io:format("Proc1 = ~p ~n", [Proc1]),
+ ?line Proc2 = spawn(OtherNode, ?MODULE, process, [Self]),
+ ?line io:format("Proc2 = ~p ~n", [Proc2]),
+ %%
+ ?line 1 = erlang:trace(Proc1, true, [procs]),
+ ?line MFA = {?MODULE, process, [Self]},
+ %%
+ %% getting_unlinked by exit()
+ ?line Proc1 ! {spawn_link_please, Self, OtherNode, MFA},
+ ?line Proc1 ! {trap_exit_please, true},
+ ?line Proc3 = receive {spawned, Proc1, P3} -> P3 end,
+ ?line io:format("Proc3 = ~p ~n", [Proc3]),
+ ?line {trace, Proc1, getting_linked, Proc3} = receive_first(),
+ ?line Reason3 = make_ref(),
+ ?line Proc1 ! {send_please, Proc3, {exit_please, Reason3}},
+ ?line receive {Proc1, {'EXIT', Proc3, Reason3}} -> ok end,
+ ?line {trace, Proc1, getting_unlinked, Proc3} = receive_first(),
+ ?line Proc1 ! {trap_exit_please, false},
+ ?line receive_nothing(),
+ %%
+ %% link
+ ?line Proc1 ! {link_please, Proc2},
+ ?line {trace, Proc1, link, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% unlink
+ ?line Proc1 ! {unlink_please, Proc2},
+ ?line {trace, Proc1, unlink, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% getting_linked
+ ?line Proc2 ! {link_please, Proc1},
+ ?line {trace, Proc1, getting_linked, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% getting_unlinked
+ ?line Proc2 ! {unlink_please, Proc1},
+ ?line {trace, Proc1, getting_unlinked, Proc2} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% exit (with registered name, due to link)
+ ?line Name = list_to_atom(OtherName),
+ ?line Reason2 = make_ref(),
+ ?line Proc1 ! {link_please, Proc2},
+ ?line {trace, Proc1, link, Proc2} = receive_first(),
+ ?line Proc1 ! {register_please, Name, Proc1},
+ ?line {trace, Proc1, register, Name} = receive_first(),
+ ?line Proc2 ! {exit_please, Reason2},
+ ?line receive {'EXIT', Proc1, Reason2} -> ok end,
+ ?line {trace, Proc1, exit, Reason2} = receive_first(),
+ ?line {trace, Proc1, unregister, Name} = receive_first(),
+ ?line receive_nothing(),
+ %%
+ %% Done.
+ ?line true = stop_node(OtherNode),
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+
+
+
+%% Tests trace(Pid, How, [set_on_spawn]).
+
+set_on_spawn(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Listener = fun_spawn(fun process/0),
+
+ %% Create and trace a process with the set_on_spawn flag.
+ %% Make sure it is traced.
+ ?line Father_SOS = fun_spawn(fun process/0),
+ ?line 1 = erlang:trace(Father_SOS, true, [send, set_on_spawn]),
+ ?line true = is_send_traced(Father_SOS, Listener, sos_father),
+
+ %% Have the process spawn of two children and test that they
+ %% are traced.
+ ?line [Child1, Child2] = spawn_children(Father_SOS, 2),
+ ?line true = is_send_traced(Child1, Listener, child1),
+ ?line true = is_send_traced(Child2, Listener, child2),
+
+ %% Second generation.
+ [Child11, Child12] = spawn_children(Child1, 2),
+ ?line true = is_send_traced(Child11, Listener, child11),
+ ?line true = is_send_traced(Child12, Listener, child12),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+%% Tests trace(Pid, How, [set_on_first_spawn]).
+
+set_on_first_spawn(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(10)),
+ ?line Listener = fun_spawn(fun process/0),
+
+ %% Create and trace a process with the set_on_first_spawn flag.
+ %% Make sure it is traced.
+ ?line Parent = fun_spawn(fun process/0),
+ ?line 1 = erlang:trace(Parent, true, [send, set_on_first_spawn]),
+ ?line is_send_traced(Parent, Listener, sos_father),
+
+ %% Have the process spawn off three children and test that the
+ %% first is traced.
+ ?line [Child1, Child2, Child3] = spawn_children(Parent, 3),
+ ?line true = is_send_traced(Child1, Listener, child1),
+ ?line false = is_send_traced(Child2, Listener, child2),
+ ?line false = is_send_traced(Child3, Listener, child3),
+ ?line receive_nothing(),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+
+system_monitor_args(doc) ->
+ ["Tests arguments to erlang:system_monitor/0-2)"];
+system_monitor_args(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Self = self(),
+ %%
+ ?line OldMonitor = erlang:system_monitor(undefined),
+ ?line undefined = erlang:system_monitor(Self, [{long_gc,0}]),
+ ?line MinT = case erlang:system_monitor() of
+ {Self,[{long_gc,T}]} when is_integer(T), T > 0 -> T;
+ Other1 -> test_server:fault(Other1)
+ end,
+ ?line {Self,[{long_gc,MinT}]} = erlang:system_monitor(),
+ ?line {Self,[{long_gc,MinT}]} =
+ erlang:system_monitor({Self,[{large_heap,0}]}),
+ ?line MinN = case erlang:system_monitor() of
+ {Self,[{large_heap,N}]} when is_integer(N), N > 0 -> N;
+ Other2 -> test_server:fault(Other2)
+ end,
+ ?line {Self,[{large_heap,MinN}]} = erlang:system_monitor(),
+ ?line {Self,[{large_heap,MinN}]} =
+ erlang:system_monitor(Self, [busy_port]),
+ ?line {Self,[busy_port]} = erlang:system_monitor(),
+ ?line {Self,[busy_port]} =
+ erlang:system_monitor({Self,[busy_dist_port]}),
+ ?line {Self,[busy_dist_port]} = erlang:system_monitor(),
+ ?line All = lists:sort([busy_port,busy_dist_port,
+ {long_gc,1},{large_heap,65535}]),
+ ?line {Self,[busy_dist_port]} = erlang:system_monitor(Self, All),
+ ?line {Self,A1} = erlang:system_monitor(),
+ ?line All = lists:sort(A1),
+ ?line {Self,A1} = erlang:system_monitor(Self, []),
+ ?line Pid = spawn(fun () -> receive {Self,die} -> exit(die) end end),
+ ?line Mref = erlang:monitor(process, Pid),
+ ?line undefined = erlang:system_monitor(Pid, All),
+ ?line {Pid,A2} = erlang:system_monitor(),
+ ?line All = lists:sort(A2),
+ ?line Pid ! {Self,die},
+ ?line receive {'DOWN',Mref,_,_,_} -> ok end,
+ ?line undefined = erlang:system_monitor(OldMonitor),
+ ?line erlang:yield(),
+ ?line OldMonitor = erlang:system_monitor(),
+ %%
+ ?line {'EXIT',{badarg,_}} = (catch erlang:system_monitor(atom)),
+ ?line {'EXIT',{badarg,_}} = (catch erlang:system_monitor({})),
+ ?line {'EXIT',{badarg,_}} = (catch erlang:system_monitor({1})),
+ ?line {'EXIT',{badarg,_}} = (catch erlang:system_monitor({1,2,3})),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor({Self,atom})),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor(atom, atom)),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor({Self,[busy_port|busy_dist_port]})),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor(Self, [{long_gc,-1}])),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor({Self,[{long_gc,atom}]})),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor(Self,[{large_heap,-1}])),
+ ?line {'EXIT',{badarg,_}} =
+ (catch erlang:system_monitor({Self,[{large_heap,atom}]})),
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+
+more_system_monitor_args(doc) ->
+ ["Tests arguments to erlang:system_monitor/0-2)"];
+more_system_monitor_args(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+
+ ?line try_l(64000),
+ ?line try_l(16#7ffffff),
+ ?line try_l(16#3fffffff),
+ ?line try_l(16#7fffffff),
+ ?line try_l(16#ffffffff),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+try_l(Val) ->
+ Self = self(),
+ Arbitrary1 = 77777,
+ Arbitrary2 = 88888,
+
+ ?line erlang:system_monitor(undefined),
+
+ ?line undefined = erlang:system_monitor(Self, [{long_gc,Val},{large_heap,Arbitrary1}]),
+
+ ?line {Self,Comb0} = erlang:system_monitor(Self, [{long_gc,Arbitrary2},{large_heap,Val}]),
+ ?line [{large_heap,Arbitrary1},{long_gc,Val}] = lists:sort(Comb0),
+
+ ?line {Self,Comb1} = erlang:system_monitor(undefined),
+ ?line [{large_heap,Val},{long_gc,Arbitrary2}] = lists:sort(Comb1).
+
+-define(LONG_GC_SLEEP, 670).
+
+system_monitor_long_gc_1(suite) ->
+ [];
+system_monitor_long_gc_1(doc) ->
+ ["Tests erlang:system_monitor(Pid, [{long_gc,Time}])"];
+system_monitor_long_gc_1(Config) when is_list(Config) ->
+ erts_debug:set_internal_state(available_internal_state, true),
+ try
+ %% Add ?LONG_GC_SLEEP ms to all gc
+ ?line erts_debug:set_internal_state(test_long_gc_sleep,
+ ?LONG_GC_SLEEP),
+ ?line LoadFun =
+ fun () ->
+ garbage_collect(),
+ self()
+ end,
+ ?line long_gc(LoadFun, false)
+ after
+ erts_debug:set_internal_state(test_long_gc_sleep, 0),
+ erts_debug:set_internal_state(available_internal_state, false)
+ end.
+
+system_monitor_long_gc_2(suite) ->
+ [];
+system_monitor_long_gc_2(doc) ->
+ ["Tests erlang:system_monitor(Pid, [{long_gc,Time}])"];
+system_monitor_long_gc_2(Config) when is_list(Config) ->
+ erts_debug:set_internal_state(available_internal_state, true),
+ try
+ %% Add ?LONG_GC_SLEEP ms to all gc
+ ?line erts_debug:set_internal_state(test_long_gc_sleep,
+ ?LONG_GC_SLEEP),
+ ?line Parent = self(),
+ ?line LoadFun =
+ fun () ->
+ Ref = make_ref(),
+ Pid =
+ spawn_link(
+ fun () ->
+ garbage_collect(),
+ Parent ! {Ref, self()}
+ end),
+ receive {Ref, Pid} -> Pid end
+ end,
+ ?line long_gc(LoadFun, true),
+ ?line long_gc(LoadFun, true),
+ ?line long_gc(LoadFun, true)
+ after
+ erts_debug:set_internal_state(test_long_gc_sleep, 0),
+ erts_debug:set_internal_state(available_internal_state, false)
+ end.
+
+long_gc(LoadFun, ExpectMonMsg) ->
+ ?line Self = self(),
+ ?line Time = 1,
+ ?line OldMonitor = erlang:system_monitor(Self, [{long_gc,Time}]),
+ ?line Pid = LoadFun(),
+ ?line Ref = erlang:trace_delivered(Pid),
+ ?line receive {trace_delivered, Pid, Ref} -> ok end,
+ ?line {Self,[{long_gc,Time}]} = erlang:system_monitor(OldMonitor),
+ ?line case {long_gc_check(Pid, Time, undefined), ExpectMonMsg} of
+ {ok, true} when Pid =/= Self ->
+ ok;
+ {ok, false} ->
+ ?line ?t:fail(unexpected_system_monitor_message_received);
+ {undefined, false} ->
+ ok;
+ {undefined, true} ->
+ ?line ?t:fail(no_system_monitor_message_received)
+ end.
+
+long_gc_check(Pid, Time, Result) ->
+ receive
+ {monitor,Pid,long_gc,L} = Monitor ->
+ case lists:foldl(
+ fun (_, error) ->
+ error;
+ ({timeout,T}, N) when is_integer(T),
+ Time =< T, T =< 10*?LONG_GC_SLEEP ->
+ %% OTP-7622. The time T must be within reasonable limits
+ %% for the test to pass.
+ N-1;
+ ({heap_size,_}, N) ->
+ N-1;
+ ({old_heap_size,_}, N) ->
+ N-1;
+ ({stack_size,_}, N) ->
+ N-1;
+ ({mbuf_size,_}, N) ->
+ N-1;
+ ({heap_block_size,_}, N) ->
+ N-1;
+ ({old_heap_block_size,_}, N) ->
+ N-1;
+ (_, _) ->
+ error
+ end, 7, L) of
+ 0 ->
+ long_gc_check(Pid, Time, ok);
+ error ->
+ {error,Monitor}
+ end;
+ {monitor,_,long_gc,_} ->
+ long_gc_check(Pid, Time, Result);
+ Other ->
+ {error,Other}
+ after 0 ->
+ Result
+ end.
+
+system_monitor_large_heap_1(suite) ->
+ [];
+system_monitor_large_heap_1(doc) ->
+ ["Tests erlang:system_monitor(Pid, [{large_heap,Size}])"];
+system_monitor_large_heap_1(Config) when is_list(Config) ->
+ ?line LoadFun =
+ fun (Size) ->
+ List = seq(1,2*Size),
+ garbage_collect(),
+ true = lists:prefix([1], List),
+ self()
+ end,
+ ?line large_heap(LoadFun, false).
+
+system_monitor_large_heap_2(suite) ->
+ [];
+system_monitor_large_heap_2(doc) ->
+ ["Tests erlang:system_monitor(Pid, [{large_heap,Size}])"];
+system_monitor_large_heap_2(Config) when is_list(Config) ->
+ ?line Parent = self(),
+ ?line LoadFun =
+ fun (Size) ->
+ Ref = make_ref(),
+ Pid =
+ spawn_opt(fun () ->
+ garbage_collect(),
+ Parent ! {Ref, self()}
+ end,
+ [link, {min_heap_size, 2*Size}]),
+ receive {Ref, Pid} -> Pid end
+ end,
+ ?line large_heap(LoadFun, true).
+
+large_heap(LoadFun, ExpectMonMsg) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(20)),
+ %%
+ ?line Size = 65535,
+ ?line Self = self(),
+ ?line NewMonitor = {Self,[{large_heap,Size}]},
+ ?line OldMonitor = erlang:system_monitor(NewMonitor),
+ ?line Pid = LoadFun(Size),
+ ?line Ref = erlang:trace_delivered(Pid),
+ ?line receive {trace_delivered, Pid, Ref} -> ok end,
+ ?line {Self,[{large_heap,Size}]} = erlang:system_monitor(OldMonitor),
+ ?line case {large_heap_check(Pid, Size, undefined), ExpectMonMsg} of
+ {ok, true} when Pid =/= Self ->
+ ?line ok;
+ {ok, false} ->
+ ?line ?t:fail(unexpected_system_monitor_message_received);
+ {undefined, false} ->
+ ?line ok;
+ {undefined, true} ->
+ ?line ?t:fail(no_system_monitor_message_received)
+ end,
+ %%
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+large_heap_check(Pid, Size, Result) ->
+ receive
+ {monitor,Pid,large_heap,L} = Monitor ->
+ case lists:foldl(
+ fun (_, error) ->
+ error;
+ ({heap_size,_}, N) ->
+ N-1;
+ ({old_heap_size,_}, N) ->
+ N-1;
+ ({stack_size,_}, N) ->
+ N-1;
+ ({mbuf_size,_}, N) ->
+ N-1;
+ ({heap_block_size,_}, N) ->
+ N-1;
+ ({old_heap_block_size,_}, N) ->
+ N-1;
+ (_, _) ->
+ error
+ end, 6, L) of
+ 0 ->
+ large_heap_check(Pid, Size, ok);
+ error ->
+ {error,Monitor}
+ end;
+ {monitor,_,large_heap,_} ->
+ large_heap_check(Pid, Size, Result);
+ Other ->
+ {error,Other}
+ after 0 ->
+ Result
+ end.
+
+seq(N, M) ->
+ seq(N, M, []).
+
+seq(M, M, R) ->
+ lists:reverse(R);
+seq(N, M, R) ->
+ seq(N+1, M, [N|R]).
+
+
+is_send_traced(Pid, Listener, Msg) ->
+ Pid ! {send_please, Listener, Msg},
+ receive
+ Any ->
+ {trace, Pid, send, Msg, Listener} = Any,
+ true
+ after 1000 ->
+ false
+ end.
+
+%% This procedure assumes that the Parent process is send traced.
+
+spawn_children(Parent, Number) ->
+ spawn_children(Parent, Number, []).
+
+spawn_children(_Parent, 0, Result) ->
+ lists:reverse(Result);
+spawn_children(Parent, Number, Result) ->
+ Self = self(),
+ Parent ! {spawn_please, Self, fun process/0},
+ Child =
+ receive
+ {trace, Parent, send, {spawned, Pid}, Self} -> Pid
+ end,
+ receive
+ {spawned, Child} ->
+ spawn_children(Parent, Number-1, [Child|Result])
+ end.
+
+suspend(doc) -> "Test erlang:suspend/1 and erlang:resume/1.";
+suspend(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:minutes(2)),
+
+ ?line Worker = fun_spawn(fun worker/0),
+ %% Suspend a process and test that it is suspended.
+ ?line ok = do_suspend(Worker, 10000),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+do_suspend(_Pid, 0) ->
+ ?line ok;
+do_suspend(Pid, N) ->
+ %% Suspend a process and test that it is suspended.
+ ?line true = erlang:suspend_process(Pid),
+ ?line {status, suspended} = process_info(Pid, status),
+
+ %% Unsuspend the process and make sure it starts working.
+ ?line true = erlang:resume_process(Pid),
+ ?line case process_info(Pid, status) of
+ {status, runnable} -> ?line ok;
+ {status, running} -> ?line ok;
+ {status, garbage_collecting} -> ?line ok;
+ ST -> ?line ?t:fail(ST)
+ end,
+ ?line erlang:yield(),
+ ?line do_suspend(Pid, N-1).
+
+
+
+mutual_suspend(doc) ->
+ [];
+mutual_suspend(suite) ->
+ [];
+mutual_suspend(Config) when is_list(Config) ->
+ ?line TimeoutSecs = 5*60,
+ ?line Dog = test_server:timetrap(test_server:minutes(TimeoutSecs)),
+ ?line Parent = self(),
+ ?line Fun = fun () ->
+ receive
+ {go, Pid} ->
+ do_mutual_suspend(Pid, 100000)
+ end,
+ Parent ! {done, self()},
+ receive after infinity -> ok end
+ end,
+ ?line P1 = spawn_link(Fun),
+ ?line P2 = spawn_link(Fun),
+ ?line T1 = erlang:start_timer((TimeoutSecs - 5)*1000, self(), oops),
+ ?line T2 = erlang:start_timer((TimeoutSecs - 5)*1000, self(), oops),
+ ?line P1 ! {go, P2},
+ ?line P2 ! {go, P1},
+ ?line Res1 = receive
+ {done, P1} -> done;
+ {timeout,T1,_} -> timeout
+ end,
+ ?line Res2 = receive
+ {done, P2} -> done;
+ {timeout,T2,_} -> timeout
+ end,
+ ?line P1S = process_info(P1, status),
+ ?line P2S = process_info(P2, status),
+ ?line ?t:format("P1S=~p P2S=~p", [P1S, P2S]),
+ ?line false = {status, suspended} == P1S,
+ ?line false = {status, suspended} == P2S,
+ ?line unlink(P1), exit(P1, bang),
+ ?line unlink(P2), exit(P2, bang),
+ ?line done = Res1,
+ ?line done = Res2,
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok.
+
+do_mutual_suspend(_Pid, 0) ->
+ ?line ok;
+do_mutual_suspend(Pid, N) ->
+ %% Suspend a process and test that it is suspended.
+ ?line true = erlang:suspend_process(Pid),
+ ?line {status, suspended} = process_info(Pid, status),
+ %% Unsuspend the process.
+ ?line true = erlang:resume_process(Pid),
+ ?line do_mutual_suspend(Pid, N-1).
+
+suspend_exit(doc) ->
+ [];
+suspend_exit(suite) ->
+ [];
+suspend_exit(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:minutes(2)),
+ ?line random:seed(4711,17,4711),
+ ?line do_suspend_exit(5000),
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok.
+
+do_suspend_exit(0) ->
+ ?line ok;
+do_suspend_exit(N) ->
+ ?line Work = random:uniform(50),
+ ?line Parent = self(),
+ ?line {Suspendee, Mon2}
+ = spawn_monitor(fun () ->
+ suspend_exit_work(Work),
+ exit(normal)
+ end),
+ ?line {Suspender, Mon1}
+ = spawn_monitor(
+ fun () ->
+ suspend_exit_work(Work div 2),
+ Parent ! {doing_suspend, self()},
+ case catch erlang:suspend_process(Suspendee) of
+ {'EXIT', _} ->
+ ok;
+ true ->
+ ?line erlang:resume_process(Suspendee)
+ end
+ end),
+ ?line receive
+ {doing_suspend, Suspender} ->
+ case N rem 2 of
+ 0 -> exit(Suspender, bang);
+ 1 -> ok
+ end
+ end,
+ ?line receive {'DOWN', Mon1, process, Suspender, _} -> ok end,
+ ?line receive {'DOWN', Mon2, process, Suspendee, _} -> ok end,
+ ?line do_suspend_exit(N-1).
+
+
+
+
+suspend_exit_work(0) ->
+ ok;
+suspend_exit_work(N) ->
+ process_info(self()),
+ suspend_exit_work(N-1).
+
+-define(CHK_SUSPENDED(P,B), chk_suspended(P, B, ?LINE)).
+
+chk_suspended(P, Bool, Line) ->
+ {Bool, Line} = {({status, suspended} == process_info(P, status)), Line}.
+
+suspender_exit(doc) ->
+ [];
+suspender_exit(suite) ->
+ [];
+suspender_exit(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:minutes(3)),
+ ?line P1 = spawn_link(fun () -> receive after infinity -> ok end end),
+ ?line {'EXIT', _} = (catch erlang:resume_process(P1)),
+ ?line {P2, M2} = spawn_monitor(
+ fun () ->
+ ?CHK_SUSPENDED(P1, false),
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ erlang:suspend_process(P1),
+ erlang:suspend_process(P1),
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ erlang:resume_process(P1),
+ erlang:resume_process(P1),
+ erlang:resume_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ erlang:resume_process(P1),
+ ?CHK_SUSPENDED(P1, false),
+ erlang:suspend_process(P1),
+ erlang:suspend_process(P1),
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ exit(bang)
+ end),
+ ?line receive
+ {'DOWN', M2,process,P2,R2} ->
+ ?line bang = R2,
+ ?line ?CHK_SUSPENDED(P1, false)
+ end,
+ ?line Parent = self(),
+ ?line {P3, M3} = spawn_monitor(
+ fun () ->
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ Parent ! self(),
+ receive after infinity -> ok end
+ end),
+ ?line {P4, M4} = spawn_monitor(
+ fun () ->
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ Parent ! self(),
+ receive after infinity -> ok end
+ end),
+ ?line {P5, M5} = spawn_monitor(
+ fun () ->
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ Parent ! self(),
+ receive after infinity -> ok end
+ end),
+ ?line {P6, M6} = spawn_monitor(
+ fun () ->
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ Parent ! self(),
+ receive after infinity -> ok end
+ end),
+ ?line {P7, M7} = spawn_monitor(
+ fun () ->
+ erlang:suspend_process(P1),
+ ?CHK_SUSPENDED(P1, true),
+ Parent ! self(),
+ receive after infinity -> ok end
+ end),
+ ?line receive P3 -> ok end,
+ ?line receive P4 -> ok end,
+ ?line receive P5 -> ok end,
+ ?line receive P6 -> ok end,
+ ?line receive P7 -> ok end,
+ ?line ?CHK_SUSPENDED(P1, true),
+ ?line exit(P3, bang),
+ ?line receive
+ {'DOWN',M3,process,P3,R3} ->
+ ?line bang = R3,
+ ?line ?CHK_SUSPENDED(P1, true)
+ end,
+ ?line exit(P4, bang),
+ ?line receive
+ {'DOWN',M4,process,P4,R4} ->
+ ?line bang = R4,
+ ?line ?CHK_SUSPENDED(P1, true)
+ end,
+ ?line exit(P5, bang),
+ ?line receive
+ {'DOWN',M5,process,P5,R5} ->
+ ?line bang = R5,
+ ?line ?CHK_SUSPENDED(P1, true)
+ end,
+ ?line exit(P6, bang),
+ ?line receive
+ {'DOWN',M6,process,P6,R6} ->
+ ?line bang = R6,
+ ?line ?CHK_SUSPENDED(P1, true)
+ end,
+ ?line exit(P7, bang),
+ ?line receive
+ {'DOWN',M7,process,P7,R7} ->
+ ?line bang = R7,
+ ?line ?CHK_SUSPENDED(P1, false)
+ end,
+ ?line unlink(P1),
+ ?line exit(P1, bong),
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok.
+
+suspend_system_limit(doc) ->
+ [];
+suspend_system_limit(suite) ->
+ [];
+suspend_system_limit(Config) when is_list(Config) ->
+ case os:getenv("ERL_EXTREME_TESTING") of
+ "true" ->
+ ?line Dog = test_server:timetrap(test_server:minutes(3*60)),
+ ?line P = spawn_link(fun () -> receive after infinity -> ok end end),
+ ?line suspend_until_system_limit(P),
+ ?line unlink(P),
+ ?line exit(P, bye),
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok;
+ _ ->
+ {skip, "Takes too long time for normal testing"}
+ end.
+
+suspend_until_system_limit(P) ->
+ ?line suspend_until_system_limit(P, 0, 0).
+
+suspend_until_system_limit(P, N, M) ->
+ NewM = case M of
+ 1 ->
+ ?line ?CHK_SUSPENDED(P, true), 2;
+ 1000000 ->
+ erlang:display(N), 1;
+ _ ->
+ M+1
+ end,
+ ?line case catch erlang:suspend_process(P) of
+ true ->
+ suspend_until_system_limit(P, N+1, NewM);
+ {'EXIT', R} when R == system_limit;
+ element(1, R) == system_limit ->
+ ?line ?t:format("system limit at ~p~n", [N]),
+ ?line resume_from_system_limit(P, N, 0);
+ Error ->
+ ?line ?t:fail(Error)
+ end.
+
+resume_from_system_limit(P, 0, _) ->
+ ?line ?CHK_SUSPENDED(P, false),
+ ?line {'EXIT', _} = (catch erlang:resume_process(P)),
+ ?line ok;
+resume_from_system_limit(P, N, M) ->
+ ?line NewM = case M of
+ 1 ->
+ ?line ?CHK_SUSPENDED(P, true), 2;
+ 1000000 ->
+ erlang:display(N), 1;
+ _ ->
+ M+1
+ end,
+ ?line erlang:resume_process(P),
+ ?line resume_from_system_limit(P, N-1, NewM).
+
+-record(susp_info, {async = 0,
+ dbl_async = 0,
+ synced = 0,
+ async_once = 0}).
+
+suspend_opts(doc) ->
+ [];
+suspend_opts(suite) ->
+ [];
+suspend_opts(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:minutes(3)),
+ ?line Self = self(),
+ ?line wait_for_empty_runq(10),
+ ?line Tok = spawn_link(fun () ->
+ Self ! self(),
+ tok_trace_loop(Self, 0, 1000000000)
+ end),
+ ?line TC = 1000,
+ ?line receive Tok -> ok end,
+ ?line SF = fun (N, #susp_info {async = A,
+ dbl_async = AA,
+ synced = S,
+ async_once = AO} = Acc) ->
+ ?line erlang:suspend_process(Tok, [asynchronous]),
+ ?line Res = case {suspend_count(Tok), N rem 4} of
+ {0, 2} ->
+ ?line erlang:suspend_process(Tok,
+ [asynchronous]),
+ case suspend_count(Tok) of
+ 2 ->
+ ?line erlang:resume_process(Tok),
+ ?line Acc#susp_info{async = A+1};
+ 0 ->
+ ?line erlang:resume_process(Tok),
+ ?line Acc#susp_info{async = A+1,
+ dbl_async = AA+1}
+ end;
+ {0, 1} ->
+ ?line erlang:suspend_process(Tok,
+ [asynchronous,
+ unless_suspending]),
+ case suspend_count(Tok) of
+ 1 ->
+ ?line Acc#susp_info{async = A+1};
+ 0 ->
+ ?line Acc#susp_info{async = A+1,
+ async_once = AO+1}
+ end;
+ {0, 0} ->
+ ?line erlang:suspend_process(Tok,
+ [unless_suspending]),
+ ?line 1 = suspend_count(Tok),
+ ?line Acc#susp_info{async = A+1,
+ synced = S+1};
+ {0, _} ->
+ ?line Acc#susp_info{async = A+1};
+ _ ->
+ Acc
+ end,
+ ?line erlang:resume_process(Tok),
+ ?line erlang:yield(),
+ ?line Res
+ end,
+ ?line SI = repeat_acc(SF, TC, #susp_info{}),
+ ?line erlang:suspend_process(Tok, [asynchronous]),
+ %% Verify that it eventually suspends
+ ?line WaitTime0 = 10,
+ ?line WaitTime1 = case {erlang:system_info(debug_compiled),
+ erlang:system_info(lock_checking)} of
+ {false, false} ->
+ WaitTime0;
+ {false, true} ->
+ WaitTime0*5;
+ _ ->
+ WaitTime0*10
+ end,
+ ?line WaitTime = case {erlang:system_info(schedulers_online),
+ erlang:system_info(logical_processors)} of
+ {Schdlrs, CPUs} when is_integer(CPUs),
+ Schdlrs =< CPUs ->
+ WaitTime1;
+ _ ->
+ WaitTime1*10
+ end,
+ ?line receive after WaitTime -> ok end,
+ ?line 1 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok, [asynchronous]),
+ ?line 2 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok, [asynchronous]),
+ ?line 3 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok),
+ ?line 4 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok),
+ ?line 5 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok, [unless_suspending]),
+ ?line 5 = suspend_count(Tok),
+ ?line erlang:suspend_process(Tok, [unless_suspending,
+ asynchronous]),
+ ?line 5 = suspend_count(Tok),
+ ?line erlang:resume_process(Tok),
+ ?line erlang:resume_process(Tok),
+ ?line erlang:resume_process(Tok),
+ ?line erlang:resume_process(Tok),
+ ?line 1 = suspend_count(Tok),
+ ?line ?t:format("Main suspends: ~p~n"
+ "Main async: ~p~n"
+ "Double async: ~p~n"
+ "Async once: ~p~n"
+ "Synced: ~p~n",
+ [TC,
+ SI#susp_info.async,
+ SI#susp_info.dbl_async,
+ SI#susp_info.async_once,
+ SI#susp_info.synced]),
+ ?line case erlang:system_info(schedulers_online) of
+ 1 ->
+ ?line ok;
+ _ ->
+ ?line true = SI#susp_info.async =/= 0
+ end,
+ ?line unlink(Tok),
+ ?line exit(Tok, bang),
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok.
+
+suspend_count(Suspendee) ->
+ suspend_count(self(), Suspendee).
+
+suspend_count(Suspender, Suspendee) ->
+ {suspending, SList} = process_info(Suspender, suspending),
+
+ case lists:keysearch(Suspendee, 1, SList) of
+ {value, {_Suspendee, 0, 0}} ->
+ ?line ?t:fail({bad_suspendee_list, SList});
+ {value, {Suspendee, Count, 0}} when is_integer(Count), Count > 0 ->
+ {status, suspended} = process_info(Suspendee, status),
+ Count;
+ {value, {Suspendee, 0, Outstanding}} when is_integer(Outstanding),
+ Outstanding > 0 ->
+ 0;
+ false ->
+ 0;
+ Error ->
+ ?line ?t:fail({bad_suspendee_list, Error, SList})
+ end.
+
+repeat_acc(Fun, N, Acc) ->
+ repeat_acc(Fun, 0, N, Acc).
+
+repeat_acc(_Fun, N, N, Acc) ->
+ Acc;
+repeat_acc(Fun, N, M, Acc) ->
+ repeat_acc(Fun, N+1, M, Fun(N, Acc)).
+
+%% Tests that waiting process can be suspended
+%% (bug in R2D and earlier; see OTP-1488).
+
+suspend_waiting(doc) -> "Test that a waiting process can be suspended.";
+suspend_waiting(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+
+ ?line Process = fun_spawn(fun process/0),
+ ?line receive after 1 -> ok end,
+ ?line true = erlang:suspend_process(Process),
+ ?line {status, suspended} = process_info(Process, status),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+
+
+new_clear(doc) ->
+ "Test that erlang:trace(new, true, ...) is cleared when tracer dies.";
+new_clear(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+
+ ?line Tracer = spawn(fun receiver/0),
+ ?line 0 = erlang:trace(new, true, [send, {tracer, Tracer}]),
+ ?line {flags, [send]} = erlang:trace_info(new, flags),
+ ?line {tracer, Tracer} = erlang:trace_info(new, tracer),
+ ?line Mref = erlang:monitor(process, Tracer),
+ ?line true = exit(Tracer, done),
+ receive
+ {'DOWN',Mref,_,_,_} -> ok
+ end,
+ ?line {flags, []} = erlang:trace_info(new, flags),
+ ?line {tracer, []} = erlang:trace_info(new, tracer),
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+
+ ok.
+
+
+
+existing_clear(doc) ->
+ "Test that erlang:trace(all, false, ...) works without tracer.";
+existing_clear(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(5)),
+ ?line Self = self(),
+
+ ?line Tracer = fun_spawn(fun receiver/0),
+ ?line N = erlang:trace(existing, true, [send, {tracer, Tracer}]),
+ ?line {flags, [send]} = erlang:trace_info(Self, flags),
+ ?line {tracer, Tracer} = erlang:trace_info(Self, tracer),
+ ?line M = erlang:trace(all, false, [all]),
+ ?line io:format("Started trace on ~p processes and stopped on ~p~n",
+ [N, M]),
+ ?line {flags, []} = erlang:trace_info(Self, flags),
+ ?line {tracer, []} = erlang:trace_info(Self, tracer),
+ ?line M = N + 1, % Since trace could not be enabled on the tracer.
+
+ %% Done.
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+bad_flag(doc) -> "Test that an invalid flag cause badarg";
+bad_flag(suite) -> [];
+bad_flag(Config) when is_list(Config) ->
+ %% A bad flag could deadlock the SMP emulator in erts-5.5
+ ?line {'EXIT', {badarg, _}} = (catch erlang:trace(new,
+ true,
+ [not_a_valid_flag])),
+ ?line ok.
+
+trace_delivered(doc) -> "Test erlang:trace_delivered/1";
+trace_delivered(suite) -> [];
+trace_delivered(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:seconds(60)),
+ ?line TokLoops = 10000,
+ ?line Go = make_ref(),
+ ?line Parent = self(),
+ ?line Tok = spawn(fun () ->
+ receive Go -> gone end,
+ tok_trace_loop(Parent, 0, TokLoops)
+ end),
+ ?line 1 = erlang:trace(Tok, true, [procs]),
+ ?line Mon = erlang:monitor(process, Tok),
+ ?line NoOfTraceMessages = 4*TokLoops + 1,
+ ?line io:format("Expect a total of ~p trace messages~n",
+ [NoOfTraceMessages]),
+ ?line Tok ! Go,
+ ?line NoOfTraceMessages = drop_trace_until_down(Tok, Mon),
+ ?line receive
+ Msg ->
+ ?line ?t:fail({unexpected_message, Msg})
+ after 1000 ->
+ ?line test_server:timetrap_cancel(Dog),
+ ?line ok
+ end.
+
+drop_trace_until_down(Proc, Mon) ->
+ drop_trace_until_down(Proc, Mon, false, 0, 0).
+
+drop_trace_until_down(Proc, Mon, TDRef, N, D) ->
+ case receive Msg -> Msg end of
+ {trace_delivered, Proc, TDRef} ->
+ io:format("~p trace messages on 'DOWN'~n", [D]),
+ io:format("Got a total of ~p trace messages~n", [N]),
+ N;
+ {'DOWN', Mon, process, Proc, _} ->
+ Ref = erlang:trace_delivered(Proc),
+ drop_trace_until_down(Proc, Mon, Ref, N, N);
+ Trace when is_tuple(Trace),
+ element(1, Trace) == trace,
+ element(2, Trace) == Proc ->
+ drop_trace_until_down(Proc, Mon, TDRef, N+1, D)
+ end.
+
+tok_trace_loop(_, N, N) ->
+ ok;
+tok_trace_loop(Parent, N, M) ->
+ Name = 'A really stupid name which I will unregister at once',
+ link(Parent),
+ register(Name, self()),
+ unregister(Name),
+ unlink(Parent),
+ tok_trace_loop(Parent, N+1, M).
+
+%% Waits for and returns the first message in the message queue.
+
+receive_first() ->
+ receive
+ Any -> Any
+ end.
+
+%% Ensures that there is no message in the message queue.
+
+receive_nothing() ->
+ receive
+ Any ->
+ test_server:fail({unexpected_message, Any})
+ after 200 ->
+ ok
+ end.
+
+
+%%% Models for various kinds of processes.
+
+process(Dest) ->
+ receive
+ {send_please, To, What} ->
+ To ! What,
+ process(Dest);
+ {spawn_link_please, ReplyTo, {M, F, A}} ->
+ Pid = spawn_link(M, F, A),
+ ReplyTo ! {spawned, self(), Pid},
+ process(Dest);
+ {spawn_link_please, ReplyTo, Node, {M, F, A}} ->
+ Pid = spawn_link(Node, M, F, A),
+ ReplyTo ! {spawned, self(), Pid},
+ process(Dest);
+ {link_please, Pid} ->
+ link(Pid),
+ process(Dest);
+ {unlink_please, Pid} ->
+ unlink(Pid),
+ process(Dest);
+ {register_please, Name, Pid} ->
+ register(Name, Pid),
+ process(Dest);
+ {unregister_please, Name} ->
+ unregister(Name),
+ process(Dest);
+ {exit_please, Reason} ->
+ exit(Reason);
+ {trap_exit_please, State} ->
+ process_flag(trap_exit, State),
+ process(Dest);
+ Other ->
+ Dest ! {self(), Other},
+ process(Dest)
+ after 3000 ->
+ exit(timeout)
+ end.
+
+
+%% A smart process template.
+
+process() ->
+ receive
+ {spawn_please, ReplyTo, Fun} ->
+ Pid = fun_spawn(Fun),
+ ReplyTo ! {spawned, Pid},
+ process();
+ {send_please, To, What} ->
+ To ! What,
+ process();
+ timeout_please ->
+ receive after 1 -> process() end;
+ _Other ->
+ process()
+ end.
+
+
+%% Sends messages when ordered to.
+
+sender() ->
+ receive
+ {send_please, To, What} ->
+ To ! What,
+ sender()
+ end.
+
+
+%% Just consumes messages from its message queue.
+
+receiver() ->
+ receive
+ _Any -> receiver()
+ end.
+
+%% Works as long as it receives CPU time. Will always be RUNNABLE.
+
+worker() ->
+ worker(0).
+
+worker(Number) ->
+ worker(Number+1).
+
+fun_spawn(Fun) ->
+ spawn_link(erlang, apply, [Fun, []]).
+
+fun_spawn(Fun, Args) ->
+ spawn_link(erlang, apply, [Fun, Args]).
+
+
+start_node(Name) ->
+ Pa = filename:dirname(code:which(?MODULE)),
+ Cookie = atom_to_list(erlang:get_cookie()),
+ test_server:start_node(Name, slave,
+ [{args, "-setcookie " ++ Cookie ++" -pa " ++ Pa}]).
+
+stop_node(Node) ->
+ test_server:stop_node(Node).
+
+
+wait_for_empty_runq(DeadLine) ->
+ case statistics(run_queue) of
+ 0 -> true;
+ RQLen ->
+ erlang:display("Waiting for empty run queue"),
+ MSDL = DeadLine*1000,
+ wait_for_empty_runq(MSDL, MSDL, RQLen)
+ end.
+
+wait_for_empty_runq(DeadLine, Left, RQLen) when Left =< 0 ->
+ issue_non_empty_runq_warning(DeadLine, RQLen),
+ false;
+wait_for_empty_runq(DeadLine, Left, _RQLen) ->
+ Wait = 10,
+ UntilDeadLine = Left - Wait,
+ receive after Wait -> ok end,
+ case statistics(run_queue) of
+ 0 ->
+ erlang:display("Waited for "
+ ++ integer_to_list(DeadLine
+ - UntilDeadLine)
+ ++ " ms for empty run queue."),
+ true;
+ NewRQLen ->
+ wait_for_empty_runq(DeadLine,
+ UntilDeadLine,
+ NewRQLen)
+ end.
+
+issue_non_empty_runq_warning(DeadLine, RQLen) ->
+ PIs = lists:foldl(
+ fun (P, Acc) ->
+ case process_info(P,
+ [status,
+ initial_call,
+ current_function,
+ registered_name,
+ reductions,
+ message_queue_len]) of
+ [{status, Runnable} | _] = PI when Runnable /= waiting,
+ Runnable /= suspended ->
+ [[{pid, P} | PI] | Acc];
+ _ ->
+ Acc
+ end
+ end,
+ [],
+ processes()),
+ ?t:format("WARNING: Unexpected runnable processes in system (waited ~p sec).~n"
+ " Run queue length: ~p~n"
+ " Self: ~p~n"
+ " Processes info: ~p~n",
+ [DeadLine div 1000, RQLen, self(), PIs]),
+ receive after 1000 -> ok end.