The R13B03 release.OTP_R13B03

1 files changed, 185 insertions, 0 deletions

diff --git a/lib/cosTransactions/src/ETraP_Common.erl b/lib/cosTransactions/src/ETraP_Common.erl
new file mode 100644
index 0000000000..dd68e9b038
--- /dev/null
+++ b/lib/cosTransactions/src/ETraP_Common.erl
@@ -0,0 +1,185 @@
+%%--------------------------------------------------------------------
+%%
+%% %CopyrightBegin%
+%% 
+%% Copyright Ericsson AB 1999-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    : ETraP_Common.erl
+%% Purpose : 
+%%----------------------------------------------------------------------
+
+-module('ETraP_Common').
+
+%%--------------- INCLUDES ----------------------------------
+-include_lib("orber/include/corba.hrl").
+-include_lib("orber/include/ifr_types.hrl").
+%% Local
+-include_lib("ETraP_Common.hrl").
+-include_lib("CosTransactions.hrl").
+
+%%--------------- EXPORTS -----------------------------------
+-export([try_timeout/1, 
+	 get_option/3, 
+	 create_name/2, 
+	 create_name/1,
+	 is_debug_compiled/0,
+	 send_stubborn/5,
+	 create_link/3]).
+
+%%--------------- DEFINITIONS OF CONSTANTS ------------------
+%%------------------------------------------------------------
+%% function : create_link
+%% Arguments: Module - which Module to call
+%%            Env/ARgList - ordinary oe_create arguments.
+%% Returns  : 
+%% Exception: 
+%% Effect   : Necessary since we want the supervisor to be a 
+%%            'simple_one_for_one'. Otherwise, using for example,
+%%            'one_for_one', we have to call supervisor:delete_child
+%%            to remove the childs startspecification from the 
+%%            supervisors internal state.
+%%------------------------------------------------------------
+create_link(Module, Env, ArgList) ->
+    Module:oe_create_link(Env, ArgList).
+
+%%------------------------------------------------------------
+%% function : get_option
+%% Arguments: 
+%% Returns  : 
+%% Exception: 
+%% Effect   : 
+%%------------------------------------------------------------
+
+get_option(Key, OptionList, DefaultList) ->
+    case lists:keysearch(Key, 1, OptionList) of
+        {value,{Key,Value}} ->
+            Value;
+        _ ->
+            case lists:keysearch(Key, 1, DefaultList) of
+                {value,{Key,Value}} ->
+                    Value;
+                _->
+                    {error, "Invalid option"}
+            end
+    end.
+%%------------------------------------------------------------
+%% function : create_name/2
+%% Arguments: 
+%% Returns  : 
+%% Exception: 
+%% Effect   : 
+%%------------------------------------------------------------
+ 
+create_name(Name,Type) ->
+    {MSec, Sec, USec} = erlang:now(),
+    lists:concat(['oe_',node(),'_',Type,'_',Name,'_',MSec, '_', Sec, '_', USec]).
+ 
+%%------------------------------------------------------------
+%% function : create_name/1
+%% Arguments: 
+%% Returns  : 
+%% Exception: 
+%% Effect   : 
+%%------------------------------------------------------------
+ 
+create_name(Type) ->
+    {MSec, Sec, USec} = erlang:now(),
+    lists:concat(['oe_',node(),'_',Type,'_',MSec, '_', Sec, '_', USec]).
+
+%%------------------------------------------------------------
+%% function : try_timeout
+%% Arguments: Id - name of the timeoutSrv server.
+%% Returns  : Boolean
+%% Exception: 
+%% Effect   : 
+%%------------------------------------------------------------
+
+try_timeout(TimeoutAt) ->
+    case TimeoutAt of
+	infinity ->
+	    false;
+	_->
+	    {MegaSecs, Secs, _Microsecs} = erlang:now(),
+	    Time  =  MegaSecs*1000000+Secs,
+	    if 
+		Time < TimeoutAt ->
+		    false;
+		true ->
+		    true
+	    end
+    end.
+
+%%------------------------------------------------------------
+%% function : send_stubborn
+%% Arguments: M - module
+%%            F - function
+%%            A - arguments
+%%            MaxR - Maximum no retries
+%%            Wait - sleep Wait seconds before next try.
+%% Returns  : see effect
+%% Exception: 
+%% Effect   : Retries repeatedly until anything else besides
+%%            'EXIT', 'COMM_FAILURE' or 'OBJECT_NOT_EXIST'
+%%------------------------------------------------------------
+
+send_stubborn(M, F, A, MaxR, Wait) when is_list(A) ->
+    send_stubborn(M, F, A, MaxR, Wait, 0);
+send_stubborn(M, F, A, MaxR, Wait) ->
+    send_stubborn(M, F, [A], MaxR, Wait, 0).
+send_stubborn(M, F, A, MaxR, _Wait, MaxR) ->
+    ?tr_error_msg("~p:~p( ~p ) failed!! Tried ~p times.~n", [M,F,A,MaxR]),
+    corba:raise(#'INTERNAL'{completion_status=?COMPLETED_NO});
+send_stubborn(M, F, A, MaxR, Wait, Times) ->
+    ?debug_print("~p:~p(~p)  # of retries: ~p~n", [M,F,A, Times]),    
+    case catch apply(M,F,A) of
+	{'EXCEPTION', E} when is_record(E, 'COMM_FAILURE')->
+	    NewTimes = Times +1,
+	    timer:sleep(Wait),
+	    send_stubborn(M, F, A, MaxR, Wait, NewTimes);
+	{'EXCEPTION', E} when is_record(E, 'TRANSIENT')->
+	    NewTimes = Times +1,
+	    timer:sleep(Wait),
+	    send_stubborn(M, F, A, MaxR, Wait, NewTimes);
+	{'EXCEPTION', E} when is_record(E, 'TIMEOUT')->
+	    NewTimes = Times +1,
+	    timer:sleep(Wait),
+	    send_stubborn(M, F, A, MaxR, Wait, NewTimes);
+	{'EXIT', _} ->
+	    NewTimes = Times +1,
+	    timer:sleep(Wait),
+	    send_stubborn(M, F, A, MaxR, Wait, NewTimes);
+	Other ->
+	    ?debug_print("~p:~p(~p) Resulted in: ~p~n", [M,F,A, Other]),    
+	    Other
+    end.
+
+%%------------------------------------------------------------
+%% function : is_debug_compiled
+%% Arguments: 
+%% Returns  : 
+%% Exception: 
+%% Effect   : 
+%%------------------------------------------------------------
+
+-ifdef(debug).
+    is_debug_compiled() -> true.
+-else.
+    is_debug_compiled() -> false.
+-endif.
+
+%%--------------- END OF MODULE ------------------------------