aboutsummaryrefslogtreecommitdiffstats
path: root/lib/stdlib/test/supervisor_bridge_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/stdlib/test/supervisor_bridge_SUITE.erl
downloadotp-84adefa331c4159d432d22840663c38f155cd4c1.tar.gz
otp-84adefa331c4159d432d22840663c38f155cd4c1.tar.bz2
otp-84adefa331c4159d432d22840663c38f155cd4c1.zip
The R13B03 release.OTP_R13B03
Diffstat (limited to 'lib/stdlib/test/supervisor_bridge_SUITE.erl')
-rw-r--r--lib/stdlib/test/supervisor_bridge_SUITE.erl178
1 files changed, 178 insertions, 0 deletions
diff --git a/lib/stdlib/test/supervisor_bridge_SUITE.erl b/lib/stdlib/test/supervisor_bridge_SUITE.erl
new file mode 100644
index 0000000000..b23bac2d44
--- /dev/null
+++ b/lib/stdlib/test/supervisor_bridge_SUITE.erl
@@ -0,0 +1,178 @@
+%%
+%% %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(supervisor_bridge_SUITE).
+-export([all/1,starting/1,mini_terminate/1,mini_die/1,badstart/1]).
+-export([client/1,init/1,internal_loop_init/1,terminate/2]).
+
+-include("test_server.hrl").
+-define(bridge_name,supervisor_bridge_SUITE_server).
+-define(work_bridge_name,work_supervisor_bridge_SUITE_server).
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+all(suite) -> [starting,mini_terminate,mini_die,badstart].
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+starting(suite) -> [];
+starting(Config) when is_list(Config) ->
+ process_flag(trap_exit,true),
+
+ ?line ignore = start(1),
+ ?line {error,testing} = start(2),
+ ok.
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+mini_terminate(suite) -> [];
+mini_terminate(Config) when is_list(Config) ->
+ miniappl(1),
+ ok.
+
+mini_die(suite) -> [];
+mini_die(Config) when is_list(Config) ->
+ miniappl(2),
+ ok.
+
+miniappl(N) ->
+ process_flag(trap_exit,true),
+ ?line {ok,Server} = start(3),
+ ?line Client = spawn_link(?MODULE,client,[N]),
+ ?line Handle = test_server:timetrap(2000),
+ ?line miniappl_loop(Client,Server),
+ ?line test_server:timetrap_cancel(Handle).
+
+miniappl_loop([],[]) ->
+ ok;
+miniappl_loop(Client,Server) ->
+ io:format("Client ~p, Server ~p\n",[Client,Server]),
+ receive
+ {'EXIT',Client,_} ->
+ ?line miniappl_loop([],Server);
+ {'EXIT',Server,killed} -> %% terminate
+ ?line miniappl_loop(Client,[]);
+ {'EXIT',Server,died} -> %% die
+ ?line miniappl_loop(Client,[]);
+ {dying,_Reason} ->
+ ?line miniappl_loop(Client, Server);
+ Other ->
+ ?line exit({failed,Other})
+ end.
+
+%%%%%%%%%%%%%%%%%%%%
+% Client
+
+client(N) ->
+ io:format("Client starting...\n"),
+ ok = public_request(),
+ case N of
+ 1 -> public_kill();
+ 2 -> ?work_bridge_name ! die
+ end,
+ io:format("Killed server, terminating client...\n"),
+ exit(fine).
+
+%%%%%%%%%%%%%%%%%%%%
+% Non compliant server
+
+start(N) ->
+ supervisor_bridge:start_link({local,?bridge_name},?MODULE,N).
+
+public_request() ->
+ ?work_bridge_name ! {non_compliant_message,self()},
+ io:format("Client waiting for answer...\n"),
+ receive
+ non_compliant_answer ->
+ ok
+ end,
+ io:format("Client got answer...\n").
+
+public_kill() ->
+ %% This func knows about supervisor_bridge
+ exit(whereis(?work_bridge_name),kill).
+
+init(1) ->
+ ignore;
+init(2) ->
+ {error,testing};
+init(3) ->
+ %% This func knows about supervisor_bridge
+ InternalPid = spawn_link(?MODULE,internal_loop_init,[self()]),
+ receive
+ {InternalPid,init_done} ->
+ {ok,InternalPid,self()}
+ end.
+
+internal_loop_init(Parent) ->
+ register(?work_bridge_name, self()),
+ Parent ! {self(),init_done},
+ internal_loop({Parent,self()}).
+
+internal_loop(State) ->
+ receive
+ {non_compliant_message,From} ->
+ io:format("Got request from ~p\n",[From]),
+ From ! non_compliant_answer,
+ internal_loop(State);
+ die ->
+ exit(died)
+ end.
+
+terminate(Reason,{Parent,Worker}) ->
+ %% This func knows about supervisor_bridge
+ io:format("Terminating bridge...\n"),
+ exit(kill,Worker),
+ Parent ! {dying,Reason},
+ anything.
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+badstart(suite) -> [];
+badstart(doc) -> "Test various bad ways of starting a supervisor bridge.";
+badstart(Config) when is_list(Config) ->
+ ?line Dog = test_server:timetrap(test_server:minutes(1)),
+
+ %% Various bad arguments.
+
+ ?line {'EXIT',_} =
+ (catch supervisor_bridge:start_link({xxx,?bridge_name},?MODULE,1)),
+ ?line {'EXIT',_} =
+ (catch supervisor_bridge:start_link({local,"foo"},?MODULE,1)),
+ ?line {'EXIT',_} =
+ (catch supervisor_bridge:start_link(?bridge_name,?MODULE,1)),
+ ?line [] = test_server:messages_get(), % No messages waiting
+
+ %% Already started.
+
+ ?line process_flag(trap_exit, true),
+ ?line {ok,Pid} =
+ supervisor_bridge:start_link({local,?bridge_name},?MODULE,3),
+ ?line {error,{already_started,Pid}} =
+ supervisor_bridge:start_link({local,?bridge_name},?MODULE,3),
+ ?line public_kill(),
+
+ %% We used to wait 1 ms before retrieving the message queue,
+ %% but that might not always be enough if the machine is overloaded.
+ ?line receive
+ {'EXIT', Pid, killed} -> ok
+ end,
+ ?line test_server:timetrap_cancel(Dog),
+ ok.
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%