The R13B03 release.OTP_R13B03

1 files changed, 182 insertions, 0 deletions

diff --git a/lib/cosEventDomain/src/CosEventDomainAdmin_EventDomainFactory_impl.erl b/lib/cosEventDomain/src/CosEventDomainAdmin_EventDomainFactory_impl.erl
new file mode 100644
index 0000000000..1729402026
--- /dev/null
+++ b/lib/cosEventDomain/src/CosEventDomainAdmin_EventDomainFactory_impl.erl
@@ -0,0 +1,182 @@
+%%--------------------------------------------------------------------
+%%
+%% %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        : CosEventDomainAdmin_EventDomainFactory_impl.erl
+%% Description : 
+%%
+%%----------------------------------------------------------------------
+-module('CosEventDomainAdmin_EventDomainFactory_impl').
+
+%%----------------------------------------------------------------------
+%% Include files
+%%----------------------------------------------------------------------
+-include_lib("orber/include/corba.hrl").
+-include_lib("orber/include/ifr_types.hrl").
+-include_lib("cosNotification/include/CosNotification.hrl").
+
+-include("CosEventDomainAdmin.hrl").
+-include("cosEventDomainApp.hrl").
+
+%%----------------------------------------------------------------------
+%% External exports
+%%----------------------------------------------------------------------
+-export([init/1,
+	 terminate/2,
+	 code_change/3,
+	 handle_info/2]).
+
+-export([create_event_domain/4, 
+	 get_all_domains/2, 
+	 get_event_domain/3]).
+
+%%----------------------------------------------------------------------
+%% Internal exports
+%%----------------------------------------------------------------------
+-export([]).
+
+%%----------------------------------------------------------------------
+%% Records
+%%----------------------------------------------------------------------
+-record(state, {current_id = -1, domains = []}).
+
+%%----------------------------------------------------------------------
+%% Macros
+%%----------------------------------------------------------------------
+
+%%======================================================================
+%% External functions
+%%======================================================================
+%%----------------------------------------------------------------------
+%% Function   : init/1
+%% Returns    : {ok, State}          |
+%%              {ok, State, Timeout} |
+%%              ignore               |
+%%              {stop, Reason}
+%% Description: Initiates the server
+%%----------------------------------------------------------------------
+init([]) ->
+    process_flag(trap_exit, true),
+    {ok, #state{}}.
+
+%%----------------------------------------------------------------------
+%% Function   : terminate/2
+%% Returns    : any (ignored by gen_server)
+%% Description: Shutdown the server
+%%----------------------------------------------------------------------
+terminate(_Reason, _State) ->
+    ok.
+
+%%----------------------------------------------------------------------
+%% Function   : code_change/3
+%% Returns    : {ok, NewState}
+%% Description: Convert process state when code is changed
+%%----------------------------------------------------------------------
+code_change(_OldVsn, State, _Extra) ->
+    {ok, State}.
+
+%%----------------------------------------------------------------------
+%% Function   : handle_info/2
+%% Returns    : {noreply, State}   |
+%%              {stop, Reason, State}  
+%% Description: Handle, for example, exit signals.
+%%----------------------------------------------------------------------
+handle_info({'EXIT', Pid, _Reason}, State) ->
+    {noreply, State#state{domains=delete_domain(State#state.domains, Pid, [])}};
+handle_info(_Info, State) ->
+    {noreply, State}.
+
+
+%%----------------------------------------------------------------------
+%% Function   : create_event_domain
+%% Arguments  : InitialQoS - CosNotification::QoSProperties
+%%              InitialAdmin - CosNotification::AdminProperties
+%% Returns    : CosEventDomainAdmin::EventDomain |
+%%              {'EXCEPTION', #'CosNotification_UnsupportedQoS'{}} |
+%%              {'EXCEPTION', #'CosNotification_UnsupportedAdmin'{}} |
+%% Description: 
+%%----------------------------------------------------------------------
+create_event_domain(_OE_This, State, InitialQoS, InitialAdmin) ->
+    Id = cosEventDomainApp:create_id(State#state.current_id),
+    Admin = cosEventDomainApp:get_admin(InitialAdmin),
+    QoS = cosEventDomainApp:get_qos(InitialQoS),
+    case catch 'CosEventDomainAdmin_EventDomain':oe_create_link([self(), Id, 
+								 QoS, Admin], 
+								[{sup_child, true}]) of
+	{ok, Pid, ED} ->
+	    {reply, {ED, Id}, State#state{current_id = Id, 
+					  domains = [{Id, ED, Pid}|State#state.domains]}};
+	What ->
+	    orber:dbg("[~p] CosEventDomainAdmin_EventDomainFactory:"
+		      "create_event_domain();~n"
+		      "Failed creatin a new EventDomain due to: ~p", 
+		      [?LINE, What], ?DEBUG_LEVEL),
+	    corba:raise(#'INTERNAL'{completion_status=?COMPLETED_NO})
+    end.
+		    
+%%----------------------------------------------------------------------
+%% Function   : get_all_domains
+%% Arguments  : -
+%% Returns    : CosEventDomainAdmin::DomainIDSeq - [long()]
+%% Description: 
+%%----------------------------------------------------------------------
+get_all_domains(_OE_This, State) ->
+    {reply, get_all_domains_helper(State#state.domains, []), State}.
+
+get_all_domains_helper([], Acc) ->
+    Acc;
+get_all_domains_helper([{Id, _, _}|T], Acc) ->
+    get_all_domains_helper(T, [Id|Acc]).
+
+
+%%----------------------------------------------------------------------
+%% Function   : get_event_domain
+%% Arguments  : CosEventDomainAdmin::DomainID - long()
+%% Returns    : CosEventDomainAdmin::EventDomain |
+%%              {'EXCEPTION', #'CosEventDomainAdmin_DomainNotFound'{}} |
+%% Description: 
+%%----------------------------------------------------------------------
+get_event_domain(_OE_This, State, DomainID) ->
+    {reply, get_event_domain_helper(State#state.domains, DomainID), State}.
+
+get_event_domain_helper([], _) ->
+    corba:raise(#'CosEventDomainAdmin_DomainNotFound'{});
+get_event_domain_helper([{Id, ED, _}|_], Id) ->
+    ED;
+get_event_domain_helper([_|T], Id) ->
+    get_event_domain_helper(T, Id).
+
+%%======================================================================
+%% Internal functions
+%%======================================================================
+delete_domain([], _, Acc) ->
+    %% The domain didn't exist.
+    Acc;
+delete_domain([{_Id, _, Pid}], Pid, Acc) ->
+    Acc;
+delete_domain([{_Id, _, Pid}|T], Pid, Acc) ->
+    T++Acc;
+delete_domain([H|T], Pid, Acc) ->
+    delete_domain(T, Pid, [H|Acc]).
+
+%%======================================================================
+%% END OF MODULE
+%%======================================================================
+