The R13B03 release.OTP_R13B03

1 files changed, 125 insertions, 0 deletions

diff --git a/lib/test_server/src/things/mnesia_power_SUITE.erl b/lib/test_server/src/things/mnesia_power_SUITE.erl
new file mode 100644
index 0000000000..281dac7742
--- /dev/null
+++ b/lib/test_server/src/things/mnesia_power_SUITE.erl
@@ -0,0 +1,125 @@
+%%
+%% %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(mnesia_power_SUITE).
+-compile([export_all]).
+%%-define(line_trace,1).
+-include("test_server.hrl").
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+all(suite) -> [run].
+
+-define(iterations,3). %% nof power-off cycles to do before acceptance
+-define(rows,8). %% nof database rows to use (not too big, please)
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+-record(sum_table_1,{row,a,b,c,s}).
+
+run(suite) -> [];
+run(Config) ->
+    ?line mnesia:create_schema([node()]),
+    ?line mnesia:start(),
+    ?line mnesia:create_table([{name, sum_table_1}, {disc_copies,[node()]},
+			       {attributes,record_info(fields,sum_table_1)}]),
+    ?line run_test(Config,?iterations).
+
+run(Config,N) ->
+    ?line mnesia:start(),
+    ?line check_consistency(sum_table_1),
+    case N of
+	0 -> ?line ok;
+	N -> ?line run_test(Config,N)
+    end.
+    
+run_test(Config,N) ->
+    ?line Pid1a = start_manipulator(sum_table_1),
+    ?line Pid1b = start_manipulator(sum_table_1),
+    ?line Pid1c = start_manipulator(sum_table_1),
+    ?line test_server:resume_point(?MODULE,run,[Config,N-1]),
+    ?line test_server:format(1,"Manipulating data like crazy now, "
+		       "power off any time..."),
+    ?line test_server:sleep(infinity).
+
+start_manipulator(Table) ->
+    ?line spawn_link(?MODULE,manipulator_init,[Table]).
+
+manipulator_init(Table) ->
+    random:seed(4711,0,0),
+    manipulator(0,Table).
+
+manipulator(N,Table) ->
+    ?line Fun = 
+	fun() ->
+		?line Row = random:uniform(?rows),
+		?line A = random:uniform(100000),
+		?line B = random:uniform(100000),
+		?line C = random:uniform(100000),
+		?line Sum = A+B+C,
+		?line case mnesia:write(#sum_table_1
+					{row=Row,a=A,b=B,c=C,s=Sum}) of
+			  ok -> ok;
+			  Other ->
+			      ?line io:format("Trans failed: ~p\n",[Other])
+		      end
+	end,
+    ?line mnesia:transaction(Fun),
+    case mnesia:table_info(sum_table_1,size) of
+	0 -> exit(still_empty);
+	_ -> ok
+    end,
+    case N rem 2000 of
+	0 -> io:format("~p did ~p operations",[self(),N]),
+	     check_consistency(sum_table_1);
+	_ -> ok
+    end,
+    ?line manipulator(N+1,Table).
+
+check_consistency(Table) ->
+    io:format("Checking consistency of table ~p\n",[Table]),
+    All = mnesia:table_info(Table,wild_pattern),
+    ?line Fun =
+        fun() ->
+		mnesia:match_object(All)
+        end,
+  ?line case mnesia:transaction(Fun) of
+	    {atomic,Val} ->
+		check_consistency_rows(Val,0);
+	    Other ->
+		io:format("Trans failed: ~p\n",[Other]),
+		exit(failed),
+		check_consistency(Table)
+	  end.
+
+check_consistency_rows([#sum_table_1{a=A,b=B,c=C,s=Sum}|Rows],N) ->
+    ?line Sum=A+B+C,
+    ?line check_consistency_rows(Rows,N+1);
+check_consistency_rows([],N) ->
+    io:format("All ~p rows were consistent\n",[N]),
+    {ok,N};
+check_consistency_rows(Thing,N) ->
+    io:format("Mnesia transaction returned:\n~p\n",[Thing]),
+    exit({bad_format,Thing}).
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+				  
+    
+		
+