diff options
Diffstat (limited to 'lib/orber/src/orber_ifr_repository.erl')
| -rw-r--r-- | lib/orber/src/orber_ifr_repository.erl | 286 |
1 files changed, 286 insertions, 0 deletions
diff --git a/lib/orber/src/orber_ifr_repository.erl b/lib/orber/src/orber_ifr_repository.erl new file mode 100644 index 0000000000..dde4d62562 --- /dev/null +++ b/lib/orber/src/orber_ifr_repository.erl @@ -0,0 +1,286 @@ +%%-------------------------------------------------------------------- +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 1997-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 : orber_ifr_repository.erl +%% Purpose : Code for Repository +%%---------------------------------------------------------------------- + +-module(orber_ifr_repository). + +-export(['_get_def_kind'/1, + destroy/1, + lookup/2, + contents/3, + lookup_name/5, + describe_contents/4, + create_module/4, + create_constant/6, + create_struct/5, + create_union/6, + create_enum/5, + create_alias/5, + create_interface/5, + create_exception/5, + lookup_id/2, + get_primitive/2, + create_string/2, + create_wstring/2, + create_fixed/3, + create_sequence/3, + create_array/3, + create_idltype/2, %not in CORBA 2.0 + create_primitivedef/1, %not in CORBA 2.0 + create_primitivedef/2 %not in CORBA 2.0 + ]). + + +-include("orber_ifr.hrl"). +-include("ifr_objects.hrl"). +-include_lib("orber/include/corba.hrl"). + +%%%====================================================================== +%%% Repository (Container (IRObject)) + +%%%---------------------------------------------------------------------- +%%% Interfaces inherited from IRObject + +'_get_def_kind'({ObjType, ObjID}) ?tcheck(ir_Repository, ObjType) -> + orber_ifr_irobject:'_get_def_kind'({ObjType, ObjID}). + +destroy({ObjType, ObjID}) ?tcheck(ir_Repository, ObjType) -> + orber:dbg("[~p] ~p:destroy(~p, ~p);~n" + "Destroying a repository is an error.~n", + [?LINE, ?MODULE, ObjType, ObjID], ?DEBUG_LEVEL), + corba:raise(#'INTF_REPOS'{completion_status=?COMPLETED_NO}). + +%%%---------------------------------------------------------------------- +%%% Interfaces inherited from Container + +lookup({ObjType,ObjID}, Search_name) ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:lookup({ObjType, ObjID}, Search_name). + +contents({ObjType,ObjID}, Limit_type, Exclude_inherited) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:contents({ObjType,ObjID},Limit_type,Exclude_inherited). + +lookup_name({ObjType,ObjID}, Search_name, Levels_to_search, Limit_type, + Exclude_inherited) ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:lookup_name({ObjType, ObjID}, Search_name, + Levels_to_search, Limit_type, + Exclude_inherited). + +describe_contents({ObjType,ObjID}, Limit_type, Exclude_inherited, + Max_returned_objs) ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:describe_contents({ObjType, ObjID}, Limit_type, + Exclude_inherited,Max_returned_objs). + +create_module({ObjType,ObjID}, Id, Name, Version) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_module({ObjType,ObjID}, Id, Name, Version). + +create_constant({ObjType,ObjID}, Id, Name, Version, Type, Value) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_constant({ObjType,ObjID}, Id, Name, Version, + Type, Value). + +create_struct({ObjType,ObjID}, Id, Name, Version, Members) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_struct({ObjType,ObjID}, Id, Name, Version, + Members). + +create_union({ObjType,ObjID}, Id, Name, Version, Discriminator_type, Members) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_union({ObjType,ObjID}, Id, Name, Version, + Discriminator_type, Members). + +create_enum({ObjType,ObjID}, Id, Name, Version, Members) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_enum({ObjType,ObjID},Id,Name,Version,Members). + +create_alias({ObjType,ObjID}, Id, Name, Version, Original_type) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_alias({ObjType,ObjID}, Id, Name, Version, + Original_type). + +create_interface({ObjType,ObjID}, Id, Name, Version, Base_interfaces) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_interface({ObjType,ObjID}, Id, Name, Version, + Base_interfaces). + +create_exception({ObjType, ObjID}, Id, Name, Version, Members) + ?tcheck(ir_Repository, ObjType) -> + orber_ifr_container:create_exception({ObjType, ObjID}, Id, Name, Version, + Members). + +%%%---------------------------------------------------------------------- +%%% Non-inherited interfaces + +lookup_id({ObjType,ObjID}, Search_id) ?tcheck(ir_Repository, ObjType) -> + Contents = orber_ifr_container:contents({ObjType, ObjID}, dk_All, false), + case lists:filter(fun(X) -> orber_ifr_contained:'_get_id'(X) == Search_id + end, Contents) of + [] -> + []; + [ObjRef] -> + ObjRef; + [H|T] -> + %% This case is just a safety-guard; orber_ifr_container:contents + %% sometimes return duplicates due to inheritance. + case lists:any(fun(X) -> X =/= H end, T) of + false -> + H; + true -> + corba:raise(#'INTERNAL'{completion_status=?COMPLETED_NO}) + end + end. + +get_primitive({ObjType,ObjID}, Kind) ?tcheck(ir_Repository, ObjType) -> + Primitivedefs = orber_ifr_utils:get_field({ObjType,ObjID}, primitivedefs), + lists:filter(fun(X) -> orber_ifr_primitivedef:'_get_kind'(X) == Kind end, + Primitivedefs). + +%% It is probably incorrect to add the anonymous typedefs (string, +%% sequence and array) to the field primitivdefs in the Repository. +%% It is probably also not correct to add them to the contents field. +%% Perhaps it is necessary to add another field in the ir_Repository +%% record for anonymous typedefs? Then again, perhaps it is not +%% necessary to keep the anonymous typedefs anywhere? According to +%% the specification it is the callers responsibility to destroy the +%% anonymous typedef if it is not successfully used. + +create_string({ObjType,_ObjID}, Bound) ?tcheck(ir_Repository, ObjType) -> + New_string = #ir_StringDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_String, + type = {tk_string, Bound}, + bound = Bound}, + orber_ifr_utils:makeref(New_string). + +create_wstring({ObjType,_ObjID}, Bound) ?tcheck(ir_Repository, ObjType) -> + NewWstring = #ir_WstringDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_Wstring, + type = {tk_wstring, Bound}, + bound = Bound}, + orber_ifr_utils:makeref(NewWstring). + +create_fixed({ObjType,_ObjID}, Digits, Scale) ?tcheck(ir_Repository, ObjType) -> + NewFixed = #ir_FixedDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_Fixed, + type = {tk_fixed, Digits, Scale}, + digits = Digits, + scale = Scale}, + orber_ifr_utils:makeref(NewFixed). + +create_sequence({ObjType,_ObjID}, Bound, Element_type) + ?tcheck(ir_Repository, ObjType) -> + Element_typecode = orber_ifr_utils:get_field(Element_type, type), + New_sequence = #ir_SequenceDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_Sequence, + type = {tk_sequence,Element_typecode,Bound}, + bound = Bound, + element_type = Element_typecode, + element_type_def = Element_type}, + orber_ifr_utils:makeref(New_sequence). + +create_array({ObjType,_ObjID}, Length, Element_type) + ?tcheck(ir_Repository, ObjType) -> + Element_typecode = orber_ifr_utils:get_field(Element_type, type), + New_array = #ir_ArrayDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_Array, + type = {tk_array, Element_typecode, Length}, + length = Length, + element_type = Element_typecode, + element_type_def = Element_type}, + orber_ifr_utils:makeref(New_array). + +%%%---------------------------------------------------------------------- +%%% Extra interfaces (not in the IDL-spec for the IFR). + +create_idltype(#orber_light_ifr_ref{} = LRef, _Typecode) -> + LRef; +create_idltype({ObjType,_ObjID}, Typecode) ?tcheck(ir_Repository, ObjType) -> + New_idltype = #ir_IDLType{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_none, + type=Typecode}, + orber_ifr_utils:set_object(New_idltype), + orber_ifr_utils:makeref(New_idltype). + +create_primitivedef(Pkind) -> + create_primitivedef(Pkind, true). +create_primitivedef(Pkind, Transaction) -> + Typecode = case Pkind of + pk_void -> + tk_void; + pk_short -> + tk_short; + pk_long -> + tk_long; + pk_longlong -> + tk_longlong; + pk_ushort -> + tk_ushort; + pk_ulong -> + tk_ulong; + pk_ulonglong -> + tk_ulonglong; + pk_float -> + tk_float; + pk_double -> + tk_double; + pk_boolean -> + tk_boolean; + pk_char -> + tk_char; + pk_wchar -> + tk_wchar; + pk_fixed -> + tk_fixed; + pk_octet -> + tk_octet; + pk_any -> + tk_any; + pk_TypeCode -> + tk_TypeCode; + pk_Principal -> + tk_Principal; + pk_string -> + orber_ifr_orb:create_string_tc(0); + pk_wstring -> + orber_ifr_orb:create_wstring_tc(0); + pk_objref -> + %%*** what should the Id and Name be here? + orber_ifr_orb:create_interface_tc("", ""); + _ -> + orber:dbg("[~p] ~p:destroy(~p);~n" + "Illegal primitivekin.~n", + [?LINE, ?MODULE, Pkind], ?DEBUG_LEVEL), + corba:raise(#'INTF_REPOS'{completion_status=?COMPLETED_NO}) + end, + New_primitivedef = #ir_PrimitiveDef{ir_Internal_ID = orber_ifr_utils:unique(), + def_kind = dk_Primitive, + type = Typecode, + kind = Pkind}, + case Transaction of + true -> + orber_ifr_utils:set_object(New_primitivedef); + false -> + mnesia:write(New_primitivedef) + end, + orber_ifr_utils:makeref(New_primitivedef). |