The R13B03 release.OTP_R13B03

2 files changed, 191 insertions, 0 deletions

diff --git a/lib/kernel/test/wrap_log_reader_SUITE_data/Makefile.src b/lib/kernel/test/wrap_log_reader_SUITE_data/Makefile.src
new file mode 100644
index 0000000000..4098cacfd2
--- /dev/null
+++ b/lib/kernel/test/wrap_log_reader_SUITE_data/Makefile.src
@@ -0,0 +1,7 @@
+EFLAGS=+debug_info
+           
+all: wrap_log_test.@EMULATOR@
+
+wrap_log_test.@EMULATOR@: wrap_log_test.erl
+	erlc $(EFLAGS) wrap_log_test.erl
+
diff --git a/lib/kernel/test/wrap_log_reader_SUITE_data/wrap_log_test.erl b/lib/kernel/test/wrap_log_reader_SUITE_data/wrap_log_test.erl
new file mode 100644
index 0000000000..e5ff70fd49
--- /dev/null
+++ b/lib/kernel/test/wrap_log_reader_SUITE_data/wrap_log_test.erl
@@ -0,0 +1,184 @@
+%%
+%% %CopyrightBegin%
+%% 
+%% Copyright Ericsson AB 1998-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%
+%%
+%%%----------------------------------------------------------------------
+%%% Purpose : Test wrap_log_reader.erl
+%%%----------------------------------------------------------------------
+
+-module(wrap_log_test).
+
+-export([init/0, stop/0]).
+-define(fsize, 80).
+-define(fno, 4).
+
+%-define(debug, true).
+
+-ifdef(debug).
+-define(format(S, A), io:format(S, A)).
+-else.
+-define(format(S, A), ok).
+-endif.
+
+init() ->
+    spawn(fun() -> start(logger) end),
+    spawn(fun() -> start2(wlt) end),
+    wait_registered(logger),
+    wait_registered(wlt),
+    ok.
+
+wait_registered(Name) ->
+    case whereis(Name) of
+	undefined ->
+	    timer:sleep(100),
+	    wait_registered(Name);
+	_Pid ->
+	    ok
+    end.
+
+stop() ->
+    catch logger ! exit,
+    catch wlt ! exit,
+    wait_unregistered(logger),
+    wait_unregistered(wlt),
+    ok.
+
+wait_unregistered(Name) ->
+    case whereis(Name) of
+	undefined ->
+	    ok;
+	_Pid ->
+	    timer:sleep(100),
+	    wait_unregistered(Name)
+    end.
+
+start(Name) ->
+    ?format("Starting ~p~n", [Name]),
+    register(Name, self()),
+    loop().
+
+start2(Name) ->
+    ?format("Starting ~p~n", [Name]),
+    register(Name, self()),
+    loop2(eof, Name).
+
+loop() ->
+    receive
+	{open, Pid, Name, File} ->
+	    R = disk_log:open([{name, Name}, {type, wrap}, {file, File},
+			       {size, {?fsize, ?fno}}]),
+	    ?format("logger: open ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+	
+	{open_ext, Pid, Name, File} ->
+	    R = disk_log:open([{name, Name}, {type, wrap}, {file, File},
+			       {format, external}, {size, {?fsize, ?fno}}]),
+	    ?format("logger: open ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+	
+	{close, Pid, Name} ->
+	    R = disk_log:close(Name),
+	    ?format("logger: close ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+	
+	{sync, Pid, Name} ->
+	    R = disk_log:sync(Name),
+	    ?format("logger: sync ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+	
+	{log_terms, Pid, Name, Terms} ->
+	    R = disk_log:log_terms(Name, Terms),
+	    ?format("logger: log_terms ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+
+	{blog_terms, Pid, Name, Terms} ->
+	    R = disk_log:blog_terms(Name, Terms),
+	    ?format("logger: blog_terms ~p -> ~p~n", [Name, R]),
+	    Pid ! R,
+	    loop();
+
+	exit ->
+	    ?format("Stopping logger~n", []),
+	    exit(normal);
+
+	_Else ->
+	    ?format("logger: ignored: ~p~n", [_Else]),
+	    loop()
+    end.
+
+loop2(C, Wlt) ->
+    receive
+	{open, Pid, Name} ->
+	    case wrap_log_reader:open(Name) of
+		{ok, R} ->
+		    ?format("~p: open ~p -> ~p~n", [Wlt, Name, {ok, R}]),
+		    Pid ! {ok, R},
+		    loop2(R, Wlt);
+		E ->
+		    ?format("~p: open ~p -> ~p~n", [Wlt, Name, E]),
+		    Pid ! E,
+		    loop2(C, Wlt)
+	    end;
+	
+	{open, Pid, Name, No} ->
+	    case wrap_log_reader:open(Name, No) of
+		{ok, R} ->
+		    ?format("~p: open ~p, file ~p -> ~p~n", 
+			    [Wlt, Name, No, {ok, R}]),
+		    Pid ! {ok, R},
+		    loop2(R, Wlt);
+		E ->
+		    ?format("~p: open ~p, file ~p -> ~p~n", 
+			    [Wlt, Name, No, E]),
+		    Pid ! E,
+		    loop2(C, Wlt)
+	    end;
+	
+	{close, Pid, WR} ->
+	    R = wrap_log_reader:close(WR),
+	    ?format("~p: close -> ~p~n", [Wlt, R]),
+	    Pid ! R,
+	    loop2(eof, Wlt);
+	
+	{chunk, Pid, WR} ->
+	    did_chunk(wrap_log_reader:chunk(WR), Pid, Wlt);
+	
+	{chunk, Pid, WR, N} ->
+	    did_chunk(wrap_log_reader:chunk(WR, N), Pid, Wlt);
+
+	exit ->
+	    ?format("Stopping ~p~n", [Wlt]),
+	    exit(normal);
+
+	_Else ->
+	    ?format("~p: ignored: ~p~n", [Wlt, _Else]),
+	    loop2(C, Wlt)
+    end.
+
+did_chunk({C1, L}, Pid, Wlt) ->
+    ?format("~p: chunk -> ~p~n", [Wlt, {C1, L}]),
+    Pid ! {C1, L},
+    loop2(C1, Wlt);
+did_chunk({C1, L, _Bad}, Pid, Wlt) ->
+    ?format("~p: chunk -> ~p (bad)~n", [Wlt, {C1, L, _Bad}]),
+    Pid ! {C1, L},
+    loop2(C1, Wlt).