The R13B03 release.OTP_R13B03

1 files changed, 184 insertions, 0 deletions

diff --git a/lib/mnesia/examples/bench/bench_trans.erl b/lib/mnesia/examples/bench/bench_trans.erl
new file mode 100644
index 0000000000..945715daae
--- /dev/null
+++ b/lib/mnesia/examples/bench/bench_trans.erl
@@ -0,0 +1,184 @@
+%%
+%% %CopyrightBegin%
+%% 
+%% Copyright Ericsson AB 2001-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%
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%%% File    : bench_trans.hrl
+%%% Author  : Hakan Mattsson <[email protected]>
+%%% Purpose : Implement the transactions in Canadian database benchmark (LMC/UU-01:025)
+%%% Created : 21 Jun 2001 by Hakan Mattsson <[email protected]>
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+-module(bench_trans).
+-author('[email protected]').
+
+-include("bench.hrl").
+
+-export([
+	 update_current_location/5,
+	 read_current_location/2,
+	 read_session_details/4,
+	 create_session_to_server/6,
+	 delete_session_from_server/5,
+	 number_to_suffix/1,
+	 number_to_key/2
+	]).
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% The transactions
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+%% -------------------------------------------------------------------
+%% T1
+%% -------------------------------------------------------------------
+
+update_current_location(Wlock, SubscrId, Location, ChangedBy, ChangedTime) ->
+    Suffix   = number_to_suffix(SubscrId),
+    [Subscr] = mnesia:read({subscriber, Suffix}, SubscrId, Wlock),
+    Subscr2  = Subscr#subscriber{location     = Location,
+                                 changed_by   = ChangedBy,
+                                 changed_time = ChangedTime},
+    mnesia:write(subscriber, Subscr2, Wlock),
+    {do_commit, false, [ok]}.
+
+%% -------------------------------------------------------------------
+%% T2
+%% -------------------------------------------------------------------
+
+read_current_location(_Wlock, SubscrId) ->
+    Suffix   = number_to_suffix(SubscrId),
+    [Subscr] = mnesia:read({subscriber, Suffix}, SubscrId, read),
+
+    Name          = Subscr#subscriber.subscriber_name,
+    Location      = Subscr#subscriber.location,
+    ChangedBy     = Subscr#subscriber.changed_by,
+    ChangedTime   = Subscr#subscriber.changed_time,
+    {do_commit, false, [Name, Location, ChangedBy, ChangedTime]}.
+
+%% -------------------------------------------------------------------
+%% T3
+%% -------------------------------------------------------------------
+
+read_session_details(Wlock, SubscrId, ServerBit, ServerId) ->
+    Suffix   = number_to_suffix(SubscrId),
+    [Subscr] = mnesia:read({subscriber, Suffix}, SubscrId, read),
+    %%[Group]  = mnesia:read(group, Subscr#subscriber.group_id, read),
+    [Group]  = mnesia:dirty_read(group, Subscr#subscriber.group_id),
+
+    IsAllowed     = ((Group#group.allow_read band ServerBit) == ServerBit),
+    IsActive      = ((Subscr#subscriber.active_sessions band ServerBit) == ServerBit),    
+    ExecuteBranch = (IsAllowed and IsActive),
+
+    case ExecuteBranch of
+        true ->
+            SessionKey = {SubscrId, ServerId},
+            [Session] = mnesia:read({session, Suffix}, SessionKey, read),
+
+            ServerKey = {ServerId, Suffix},
+            [Server] = mnesia:read({server, Suffix}, ServerKey, Wlock),
+            Server2 = Server#server{no_of_read = Server#server.no_of_read + 1},
+            mnesia:write(server, Server2, Wlock),
+            {do_commit, ExecuteBranch, [Session#session.session_details]};
+        false  ->
+            {do_commit, ExecuteBranch, []}
+    end.
+
+%% -------------------------------------------------------------------
+%% T4
+%% -------------------------------------------------------------------
+
+create_session_to_server(Wlock, SubscrId, ServerBit, ServerId, Details, DoRollback) ->
+    Suffix   = number_to_suffix(SubscrId),
+    [Subscr] = mnesia:read({subscriber, Suffix}, SubscrId, Wlock),
+    %%[Group]  = mnesia:read(group, Subscr#subscriber.group_id, read),
+    [Group]  = mnesia:dirty_read(group, Subscr#subscriber.group_id),
+
+    IsAllowed     = ((Group#group.allow_insert band ServerBit) == ServerBit),
+    IsInactive    = ((Subscr#subscriber.active_sessions band ServerBit) == 0),
+    ExecuteBranch = (IsAllowed and IsInactive),
+    case ExecuteBranch of
+        true ->
+            SessionKey = {SubscrId, ServerId},
+            Session = #session{session_key     = SessionKey,
+                               session_details = Details,
+                               suffix          = Suffix},
+            mnesia:write(session, Session, Wlock),
+            Active = (Subscr#subscriber.active_sessions bor ServerBit),
+            Subscr2 = Subscr#subscriber{active_sessions = Active},
+            mnesia:write(subscriber, Subscr2, Wlock),
+
+            ServerKey = {ServerId, Suffix},
+            [Server] = mnesia:read({server, Suffix}, ServerKey, Wlock),
+            Server2 = Server#server{no_of_insert = Server#server.no_of_insert + 1},
+            mnesia:write(server, Server2, Wlock);
+        false ->
+            ignore
+    end,
+    case DoRollback of
+        true ->
+            mnesia:abort({do_rollback, ExecuteBranch, []});
+        false ->
+            {do_commit, ExecuteBranch, []}
+    end.
+
+%% -------------------------------------------------------------------
+%% T5
+%% -------------------------------------------------------------------
+
+delete_session_from_server(Wlock, SubscrId, ServerBit, ServerId, DoRollback) ->
+    Suffix   = number_to_suffix(SubscrId),
+    [Subscr] = mnesia:read({subscriber, Suffix}, SubscrId, Wlock),
+    %%[Group]  = mnesia:read(group, Subscr#subscriber.group_id, read),
+    [Group]  = mnesia:dirty_read(group, Subscr#subscriber.group_id),
+
+    IsAllowed     = ((Group#group.allow_delete band ServerBit) == ServerBit),
+    IsActive      = ((Subscr#subscriber.active_sessions band ServerBit) == ServerBit),    
+    ExecuteBranch = (IsAllowed and IsActive),
+    case ExecuteBranch of
+        true ->
+            SessionKey = {SubscrId, ServerId},
+            mnesia:delete({session, Suffix}, SessionKey, Wlock),
+            Active = (Subscr#subscriber.active_sessions bxor ServerBit),
+            Subscr2 = Subscr#subscriber{active_sessions = Active},
+            mnesia:write(subscriber, Subscr2, Wlock),
+
+            ServerKey = {ServerId, Suffix},
+            [Server] = mnesia:read({server, Suffix}, ServerKey, Wlock),
+            Server2 = Server#server{no_of_delete = Server#server.no_of_delete + 1},
+            mnesia:write(server, Server2, Wlock);
+        false ->
+            ignore
+    end,
+    case DoRollback of
+        true ->
+            mnesia:abort({do_rollback, ExecuteBranch, []});
+        false ->
+            {do_commit, ExecuteBranch, []}
+    end.
+
+number_to_suffix(SubscrId) when is_integer(SubscrId) ->
+    SubscrId rem 100;
+number_to_suffix(<<_:8/binary, TimesTen:8/integer, TimesOne:8/integer>>) ->
+    ((TimesTen - $0) * 10) + (TimesOne - $0).
+
+number_to_key(Id, C) when is_integer(Id) ->
+    case C#config.use_binary_subscriber_key of
+	true ->
+	    list_to_binary(string:right(integer_to_list(Id), 10, $0));
+	false ->
+	    Id
+    end.
+