%%-------------------------------------------------------------------- %% %% %CopyrightBegin% %% %% Copyright Ericsson AB 1997-2016. All Rights Reserved. %% %% Licensed under the Apache License, Version 2.0 (the "License"); %% you may not use this file except in compliance with the License. %% You may obtain a copy of the License at %% %% http://www.apache.org/licenses/LICENSE-2.0 %% %% Unless required by applicable law or agreed to in writing, software %% distributed under the License is distributed on an "AS IS" BASIS, %% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. %% See the License for the specific language governing permissions and %% limitations under the License. %% %% %CopyrightEnd% %% %% %%----------------------------------------------------------------- %% File: iop_ior.erl %% Description: %% This file contains the IOP::IOR handling %% %%----------------------------------------------------------------- -module(iop_ior). -include_lib("orber/include/corba.hrl"). -include_lib("orber/src/orber_iiop.hrl"). %%----------------------------------------------------------------- %% External exports %%----------------------------------------------------------------- -export([code/4, decode/4, string_decode/1, string_code/1, string_code/2, string_code/3, string_code/4, get_key/1, get_key/2, get_typeID/1, create/9, get_objkey/1, check_nil/1, get_privfield/1, set_privfield/2, get_orbfield/1, set_orbfield/2, get_flagfield/1, set_flagfield/2, create_external/5, create_external/6, print/1, print/2, get_alt_addr/1, add_component/2, get_peerdata/1]). %%----------------------------------------------------------------- %% Internal exports %%----------------------------------------------------------------- %%----------------------------------------------------------------- %% Macros %%----------------------------------------------------------------- -define(DEBUG_LEVEL, 6). %%----------------------------------------------------------------- %% External interface functions %%----------------------------------------------------------------- %%----------------------------------------------------------------- %% Func: create/5/6 %%----------------------------------------------------------------- %% There are a few restrictions if a certain IIOP-version may contain certain components %% and contexts The ones we currently, and the ones we perhaps will, support is: %% %% Feature 1.0 1.1 1.2 %% TransactionService Service Context yes yes yes %% CodeSets Service Context yes yes %% Object by Value Service Context yes %% Bi-Directional IIOP Service Context yes %% IOR components in IIOP profile yes yes %% TAG_ORB_TYPE yes yes %% TAG_CODE_SETS yes yes %% TAG_ALTERNATE_IIOP_ADDRESS yes %% TAG_SSL_SEC_TRANS yes yes %% Extended IDL data types yes yes %% Bi-Directional GIOP Features yes %% Value types and Abstract Interfaces yes %% %% CSIv2: %% A target that supports unprotected IIOP invocations shall specify in the %% corresponding TAG_INTERNET_IOP profile a nonzero port number at which the %% target will accept unprotected invocations.9 A target that supports only %% protected IIOP invocations shall specify a port number of 0 (zero) in the %% corresponding TAG_INTERNET_IOP profile. %%----------------------------------------------------------------- create({1, 0}, TypeID, Hosts, IIOPPort, _, Objkey, _, _, _) -> Template = #'IIOP_ProfileBody_1_0'{iiop_version = #'IIOP_Version'{major=1, minor=0}, port = IIOPPort, object_key = Objkey}, #'IOP_IOR'{type_id=TypeID, profiles=duplicate_1_0_profiles(Hosts, Template, [])}; create({1, Minor}, TypeID, Hosts, IIOPPort, -1, Objkey, MC, _, _) -> Template = #'IIOP_ProfileBody_1_1'{iiop_version = #'IIOP_Version'{major=1, minor=Minor}, port = IIOPPort, object_key = Objkey, components = MC}, #'IOP_IOR'{type_id=TypeID, profiles=duplicate_1_1_profiles(Hosts, Template, [])}; create({1, Minor}, TypeID, Hosts, IIOPPort, SSLPort, Objkey, MC, Flags, EnvFlags) -> V=#'IIOP_Version'{major=1, minor=Minor}, UseCSIv2 = ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_USE_CSIV2), Template = case ?ORB_FLAG_TEST(Flags, ?ORB_NO_SECURITY) of true -> #'IIOP_ProfileBody_1_1'{iiop_version = V, port = IIOPPort, object_key = Objkey, components = MC}; false when UseCSIv2 == false -> #'IIOP_ProfileBody_1_1'{iiop_version=V, port=IIOPPort, object_key=Objkey, components= [#'IOP_TaggedComponent' {tag=?TAG_SSL_SEC_TRANS, component_data=#'SSLIOP_SSL'{target_supports = 2, target_requires = 2, port = SSLPort}}|MC]}; false when UseCSIv2 == true -> #'IIOP_ProfileBody_1_1' {iiop_version=V, port=0, object_key=Objkey, components= [#'IOP_TaggedComponent' {tag = ?TAG_CSI_SEC_MECH_LIST, component_data = #'CSIIOP_CompoundSecMechList' {stateful = false, mechanism_list = [#'CSIIOP_CompoundSecMech' {target_requires = 6, transport_mech = #'IOP_TaggedComponent' {tag=?TAG_TLS_SEC_TRANS, component_data=#'CSIIOP_TLS_SEC_TRANS' {target_supports = 7, target_requires = 8, addresses = [#'CSIIOP_TransportAddress'{host_name = "Host", port = SSLPort}]}}, as_context_mech = #'CSIIOP_AS_ContextSec' {target_supports = 9, target_requires = 10, client_authentication_mech = [1, 255], target_name = [2,255]}, sas_context_mech = #'CSIIOP_SAS_ContextSec' {target_supports = 11, target_requires = 12, privilege_authorities = [#'CSIIOP_ServiceConfiguration' {syntax = ?ULONGMAX, name = [3,255]}], supported_naming_mechanisms = [[4,255],[5,255]], supported_identity_types = ?ULONGMAX}}]}}|MC]} end, #'IOP_IOR'{type_id=TypeID, profiles=duplicate_1_1_profiles(Hosts, Template, [])}; create(Version, TypeID, Host, IIOPPort, SSLPort, Objkey, MC, _, _) -> orber:dbg("[~p] iop_ior:create(~p, ~p, ~p, ~p, ~p, ~p, ~p);~n" "Unsupported IIOP-version.", [?LINE, Version, TypeID, Host, IIOPPort, SSLPort, Objkey, MC], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). duplicate_1_1_profiles([], _, Profiles) -> Profiles; duplicate_1_1_profiles([H|T], Template, Profiles) -> duplicate_1_1_profiles(T, Template, [#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data = Template#'IIOP_ProfileBody_1_1'{host = H}}|Profiles]). duplicate_1_0_profiles([], _, Profiles) -> Profiles; duplicate_1_0_profiles([H|T], Template, Profiles) -> duplicate_1_0_profiles(T, Template, [#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data = Template#'IIOP_ProfileBody_1_0'{host = H}}|Profiles]). %%----------------------------------------------------------------- %% Func: create_external/5/6 %%----------------------------------------------------------------- create_external(Version, TypeID, Host, IIOP_port, Objkey) -> create_external(Version, TypeID, Host, IIOP_port, Objkey, []). create_external({1, 0}, TypeID, Host, IIOP_port, Objkey, _MC) -> V=#'IIOP_Version'{major=1, minor=0}, PB=#'IIOP_ProfileBody_1_0'{iiop_version=V, host=Host, port=IIOP_port, object_key=Objkey}, #'IOP_IOR'{type_id=TypeID, profiles=[#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}]}; create_external({1, 1}, TypeID, Host, IIOP_port, Objkey, Components) -> V=#'IIOP_Version'{major=1, minor=1}, PB=#'IIOP_ProfileBody_1_1'{iiop_version=V, host=Host, port=IIOP_port, object_key=Objkey, components=Components}, #'IOP_IOR'{type_id=TypeID, profiles=[#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}]}; create_external({1, 2}, TypeID, Host, IIOP_port, Objkey, Components) -> V=#'IIOP_Version'{major=1, minor=2}, PB=#'IIOP_ProfileBody_1_1'{iiop_version=V, host=Host, port=IIOP_port, object_key=Objkey, components=Components}, #'IOP_IOR'{type_id=TypeID, profiles=[#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}]}; create_external(Version, TypeID, Host, IIOP_port, Objkey, MC) -> orber:dbg("[~p] iop_ior:create_external(~p, ~p, ~p, ~p, ~p, ~p);~n" "Unsupported IIOP-version.", [?LINE, Version, TypeID, Host, IIOP_port, Objkey, MC], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). %%----------------------------------------------------------------- %% Func: get_peerdata/1 %%----------------------------------------------------------------- %% Probably an external IOR. get_peerdata(#'IOP_IOR'{} = IOR) -> get_peerdata(get_key(IOR), IOR, [], []); %% Local object reference. get_peerdata(_) -> []. %% "Plain" TCP/IP. get_peerdata({'external', {Host, Port, _InitObjkey, Index, TaggedProfile, #host_data{protocol = normal, csiv2_mech = undefined}}}, IOR, Acc, Indexes) -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, [{Host, Port}|Alts] ++ Acc, [Index|Indexes]); %% "Plain" SSL get_peerdata({'external', {Host, _Port, _InitObjkey, Index, TaggedProfile, #host_data{protocol = ssl, ssl_data = #'SSLIOP_SSL'{port = Port}, csiv2_mech = undefined}}}, IOR, Acc, Indexes) -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, [{Host, Port}|Alts] ++ Acc, [Index|Indexes]); %% TEMPORARY FIX TO SKIP CSIv2 DATA. get_peerdata({'external', {Host, _Port, _InitObjkey, Index, TaggedProfile, #host_data{protocol = ssl, ssl_data = #'SSLIOP_SSL'{port = Port}}}}, IOR, Acc, Indexes) -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, [{Host, Port}|Alts] ++ Acc, [Index|Indexes]); %% CSIv2 over SSL (TAG_TLS_SEC_TRANS) using the SAS protocol. Note port must equal 0. get_peerdata({'external', {_Host, 0, _InitObjkey, Index, TaggedProfile, #host_data{protocol = ssl, csiv2_mech = #'CSIIOP_CompoundSecMech'{target_requires = _TR} = _Mech, csiv2_addresses = Addresses}}}, IOR, Acc, Indexes) -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, Addresses ++ Alts ++ Acc, [Index|Indexes]); %% CSIv2 over SSL (TAG_NULL_TAG) using the SAS protocol. get_peerdata({'external', {Host, _Port, _InitObjkey, Index, TaggedProfile, #host_data{protocol = ssl, ssl_data = #'SSLIOP_SSL'{port = Port}, csiv2_mech = Mech}}}, IOR, Acc, Indexes) when is_record(Mech, 'CSIIOP_CompoundSecMech') -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, [{Host, Port}|Alts] ++ Acc, [Index|Indexes]); %% CSIv2 over TCP (TAG_NULL_TAG) using the SAS protocol. get_peerdata({'external', {Host, Port, _InitObjkey, Index, TaggedProfile, #host_data{protocol = normal, csiv2_mech = Mech}}}, IOR, Acc, Indexes) when is_record(Mech, 'CSIIOP_CompoundSecMech') -> Alts = get_alt_addr(TaggedProfile), get_peerdata(get_key(IOR, [Index|Indexes]), IOR, [{Host, Port}|Alts] ++ Acc, [Index|Indexes]); get_peerdata(undefined, _IOR, Acc, _Indexes) -> Acc; %% Local object reference. get_peerdata(_, _, _, _) -> []. %%----------------------------------------------------------------- %% Func: get_key/1 %%----------------------------------------------------------------- get_key(#'IOP_IOR'{profiles=P}) -> get_key_1(P, false, 0, undefined, #host_data{}); get_key({Module, Type, Key, _UserDef, OrberDef, Flags}) -> if is_binary(Key) -> {'internal', Key, OrberDef, Flags, Module}; Type == pseudo -> {'internal_registered', {pseudo, Key}, OrberDef, Flags, Module}; is_atom(Key) -> {'internal_registered', Key, OrberDef, Flags, Module} end; get_key(What) -> orber:dbg("[~p] iop_ior:get_key(~p); Invalid IOR", [?LINE, What], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). get_key(#'IOP_IOR'{profiles=P}, Exclude) -> get_key_1(P, true, 0, Exclude, #host_data{}); get_key(What, _Exclude) -> orber:dbg("[~p] iop_ior:get_key(~p); Invalid IOR", [?LINE, What], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). get_key_1([], false, _, _, _) -> orber:dbg("[~p] iop_ior:get_key_1([]); bad object reference, profile not found.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); get_key_1([], true, _, _, _) -> undefined; %%--------- Local IIOP-1.0 Profile --------- get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_0' {object_key={Module, Type, Key, _UserDef, OrberDef, Flags}}}|_], _Retry, _Counter, _Exclude, _HD) -> if is_binary(Key) -> {'internal', Key, OrberDef, Flags, Module}; Type == pseudo -> {'internal_registered', {pseudo, Key}, OrberDef, Flags, Module}; is_atom(Key) -> {'internal_registered', Key, OrberDef, Flags, Module} end; %%--------- Local IIOP-1.1 & IIOP-1.2 Profiles --------- get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1' {object_key={Module, Type, Key, _UserDef, OrberDef, Flags}}}|_], _Retry, _Counter, _Exclude, _HD) -> if is_binary(Key) -> {'internal', Key, OrberDef, Flags, Module}; Type == pseudo -> {'internal_registered', {pseudo, Key}, OrberDef, Flags, Module}; Type == passive -> %% CHECK FOR PRIMARY COMPONENT & GROUPID! Better yet, do not. %% This is internal key and is supposed to be well formed. %% Also, internal keys are not searched for primary member or %% groupid in the component-section of IOR. ObjectKey will tell %% GroupID and database read transaction will tell primary member. {'internal_registered', {passive, Key}, OrberDef, Flags, Module}; is_atom(Key) -> {'internal_registered', Key, OrberDef, Flags, Module} end; %%--------- External IIOP-1.0 Profile --------- get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_0' {host = Host, port = Port, object_key= ObjectKey}} = TP|P], _Retry, Counter, Exclude, HD) when Exclude == undefined -> %% This case is "necessary" if an ORB adds several IIOP-profiles since, %% for example, wchar isn't supported for 1.0. case get_key_1(P, true, Counter+1, Exclude, HD) of undefined -> %% We now it's IIOP-1.0 and it doesn't contain any %% components. Hence, no need to check for it. {'external', {Host, Port, ObjectKey, Counter, TP, HD#host_data{version = {1,0}}}}; LaterVersion -> LaterVersion end; get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_0' {host = Host, port = Port, object_key= ObjectKey}} = TP|P], Retry, Counter, Exclude, HD) -> case lists:member(Counter, Exclude) of true -> get_key_1(P, Retry, Counter+1, Exclude, HD); false -> %% This case is "necessary" if an ORB adds several IIOP-profiles since, %% for example, wchar isn't supported for 1.0. case get_key_1(P, true, Counter+1, Exclude, HD) of undefined -> {'external', {Host, Port, ObjectKey, Counter, TP, HD#host_data{version = {1,0}}}}; LaterVersion -> LaterVersion end end; %%--------- External IIOP-1.1 & IIOP-1.2 Profiles --------- get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1' {iiop_version = #'IIOP_Version'{major=Major, minor=Minor}, host = Host, port = Port, object_key= ObjectKey, components = Components}} = TP|P], Retry, Counter, Exclude, HD) when Exclude == undefined -> case check_components(Components, Port, HD#host_data{version = {Major,Minor}}) of #host_data{csiv2_mech = undefined} when Port == 0 -> get_key_1(P, Retry, Counter+1, Exclude, HD); NewHD -> {'external', {Host, Port, ObjectKey, Counter, TP, NewHD}} end; get_key_1([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1' {iiop_version = #'IIOP_Version'{major=Major, minor=Minor}, host = Host, port = Port, object_key= ObjectKey, components = Components}} = TP|P], Retry, Counter, Exclude, HD) -> case lists:member(Counter, Exclude) of true -> get_key_1(P, Retry, Counter+1, Exclude, HD); false -> case check_components(Components, Port, HD#host_data{version = {Major,Minor}}) of #host_data{csiv2_mech = undefined} when Port == 0 -> get_key_1(P, Retry, Counter+1, Exclude, HD); NewHD -> {'external', {Host, Port, ObjectKey, Counter, TP, NewHD}} end end; get_key_1([_ | P], Retry, Counter, Exclude, HD) -> get_key_1(P, Retry, Counter+1, Exclude, HD). check_components([], _, HostData) -> HostData; check_components([#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=SSLStruct}|Rest], Port, HostData) when is_record(SSLStruct, 'SSLIOP_SSL') -> check_components(Rest, Port, HostData#host_data{protocol = ssl, ssl_data = SSLStruct}); %% CSIv2 Components check_components([#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=Data}|Rest], Port, HostData) when is_record(Data, 'CSIIOP_CompoundSecMechList') -> case check_sec_mech(Data#'CSIIOP_CompoundSecMechList'.mechanism_list, Port) of undefined -> check_components(Rest, Port, HostData); {ok, Protocol, Mech, Addresses} -> check_components(Rest, Port, HostData#host_data {protocol = Protocol, csiv2_mech = Mech, csiv2_statefull = Data#'CSIIOP_CompoundSecMechList'.stateful, csiv2_addresses = Addresses}); {ok, Mech} -> check_components(Rest, Port, HostData#host_data {csiv2_mech = Mech, csiv2_statefull = Data#'CSIIOP_CompoundSecMechList'.stateful}) end; %% FT Components check_components([#'IOP_TaggedComponent' {tag=?TAG_FT_HEARTBEAT_ENABLED, component_data= #'FT_TagFTHeartbeatEnabledTaggedComponent' {heartbeat_enabled = Boolean}}|Rest], Port, HostData) -> check_components(Rest, Port, HostData#host_data{ft_heartbeat = Boolean}); check_components([#'IOP_TaggedComponent' {tag=?TAG_FT_PRIMARY, component_data= #'FT_TagFTPrimaryTaggedComponent'{primary = Boolean}}|Rest], Port, HostData) -> check_components(Rest, Port, HostData#host_data{ft_primary = Boolean}); check_components([#'IOP_TaggedComponent' {tag=?TAG_FT_GROUP, component_data=#'FT_TagFTGroupTaggedComponent' {version = #'GIOP_Version'{major = 1, minor = 0}, ft_domain_id = FTDomain, object_group_id = GroupID, object_group_ref_version = GroupVer}}|Rest], Port, HostData) -> check_components(Rest, Port, HostData#host_data{ft_domain = FTDomain, ft_group = GroupID, ft_ref_version = GroupVer}); %% CodeSets Component check_components([#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=#'CONV_FRAME_CodeSetComponentInfo' {'ForCharData' = Char, 'ForWcharData' = Wchar}}|Rest], Port, HostData) -> CharData = check_char_codeset(Char), WcharData = check_wchar_codeset(Wchar), check_components(Rest, Port, HostData#host_data{charset = CharData, wcharset = WcharData}); %% Not used check_components([_ | Rest], Port, HostData) -> check_components(Rest, Port, HostData). check_sec_mech([], _) -> undefined; %% Not supported yet. %check_sec_mech([#'CSIIOP_CompoundSecMech' % {target_requires = TR, % transport_mech= % #'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS}} = Mech|_], % Port) -> % {ok, seciop, Mech}; check_sec_mech([#'CSIIOP_CompoundSecMech' {target_requires = TR, transport_mech= #'IOP_TaggedComponent'{tag = ?TAG_TLS_SEC_TRANS, component_data = CD}} = Mech|_], _Port) when TR =< ?CSIv2_MAX_TARGET_REQUIRES -> {ok, ssl, Mech, extract_host_port(CD#'CSIIOP_TLS_SEC_TRANS'.addresses, [])}; %% The TAG_NULL_TAG component shall be used in the 'transport_mech' field to %% indicate that a mechanism does not implement security functionality at the %% transport layer. %% If the port field in TAG_INTERNET_IOP equals 0 we must find a TAG_TLS_SEC_TRANS %% or TAG_SECIOP_SEC_TRANS mechanism. check_sec_mech([#'CSIIOP_CompoundSecMech' {transport_mech= #'IOP_TaggedComponent'{tag = ?TAG_NULL_TAG}}|Rest], 0) -> check_sec_mech(Rest, 0); check_sec_mech([#'CSIIOP_CompoundSecMech' {target_requires = TR, transport_mech= #'IOP_TaggedComponent'{tag = ?TAG_NULL_TAG}} = Mech|_], _Port) when TR =< ?CSIv2_MAX_TARGET_REQUIRES -> {ok, Mech}; %% Unrecognized or the peer requires more than we support. check_sec_mech([_ | Rest], Port) -> check_sec_mech(Rest, Port). extract_host_port([], Acc) -> Acc; extract_host_port([#'CSIIOP_TransportAddress'{host_name = Host, port = Port}|Rest], Acc) -> extract_host_port(Rest, [{Host, Port}|Acc]). check_char_codeset(#'CONV_FRAME_CodeSetComponent'{native_code_set=?ISO8859_1_ID}) -> ?ISO8859_1_ID; check_char_codeset(#'CONV_FRAME_CodeSetComponent'{native_code_set=?ISO646_IRV_ID}) -> ?ISO646_IRV_ID; check_char_codeset(#'CONV_FRAME_CodeSetComponent'{conversion_code_sets=Converters}) -> %% Since the list of Converters usually is very short (0 or 1 element) we %% can use lists:member. case lists:member(?ISO8859_1_ID, Converters) of true -> ?ISO8859_1_ID; false -> %% Since we are 100% sure strings will be (e.g. IFR-ids) used we %% can raise an exception at this point. orber:dbg("[~p] iop_ior:check_char_codeset(~p);~n" "Orber cannot communicate with this ORB.~n" "It doesn't support a Char CodeSet known to Orber.", [?LINE, Converters], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status = ?COMPLETED_NO}) end. check_wchar_codeset(#'CONV_FRAME_CodeSetComponent'{native_code_set=?UTF_16_ID}) -> ?UTF_16_ID; check_wchar_codeset(#'CONV_FRAME_CodeSetComponent'{native_code_set=?UCS_2_ID}) -> ?UCS_2_ID; check_wchar_codeset(#'CONV_FRAME_CodeSetComponent'{conversion_code_sets=Converters}) -> case lists:member(?UTF_16_ID, Converters) of true -> ?UTF_16_ID; false -> %% We should not raise an exception here since we do not know if %% wchar/wstring is used. ?UTF_16_ID % ?UNSUPPORTED_WCHAR end. %%----------------------------------------------------------------- %% Func: add_component/2 %%----------------------------------------------------------------- add_component(Objref, Component) when is_record(Objref, 'IOP_IOR') -> add_component_ior(Objref, Component); add_component(Objref, Component) -> add_component_local(Objref, Component, orber:giop_version()). add_component_local(_, Component, {1,0}) -> orber:dbg("[~p] iop_ior:add_component(~p);~n" "IIOP-1.0 objects cannot contain any components.", [?LINE, Component], ?DEBUG_LEVEL), corba:raise(#'BAD_PARAM'{completion_status = ?COMPLETED_NO}); add_component_local(_, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS} = Component, {1,1}) -> orber:dbg("[~p] iop_ior:add_component(~p);~n" "IIOP-1.1 objects may not contain ALTERNATE_IIOP_ADDRESS components.", [?LINE, Component], ?DEBUG_LEVEL), corba:raise(#'BAD_PARAM'{completion_status = ?COMPLETED_NO}); add_component_local({Mod, Type, Key, UserDef, OrberDef, Flags}, Component, Version) -> EnvFlags = orber:get_flags(), MC = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_EXCLUDE_CODESET_COMPONENT) of true -> [Component]; false -> [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=?DEFAULT_CODESETS}, Component] end, case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_ENABLE_NAT) of false -> create(Version, Mod:typeID(), orber:host(), orber:iiop_port(), orber:iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags); true -> create(Version, Mod:typeID(), orber:nat_host(), orber:nat_iiop_port(), orber:nat_iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags) end. add_component_ior(#'IOP_IOR'{profiles=P} = IOR, Component) -> case add_component_ior_helper(P, Component, false, []) of {false, _} -> orber:dbg("[~p] iop_ior:add_component_ior(~p);~n" "The IOR do not contain a valid IIOP-version for the supplied component.", [?LINE, Component], ?DEBUG_LEVEL), corba:raise(#'BAD_PARAM'{completion_status = ?COMPLETED_NO}); {_, NewProfiles} -> IOR#'IOP_IOR'{profiles=NewProfiles} end. add_component_ior_helper([], _Component, Status, Acc) -> {Status, Acc}; add_component_ior_helper([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1' {iiop_version= #'IIOP_Version'{minor=1}}}|T], #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS} = Component, Status, Acc) -> %% 'ALTERNATE_IIOP_ADDRESS' may only be added to IIOP-1.2 IOR's. add_component_ior_helper(T, Component, Status, Acc); add_component_ior_helper([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1' {object_key=Objkey, components=Components} = PB} = H|T], Component, _Status, Acc) when is_tuple(Objkey) -> %% The objectkey must be a tuple if it's a local object. We cannot(!!) add components %% to an external IOR. add_component_ior_helper(T, Component, true, [H#'IOP_TaggedProfile' {profile_data=PB#'IIOP_ProfileBody_1_1' {components = [Component|Components]}}|Acc]); add_component_ior_helper([_|T], Component, Status, Acc) -> add_component_ior_helper(T, Component, Status, Acc). %%----------------------------------------------------------------- %% Func: get_alt_addr/1 %%----------------------------------------------------------------- %% TAG_ALTERNATE_IIOP_ADDRESS may only occur in IIOP-1.2 IOR's. get_alt_addr(#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data=#'IIOP_ProfileBody_1_1'{iiop_version= #'IIOP_Version'{minor=2}, components=Components}}) -> get_alt_addr_helper(Components, []); get_alt_addr(_) -> []. get_alt_addr_helper([], Acc) -> Acc; get_alt_addr_helper([#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=#'ALTERNATE_IIOP_ADDRESS' {'HostID'=Host, 'Port'=Port}}|T], Acc) -> get_alt_addr_helper(T, [{Host, Port}|Acc]); get_alt_addr_helper([_|T], Acc) -> get_alt_addr_helper(T, Acc). %%----------------------------------------------------------------- %% Func: get_typeID/1 %%----------------------------------------------------------------- get_typeID(#'IOP_IOR'{type_id=TypeID}) -> TypeID; get_typeID({Mod, _Type, _Key, _UserDef, _OrberDef, _Flags}) -> Mod:typeID(). %%----------------------------------------------------------------- %% Func: get_objkey/1 %%----------------------------------------------------------------- get_objkey(#'IOP_IOR'{profiles=P}) -> get_objkey_1(P); get_objkey({Id, Type, Key, UserDef, OrberDef, Flags}) -> {Id, Type, Key, UserDef, OrberDef, Flags}. get_objkey_1([]) -> orber:dbg("[~p] iop_ior:get_objkey_1([]); bad object key, profile not found.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); get_objkey_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB} |_]) -> [_, _, _, _, ObjectKey | _] = tuple_to_list(PB), ObjectKey; get_objkey_1([_ | P]) -> get_objkey_1(P). %%----------------------------------------------------------------- %% Func: get_privfield/1 %%----------------------------------------------------------------- get_privfield(#'IOP_IOR'{profiles=P}) -> get_privfield_1(P); get_privfield({_Id, _Type, _Key, UserDef, _OrberDef, _Flags}) -> UserDef. get_privfield_1([]) -> orber:dbg("[~p] iop_ior:get_privfield_1([]); bad object key, profile not found.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); get_privfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}|_]) -> [_, _, _, _, ObjectKey | _] = tuple_to_list(PB), case ObjectKey of {_Id, _Type, _Key, UserDef, _OrberDef, _Flags} -> UserDef; _ -> orber:dbg("[~p] iop_ior:get_privfield_1(~p); bad object key.", [?LINE, ObjectKey], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}) end; get_privfield_1([_| P]) -> get_privfield_1(P). %%----------------------------------------------------------------- %% Func: set_privfield/2 %%----------------------------------------------------------------- set_privfield(#'IOP_IOR'{type_id=Id, profiles=P}, UserData) -> #'IOP_IOR'{type_id=Id, profiles=set_privfield_1(P, UserData)}; set_privfield({Id, Type, Key, _, OrberDef, Flags}, UserData) -> {Id, Type, Key, UserData, OrberDef, Flags}. set_privfield_1([], _) -> orber:dbg("[~p] iop_ior:set_privfield_1([]); bad object key, profile not found or external object.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); set_privfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}|P], UserData) -> [RecName, Version, Host, IIOP_port, ObjectKey | Rest] = tuple_to_list(PB), case ObjectKey of {Id, Type, Key, _, OrberDef, Flags} -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=list_to_tuple([RecName, Version, Host, IIOP_port, {Id, Type, Key, UserData, OrberDef, Flags}| Rest])} | set_privfield_1(P, UserData)]; _ -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB} | set_privfield_1(P, UserData)] end; set_privfield_1([PB| P], UserData) -> [PB | set_privfield_1(P, UserData)]. %%----------------------------------------------------------------- %% Func: get_orbfield/1 %%----------------------------------------------------------------- get_orbfield(#'IOP_IOR'{profiles=P}) -> get_orbfield_1(P); get_orbfield({_Id, _Type, _Key, _UserDef, OrberDef, _Flags}) -> OrberDef. get_orbfield_1([]) -> orber:dbg("[~p] iop_ior:get_orbfield_1([]);~n" "bad object key, profile not found.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); get_orbfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}|_]) -> [_, _, _, _, ObjectKey | _] = tuple_to_list(PB), case ObjectKey of {_Id, _Type, _Key, _UserDef, OrberDef, _Flags} -> OrberDef; _ -> orber:dbg("[~p] iop_ior:get_orbfield_1(~p);~n" "bad object key.", [?LINE, ObjectKey], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}) end; get_orbfield_1([_| P]) -> get_orbfield_1(P). %%----------------------------------------------------------------- %% Func: set_orbfield/2 %%----------------------------------------------------------------- set_orbfield(#'IOP_IOR'{type_id=Id, profiles=P}, OrberDef) -> #'IOP_IOR'{type_id=Id, profiles=set_orbfield_1(P, OrberDef)}; set_orbfield({Id, Type, Key, Priv, _, Flags}, OrberDef) -> {Id, Type, Key, Priv, OrberDef, Flags}. set_orbfield_1([], _) -> orber:dbg("[~p] iop_ior:set_orbfield_1([]);~n" "bad object key, profile not found or external object.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); set_orbfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}| P], OrberDef) -> [RecName, Version, Host, IIOP_port, ObjectKey | Rest] = tuple_to_list(PB), case ObjectKey of {Id, Type, Key, Priv, _, Flags} -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=list_to_tuple([RecName, Version, Host, IIOP_port, {Id, Type, Key, Priv, OrberDef, Flags}| Rest])} | set_orbfield_1(P, OrberDef)]; _ -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB} | set_orbfield_1(P, OrberDef)] end; set_orbfield_1([PB| P], OrberDef) -> [PB | set_orbfield_1(P, OrberDef)]. %%----------------------------------------------------------------- %% Func: get_flagfield/1 %%----------------------------------------------------------------- get_flagfield(#'IOP_IOR'{profiles=P}) -> get_flagfield_1(P); get_flagfield({_Id, _Type, _Key, _UserDef, _OrberDef, Flags}) -> Flags. get_flagfield_1([]) -> orber:dbg("[~p] iop_ior:get_flagfield_1([]); bad object key, profile not found.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); get_flagfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}|_]) -> [_, _, _, _, ObjectKey | _] = tuple_to_list(PB), case ObjectKey of {_Id, _Type, _Key, _UserDef, _OrberDef, Flags} -> Flags; _ -> orber:dbg("[~p] iop_ior:get_flagfield_1(~p); bad object key.", [?LINE, ObjectKey], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}) end; get_flagfield_1([_| P]) -> get_flagfield_1(P). %%----------------------------------------------------------------- %% Func: set_flagfield/2 %%----------------------------------------------------------------- set_flagfield(#'IOP_IOR'{type_id=Id, profiles=P}, Flags) -> #'IOP_IOR'{type_id=Id, profiles=set_flagfield_1(P, Flags)}; set_flagfield({Id, Type, Key, Priv, OrberDef, _}, Flags) -> {Id, Type, Key, Priv, OrberDef, Flags}. set_flagfield_1([], _) -> orber:dbg("[~p] iop_ior:set_flagfield_1([]); bad object key, profile not found or external object.", [?LINE], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}); set_flagfield_1([#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB}| P], Flags) -> [RecName, Version, Host, IIOP_port, ObjectKey | Rest] = tuple_to_list(PB), case ObjectKey of {Id, Type, Key, Priv, OrberDef, _} -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=list_to_tuple([RecName, Version, Host, IIOP_port, {Id, Type, Key, Priv, OrberDef, Flags}| Rest])} | set_flagfield_1(P, Flags)]; _ -> [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=PB} | set_flagfield_1(P, Flags)] end; set_flagfield_1([PB| P], Flags) -> [PB | set_flagfield_1(P, Flags)]. %%----------------------------------------------------------------- %% Func: check_nil/1 %%----------------------------------------------------------------- check_nil(#'IOP_IOR'{type_id="", profiles=[]}) -> true; check_nil({Id, _, _, _, _, _}) when is_atom(Id) -> false; check_nil({Id, _, _, _, _, _}) -> case binary_to_list(Id) of "" -> true; _ -> false end; check_nil(_) -> false. %%---------------------------------------------------------------------- %% Function : print %% Arguments : An object represented as one of the following: %% - local (tuple) %% - IOR %% - stringified IOR %% - corbaloc- or corbaname-schema %% IoDevice - the same as the io-module defines. %% Returns : %% Description: Prints the object's components. %%---------------------------------------------------------------------- print(Object) -> print(undefined, Object). print(IoDevice, #'IOP_IOR'{type_id="", profiles=[]}) -> print_it(IoDevice, "================== IOR ====================~n" "NIL Object Reference.~n" "================== END ====================~n"); print(IoDevice, IORStr) when is_list(IORStr) -> IOR = corba:string_to_object(IORStr), print_helper(IoDevice, IOR); print(IoDevice, IOR) when is_record(IOR, 'IOP_IOR') -> print_helper(IoDevice, IOR); print(IoDevice, {Mod, Type, Key, UserDef, OrberDef, Flags}) -> EnvFlags = orber:get_flags(), MC = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_EXCLUDE_CODESET_COMPONENT) of true -> []; false -> [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=?DEFAULT_CODESETS}] end, IOR = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_ENABLE_NAT) of false -> create(orber:giop_version(), Mod:typeID(), orber:host(), orber:iiop_port(), orber:iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags); true -> create(orber:giop_version(), Mod:typeID(), orber:nat_host(), orber:nat_iiop_port(), orber:nat_iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags) end, print_helper(IoDevice, IOR); print(_, _) -> exit("Bad parameter"). print_helper(IoDevice, #'IOP_IOR'{type_id=TypeID, profiles=Profs}) -> Data = io_lib:format("================== IOR ====================~n" "------------------ IFR ID -----------------~n~s~n", [TypeID]), NewData = print_profiles(Profs, []), print_it(IoDevice, lists:flatten([Data|NewData])). print_profiles([], Acc) -> lists:flatten([Acc | io_lib:format("================== END ====================~n", [])]); print_profiles([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data = #'IIOP_ProfileBody_1_0'{iiop_version= #'IIOP_Version'{major=Major, minor=Minor}, host=Host, port=Port, object_key=Objkey}}|T], Acc) -> Profile = io_lib:format("~n------------------ IIOP Profile -----------~n" "Version.............: ~p.~p~n" "Host................: ~s~n" "Port................: ~p~n", [Major, Minor, Host, Port]), ObjKeyStr = print_objkey(Objkey), print_profiles(T, [Profile, ObjKeyStr | Acc]); print_profiles([#'IOP_TaggedProfile' {tag=?TAG_INTERNET_IOP, profile_data = #'IIOP_ProfileBody_1_1'{iiop_version= #'IIOP_Version'{major=Major, minor=Minor}, host=Host, port=Port, object_key=Objkey, components=Components}}|T], Acc) -> Profile = io_lib:format("~n------------------ IIOP Profile -----------~n" "Version.............: ~p.~p~n" "Host................: ~s~n" "Port................: ~p~n", [Major, Minor, Host, Port]), ComponentsStr = print_components(Components, []), ObjKeyStr = print_objkey(Objkey), print_profiles(T, [Profile, ObjKeyStr, ComponentsStr |Acc]); print_profiles([#'IOP_TaggedProfile'{tag=?TAG_MULTIPLE_COMPONENTS, profile_data = Components}|T], Acc) -> MComp = io_lib:format("~n------------------ Multiple Components ----~n", []), ComponentsStr = print_components(Components, []), print_profiles(T, [MComp, ComponentsStr | Acc]); print_profiles([#'IOP_TaggedProfile'{tag=?TAG_SCCP_IOP, profile_data = _Data}|T], Acc) -> SCCP = io_lib:format("~n------------------ SCCP IOP ---------------~n", []), print_profiles(T, [SCCP | Acc]); print_profiles([#'IOP_TaggedProfile'{tag=Tag, profile_data = Data}|T], Acc) -> TAG = io_lib:format("~n------------------ TAG ~p -----------------~n" "Data................: ~p~n", [Tag, Data]), print_profiles(T, [TAG|Acc]). print_components([], Data) -> lists:flatten(lists:reverse(Data)); print_components([#'IOP_TaggedComponent'{tag=?TAG_ORB_TYPE, component_data=ORB}|T], Data) -> OType = io_lib:format(" TAG_ORB_TYPE~n" "ORB Type............: ~p~n", [ORB]), print_components(T, [OType | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data= #'CONV_FRAME_CodeSetComponentInfo' {'ForCharData' = Char, 'ForWcharData' = Wchar}}|T], Data) -> CharSet = io_lib:format(" TAG_CODE_SETS~n" "Native Char.........: ~p~n" "Char Conversion.....: ~p~n" "Native Wchar........: ~p~n" "Wchar Conversion....: ~p~n", [Char#'CONV_FRAME_CodeSetComponent'.native_code_set, Char#'CONV_FRAME_CodeSetComponent'.conversion_code_sets, Wchar#'CONV_FRAME_CodeSetComponent'.native_code_set, Wchar#'CONV_FRAME_CodeSetComponent'.conversion_code_sets]), print_components(T, [CharSet | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=#'ALTERNATE_IIOP_ADDRESS' {'HostID'=Host, 'Port'=Port}}|T], Data) -> AltAddr = io_lib:format(" TAG_ALTERNATE_IIOP_ADDRESS~n" "Alternate Address...: ~s:~p~n", [Host, Port]), print_components(T, [AltAddr | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=#'SSLIOP_SSL' {target_supports=Supports, target_requires=Requires, port=Port}}|T], Data) -> SSL = io_lib:format(" TAG_SSL_SEC_TRANS~n" "SSL Port............: ~p~n" "SSL Requires........: ~p~n" "SSL Supports........: ~p~n", [Port, Requires, Supports]), print_components(T, [SSL | Data]); %% Fault Tolerant Components print_components([#'IOP_TaggedComponent'{tag=?TAG_FT_GROUP, component_data=#'FT_TagFTGroupTaggedComponent' {version = Version, ft_domain_id = DomainId, object_group_id = ObjectGroupId, object_group_ref_version = ObjGrRefVer}}|T], Data) -> Comp = io_lib:format(" TAG_FT_GROUP~n" "Version.............: ~p~n" "Domain Id...........: ~p~n" "Obj Group Id........: ~p~n" "Obj Group Ref Ver...: ~p~n", [Version, DomainId, ObjectGroupId, ObjGrRefVer]), print_components(T, [Comp | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_FT_PRIMARY, component_data=#'FT_TagFTPrimaryTaggedComponent' {primary = Primary}}|T], Data) -> Comp = io_lib:format(" TAG_FT_PRIMARY~n" "Primary.............: ~p~n", [Primary]), print_components(T, [Comp | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_FT_HEARTBEAT_ENABLED, component_data=#'FT_TagFTHeartbeatEnabledTaggedComponent' {heartbeat_enabled = HBE}}|T], Data) -> Comp = io_lib:format(" TAG_FT_HEARTBEAT_ENABLED~n" "Heart Beat Enabled..: ~p~n", [HBE]), print_components(T, [Comp | Data]); %% Security - CSIIOP print_components([#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=#'CSIIOP_CompoundSecMechList' {stateful=Stateful, mechanism_list = MechList}}|T], Data) -> Comp = io_lib:format(" TAG_CSI_SEC_MECH_LIST~n" "Stateful............: ~p~n" "Mechanisms..........: ~p~n", [Stateful, MechList]), print_components(T, [Comp | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_TLS_SEC_TRANS, component_data=#'CSIIOP_TLS_SEC_TRANS' {target_supports = TargetS, target_requires = TargetR, addresses = Addresses}}|T], Data) -> Comp = io_lib:format(" TAG_TLS_SEC_TRANS~n" "Target Supports.....: ~p~n" "Target Requires.....: ~p~n" "Addresses...........: ~p~n", [TargetS, TargetR, Addresses]), print_components(T, [Comp | Data]); print_components([#'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS, component_data=#'CSIIOP_SECIOP_SEC_TRANS' {target_supports = TargetS, target_requires = TargetR, mech_oid = MechOID, target_name = TargetName, addresses = Addresses}}|T], Data) -> Comp = io_lib:format(" TAG_SECIOP_SEC_TRANS~n" "Target Supports.....: ~p~n" "Target Requires.....: ~p~n" "Mechanism OID.......: ~p~n" "Target Name.........: ~p~n" "Addresses...........: ~p~n", [TargetS, TargetR, MechOID, TargetName, Addresses]), print_components(T, [Comp | Data]); %% Unused components. print_components([#'IOP_TaggedComponent'{tag=TAG, component_data=CData}|T], Data) -> Unused = io_lib:format("Unused Component....: ~s~n", [match_tag(TAG)]), Octets = print_octets(CData, [], 1, []), print_components(T, [lists:flatten([Unused | Octets])| Data]). print_objkey(Objkey) when is_tuple(Objkey) -> io_lib:format("Local Object........:~n~p~n", [Objkey]); print_objkey(Objkey) -> Hdr = io_lib:format("External Object.....: ~n", []), Octets = print_octets(Objkey, [], 1, []), lists:flatten([Hdr | Octets]). print_octets([], [], _, Data) -> lists:reverse(Data); print_octets([], Acc, C, Data) -> Filling = lists:duplicate((4*(9-C)), 32), FData = io_lib:format("~s", [Filling]), Rest = io_lib:format(" ~p~n", [lists:reverse(Acc)]), [lists:reverse(Data), FData | Rest]; print_octets([H|T], Acc, 8, Data) when H > 31 , H < 127 -> D1 = io_lib:format("~4w", [H]), D2 = io_lib:format(" ~p~n", [lists:reverse([H|Acc])]), print_octets(T, [], 1, [D2, D1 | Data]); print_octets([H|T], Acc, 1, Data) when H > 31 , H < 127 -> D1 = io_lib:format("~3w", [H]), print_octets(T, [H|Acc], 2, [D1 | Data]); print_octets([H|T], Acc, C, Data) when H > 31 , H < 127 -> D1 = io_lib:format("~4w", [H]), print_octets(T, [H|Acc], C+1, [D1 | Data]); print_octets([H|T], Acc, 8, Data) -> D1 = io_lib:format("~4w", [H]), D2 = io_lib:format(" ~p~n", [lists:reverse([$.|Acc])]), print_octets(T, [], 1, [D2, D1 | Data]); print_octets([H|T], Acc, 1, Data) -> D1 = io_lib:format("~3w", [H]), print_octets(T, [$.|Acc], 2, [D1|Data]); print_octets([H|T], Acc, C, Data) -> D1 = io_lib:format("~4w", [H]), print_octets(T, [$.|Acc], C+1, [D1|Data]). print_it(undefined, Data) -> io:format(Data); print_it(error_report, Data) -> error_logger:error_report(Data); print_it(info_msg, Data) -> error_logger:info_msg(Data); print_it(string, Data) -> lists:flatten(Data); print_it({error_report, Msg}, Data) -> error_logger:error_report(io_lib:format("================== Reason =================~n~s~n~s", [Msg, Data])); print_it({info_msg, Msg}, Data) -> error_logger:info_msg(io_lib:format("================== Comment ================~n~s~n~s", [Msg, Data])); print_it(IoDevice, Data) -> io:format(IoDevice, Data, []). match_tag(?TAG_ORB_TYPE) -> ?TAG_ORB_TYPE_STR; match_tag(?TAG_CODE_SETS) -> ?TAG_CODE_SETS_STR; match_tag(?TAG_POLICIES) -> ?TAG_POLICIES_STR; match_tag(?TAG_ALTERNATE_IIOP_ADDRESS) -> ?TAG_ALTERNATE_IIOP_ADDRESS_STR; match_tag(?TAG_COMPLETE_OBJECT_KEY) -> ?TAG_COMPLETE_OBJECT_KEY_STR; match_tag(?TAG_ENDPOINT_ID_POSITION) -> ?TAG_ENDPOINT_ID_POSITION_STR; match_tag(?TAG_LOCATION_POLICY) -> ?TAG_LOCATION_POLICY_STR; match_tag(?TAG_ASSOCIATION_OPTIONS) -> ?TAG_ASSOCIATION_OPTIONS_STR; match_tag(?TAG_SEC_NAME) -> ?TAG_SEC_NAME_STR; match_tag(?TAG_SPKM_1_SEC_MECH) -> ?TAG_SPKM_1_SEC_MECH_STR; match_tag(?TAG_SPKM_2_SEC_MECH) -> ?TAG_SPKM_2_SEC_MECH_STR; match_tag(?TAG_KerberosV5_SEC_MECH) -> ?TAG_KerberosV5_SEC_MECH_STR; match_tag(?TAG_CSI_ECMA_Secret_SEC_MECH) -> ?TAG_CSI_ECMA_Secret_SEC_MECH_STR; match_tag(?TAG_CSI_ECMA_Hybrid_SEC_MECH) -> ?TAG_CSI_ECMA_Hybrid_SEC_MECH_STR; match_tag(?TAG_SSL_SEC_TRANS) -> ?TAG_SSL_SEC_TRANS_STR; match_tag(?TAG_CSI_ECMA_Public_SEC_MECH) -> ?TAG_CSI_ECMA_Public_SEC_MECH_STR; match_tag(?TAG_GENERIC_SEC_MECH) -> ?TAG_GENERIC_SEC_MECH_STR; match_tag(?TAG_FIREWALL_TRANS) -> ?TAG_FIREWALL_TRANS_STR; match_tag(?TAG_SCCP_CONTACT_INFO) -> ?TAG_SCCP_CONTACT_INFO_STR; match_tag(?TAG_JAVA_CODEBASE) -> ?TAG_JAVA_CODEBASE_STR; match_tag(?TAG_TRANSACTION_POLICY) -> ?TAG_TRANSACTION_POLICY_STR; match_tag(?TAG_FT_GROUP) -> ?TAG_FT_GROUP_STR; match_tag(?TAG_FT_PRIMARY) -> ?TAG_FT_PRIMARY_STR; match_tag(?TAG_FT_HEARTBEAT_ENABLED) -> ?TAG_FT_HEARTBEAT_ENABLED_STR; match_tag(?TAG_MESSAGE_ROUTERS) -> ?TAG_MESSAGE_ROUTERS_STR; match_tag(?TAG_OTS_POLICY) -> ?TAG_OTS_POLICY_STR; match_tag(?TAG_INV_POLICY) -> ?TAG_INV_POLICY_STR; match_tag(?TAG_CSI_SEC_MECH_LIST) -> ?TAG_CSI_SEC_MECH_LIST_STR; match_tag(?TAG_NULL_TAG) -> ?TAG_NULL_TAG_STR; match_tag(?TAG_SECIOP_SEC_TRANS) -> ?TAG_SECIOP_SEC_TRANS_STR; match_tag(?TAG_TLS_SEC_TRANS) -> ?TAG_TLS_SEC_TRANS_STR; match_tag(?TAG_DCE_STRING_BINDING) -> ?TAG_DCE_STRING_BINDING_STR; match_tag(?TAG_DCE_BINDING_NAME) -> ?TAG_DCE_BINDING_NAME_STR; match_tag(?TAG_DCE_NO_PIPES) -> ?TAG_DCE_NO_PIPES_STR; match_tag(?TAG_DCE_SEC_MECH) -> ?TAG_DCE_SEC_MECH_STR; match_tag(?TAG_INET_SEC_TRANS) -> ?TAG_INET_SEC_TRANS_STR; match_tag(Tag) -> integer_to_list(Tag). %%----------------------------------------------------------------- %% Func: string_code/1 %%----------------------------------------------------------------- string_code(IOR) -> Flags = orber:get_flags(), case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_ENABLE_NAT) of false -> string_code(IOR, Flags, orber:host(), orber:iiop_port(), orber:iiop_ssl_port()); true -> string_code(IOR, Flags, orber:nat_host(), orber:nat_iiop_port(), orber:nat_iiop_ssl_port()) end. string_code(IOR, Host) -> Flags = orber:get_flags(), case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_ENABLE_NAT) of false -> string_code(IOR, Flags, Host, orber:iiop_port(), orber:iiop_ssl_port()); true -> string_code(IOR, Flags, Host, orber:nat_iiop_port(), orber:nat_iiop_ssl_port()) end. string_code(IOR, Host, Port) -> Flags = orber:get_flags(), case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_ENABLE_NAT) of false -> string_code(IOR, Flags, Host, Port, orber:iiop_ssl_port()); true -> string_code(IOR, Flags, Host, Port, orber:nat_iiop_ssl_port()) end. string_code(IOR, Host, Port, SSLPort) -> string_code(IOR, orber:get_flags(), Host, Port, SSLPort). string_code(IOR, Flags, IP, Port, SSLPort) -> Env = #giop_env{version = orber:giop_version(), flags = Flags, host = IP, iiop_port = Port, iiop_ssl_port = SSLPort, domain = orber:domain(), partial_security = orber:partial_security()}, {IorByteSeq0, Length0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), {IorByteSeq, _} = code(Env, IOR, IorByteSeq0, Length0), IorByteSeq1 = binary_to_list(list_to_binary(lists:reverse(IorByteSeq))), IorHexSeq = bytestring_to_hexstring(IorByteSeq1), [$I,$O,$R,$: | IorHexSeq]. %%----------------------------------------------------------------- %% Func: code/3 %%----------------------------------------------------------------- code(#giop_env{version = Version} = Env, #'IOP_IOR'{type_id=TypeId, profiles=Profiles}, Bytes, Len) -> ProfileSeq =code_profile_datas(Version, Profiles), %% Byte order cdr_encode:enc_type(?IOR_TYPEDEF, Env, #'IOP_IOR'{type_id=TypeId, profiles=ProfileSeq}, Bytes, Len); %% No Local Interface supplied. Use configuration parameters. code(#giop_env{version = Version, host = 0, flags = EnvFlags} = Env, {Mod, Type, Key, UserDef, OrberDef, Flags}, Bytes, Len) -> MC = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_EXCLUDE_CODESET_COMPONENT) of true -> []; false -> [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=?DEFAULT_CODESETS}] end, IOR = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_ENABLE_NAT) of false -> create(Version, Mod:typeID(), orber_env:host(), orber_env:iiop_port(), orber_env:iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags); true -> create(Version, Mod:typeID(), orber_env:nat_host(), orber_env:nat_iiop_port(), orber_env:nat_iiop_ssl_port(), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags) end, code(Env, IOR, Bytes, Len); code(#giop_env{version = Version, host = Host, iiop_port = IIOPort, iiop_ssl_port = SSLPort, flags = EnvFlags} = Env, {Mod, Type, Key, UserDef, OrberDef, Flags}, Bytes, Len) -> MC = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_EXCLUDE_CODESET_COMPONENT) of true -> []; false -> [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=?DEFAULT_CODESETS}] end, IOR = case ?ORB_FLAG_TEST(EnvFlags, ?ORB_ENV_ENABLE_NAT) of false -> create(Version, Mod:typeID(), Host, check_port(IIOPort, normal), check_port(SSLPort, ssl), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags); true -> create(Version, Mod:typeID(), orber_env:nat_host(Host), orber_env:nat_iiop_port(check_port(IIOPort, normal)), orber_env:nat_iiop_ssl_port(check_port(SSLPort, ssl)), {Mod, Type, Key, UserDef, OrberDef, Flags}, MC, Flags, EnvFlags) end, code(Env, IOR, Bytes, Len). check_port(Port, _Type) when is_integer(Port) -> Port; check_port(_, normal) -> orber:iiop_port(); check_port(_, ssl) -> orber:iiop_ssl_port(). code_profile_datas(_, []) -> []; code_profile_datas(Version, [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=P} | Profiles]) -> NewBytes = list_to_binary(code_profile_data(Version, P)), [#'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=NewBytes} | code_profile_datas(Version, Profiles)]; %% Multiple Components code_profile_datas(Version, [#'IOP_TaggedProfile'{tag=?TAG_MULTIPLE_COMPONENTS, profile_data=P} | Profiles]) -> Comps= code_comp(Version, P, []), {Bytes, Length} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Length1} = cdr_encode:enc_type(?IOP_TAGGEDCOMPONENT_SEQ, Version, Comps, Bytes, Length), Profs = binary_to_list(list_to_binary(lists:reverse(Bytes1))), [#'IOP_TaggedProfile'{tag=?TAG_MULTIPLE_COMPONENTS, profile_data=Profs}| code_profile_datas(Version, Profiles)]; code_profile_datas(Version, [#'IOP_TaggedProfile'{tag=N, profile_data=P} | Profiles]) -> [#'IOP_TaggedProfile'{tag=N, profile_data=P} | code_profile_datas(Version, Profiles)]; code_profile_datas(_, Data) -> orber:dbg("[~p] iop_ior:code_profile_datas(~p); unsupported TaggedProfile.", [?LINE, Data], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). code_profile_data(Version, ProfileData) -> [RecTag, V, H, P, O |Rest] = tuple_to_list(ProfileData), {Bytes, Length} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, Length1} = cdr_encode:enc_type(?IIOP_VERSION, Version, V, Bytes, Length), {Bytes2, Length2} = cdr_encode:enc_type({'tk_string', 0}, Version, H, Bytes1, Length1), {Bytes3, Length3} = cdr_encode:enc_type('tk_ushort', Version, P, Bytes2, Length2), {Bytes4, Length4} = cdr_encode:enc_type({'tk_sequence', 'tk_octet', 0}, Version, corba:objkey_to_string(O), Bytes3, Length3), {Bytes5, _Length5} = code_profile_data_1(Version, RecTag, Rest, Bytes4, Length4), Bytes6 = lists:reverse(Bytes5), lists:flatten(Bytes6). code_profile_data_1(_Version, 'IIOP_ProfileBody_1_0', [], Bytes, Length) -> {Bytes, Length}; code_profile_data_1(Version, 'IIOP_ProfileBody_1_1', [TaggedComponentSeq], Bytes, Length) -> Comps = code_comp(Version, TaggedComponentSeq, []), cdr_encode:enc_type(?IOP_TAGGEDCOMPONENT_SEQ, Version, Comps, Bytes, Length); code_profile_data_1(_,V,S,_,_) -> orber:dbg("[~p] iop_ior:code_profile_datas(~p, ~p); probably unsupported IIOP-version", [?LINE, V, S], ?DEBUG_LEVEL), corba:raise(#'NO_IMPLEMENT'{completion_status=?COMPLETED_NO}). code_comp(_Version, [], CompData) -> CompData; code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=CodeSet}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?CONV_FRAME_CODESETCOMPONENTINFO, Version, CodeSet, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_ORB_TYPE, component_data=ORBType}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?ORB_TYPE, Version, ORBType, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_ORB_TYPE, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=AltAddr}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?ALTERNATE_IIOP_ADDRESS, Version, AltAddr, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=SSLStruct}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?SSLIOP_SSL, Version, SSLStruct, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=Bytes}|CompData]); %% Fault Tolerant Components code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_GROUP, component_data=Data}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?FT_TagFTGroupTaggedComponent, Version, Data, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_GROUP, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_PRIMARY, component_data=Data}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?FT_TagFTPrimaryTaggedComponent, Version, Data, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_PRIMARY, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_HEARTBEAT_ENABLED, component_data=Data}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?FT_TagFTHeartbeatEnabledTaggedComponent, Version, Data, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_HEARTBEAT_ENABLED, component_data=Bytes}|CompData]); %% Security - CSIIOP code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=Data}|Comps], CompData) -> NewData = Data#'CSIIOP_CompoundSecMechList' {mechanism_list = code_sec_mech(Version, Data#'CSIIOP_CompoundSecMechList'.mechanism_list, [])}, {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?CSIIOP_CompoundSecMechList, Version, NewData, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_TLS_SEC_TRANS, component_data=Data}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?CSIIOP_TLS_SEC_TRANS, Version, Data, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_TLS_SEC_TRANS, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS, component_data=Data}|Comps], CompData) -> {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type(?CSIIOP_SECIOP_SEC_TRANS, Version, Data, Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS, component_data=Bytes}|CompData]); code_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_NULL_TAG}|Comps], CompData) -> %% The body of the TAG_NULL_TAG component is a sequence of octets of %% length 0. {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Version, 0, [], 0), {Bytes1, _Len1} = cdr_encode:enc_type({'tk_sequence', 'tk_octet', 0}, Version, [], Bytes0, Len0), Bytes = binary_to_list(list_to_binary(lists:reverse(Bytes1))), code_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_NULL_TAG, component_data=Bytes}|CompData]); %% Unsupported/not used component. code_comp(Version, [C|Comps], CompData) -> code_comp(Version, Comps, [C|CompData]). code_sec_mech(_, [], Acc) -> %% We must preserver the order!! lists:reverse(Acc); code_sec_mech(Version, [#'CSIIOP_CompoundSecMech'{transport_mech = TagComp} = CSM|T], Acc) -> [EncTagComp] = code_comp(Version, [TagComp], []), code_sec_mech(Version, T, [CSM#'CSIIOP_CompoundSecMech' {transport_mech = EncTagComp}|Acc]). %%----------------------------------------------------------------- %% Func: string_decode/1 %%----------------------------------------------------------------- string_decode([$I,$O,$R,$: | IorHexSeq]) -> Version = orber:giop_version(), IorByteSeq = list_to_binary(hexstring_to_bytestring(IorHexSeq)), {ByteOrder, IorRest} = cdr_decode:dec_byte_order(IorByteSeq), decode(Version, IorRest, 1, ByteOrder); string_decode([$i,$o,$r,$: | IorHexSeq]) -> Version = orber:giop_version(), IorByteSeq = list_to_binary(hexstring_to_bytestring(IorHexSeq)), {ByteOrder, IorRest} = cdr_decode:dec_byte_order(IorByteSeq), decode(Version, IorRest, 1, ByteOrder); string_decode(What) -> orber:dbg("[~p] iop_ior:string_decode(~p); Should be IOR:.. or ior:..", [?LINE, What], ?DEBUG_LEVEL), corba:raise(#'BAD_PARAM'{completion_status=?COMPLETED_NO}). %%----------------------------------------------------------------- %% Func: decode/3 %%----------------------------------------------------------------- decode(Version, IorByteSeq, Len, ByteOrder) -> {#'IOP_IOR'{type_id=TypeId, profiles=Profiles}, Rest, Length} = cdr_decode:dec_type(?IOR_TYPEDEF, Version, IorByteSeq, Len, ByteOrder), L = decode_profiles(Version, Profiles), {#'IOP_IOR'{type_id=TypeId, profiles=L}, Rest, Length}. decode_profiles(_, []) -> []; decode_profiles(Version, [P | Profiles]) -> Struct = decode_profile(Version, P), L = decode_profiles(Version, Profiles), [Struct | L]. decode_profile(Version, #'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=ProfileData}) -> {ByteOrder, Rest} = cdr_decode:dec_byte_order(list_to_binary(ProfileData)), Length = 1, {V, Rest1, Length1} = cdr_decode:dec_type(?IIOP_VERSION, Version, Rest, Length, ByteOrder), {H, Rest2, Length2} = cdr_decode:dec_type({'tk_string', 0}, Version, Rest1, Length1, ByteOrder), {P, Rest3, Length3} = cdr_decode:dec_type('tk_ushort', Version, Rest2, Length2, ByteOrder), {ObjKey, Rest4, Length4} = cdr_decode:dec_type({'tk_sequence', 'tk_octet', 0}, Version, Rest3, Length3, ByteOrder), Struct = decode_profile_1(V, H, P, ObjKey, Version, Rest4, Length4, ByteOrder), #'IOP_TaggedProfile'{tag=?TAG_INTERNET_IOP, profile_data=Struct}; %% Multiple Components decode_profile(Version, #'IOP_TaggedProfile'{tag=?TAG_MULTIPLE_COMPONENTS, profile_data=ProfileData}) -> {ByteOrder, Rest} = cdr_decode:dec_byte_order(list_to_binary(ProfileData)), {Components, <<>>, _Length1} =cdr_decode:dec_type(?IOP_TAGGEDCOMPONENT_SEQ, Version, Rest, 1, ByteOrder), CompData = decode_comp(Version, Components, []), #'IOP_TaggedProfile'{tag=?TAG_MULTIPLE_COMPONENTS, profile_data=CompData}; decode_profile(_, #'IOP_TaggedProfile'{tag=N, profile_data=ProfileData}) -> #'IOP_TaggedProfile'{tag=N, profile_data=ProfileData}; decode_profile(_, Data) -> orber:dbg("[~p] iop_ior:decode_profile(~p); unsupported TaggedProfile.", [?LINE, Data], ?DEBUG_LEVEL), corba:raise(#'INV_OBJREF'{completion_status=?COMPLETED_NO}). decode_profile_1(#'IIOP_Version'{major=1, minor=0}, H, P, ObjKey, _Version, _Rest, _Length, _ByteOrder) -> #'IIOP_ProfileBody_1_0'{iiop_version=#'IIOP_Version'{major=1, minor=0}, host=H, port=P, object_key=corba:string_to_objkey(ObjKey)}; decode_profile_1(#'IIOP_Version'{major=1, minor=1}, H, P, ObjKey, Version, Rest, Length, ByteOrder) -> {Components, <<>>, _Length1} =cdr_decode:dec_type(?IOP_TAGGEDCOMPONENT_SEQ, Version, Rest, Length, ByteOrder), CompData = decode_comp(Version, Components, []), #'IIOP_ProfileBody_1_1'{iiop_version=#'IIOP_Version'{major=1, minor=1}, host=H, port=P, object_key=corba:string_to_objkey(ObjKey), components=CompData}; decode_profile_1(#'IIOP_Version'{major=1, minor=2}, H, P, ObjKey, Version, Rest, Length, ByteOrder) -> {Components, <<>>, _Length1} =cdr_decode:dec_type(?IOP_TAGGEDCOMPONENT_SEQ, Version, Rest, Length, ByteOrder), CompData = decode_comp(Version, Components, []), #'IIOP_ProfileBody_1_1'{iiop_version=#'IIOP_Version'{major=1, minor=2}, host=H, port=P, object_key=corba:string_to_objkey(ObjKey), components=CompData}; decode_profile_1(V, _, _, _, _, _, _,_) -> orber:dbg("[~p] iop_ior:decode_profile_1(~p); probably unsupported IIOP-version.", [?LINE, V], ?DEBUG_LEVEL), corba:raise(#'NO_IMPLEMENT'{completion_status=?COMPLETED_NO}). decode_comp(_Version, [], Components) -> Components; decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=Bytes}|Comps], Components) -> {ByteOrder, Rest} = cdr_decode:dec_byte_order(list_to_binary(Bytes)), {CodeSet, _, _} = cdr_decode:dec_type(?CONV_FRAME_CODESETCOMPONENTINFO, Version, Rest, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_CODE_SETS, component_data=CodeSet}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_ORB_TYPE, component_data=Bytes}|Comps], Components) -> {ByteOrder, Rest} = cdr_decode:dec_byte_order(list_to_binary(Bytes)), {ORBType, _, _} = cdr_decode:dec_type(?ORB_TYPE, Version, Rest, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_ORB_TYPE, component_data=ORBType}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=Bytes}|Comps], Components) -> {ByteOrder, Rest} = cdr_decode:dec_byte_order(list_to_binary(Bytes)), {AltIIOP, _, _} = cdr_decode:dec_type(?ALTERNATE_IIOP_ADDRESS, Version, Rest, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_ALTERNATE_IIOP_ADDRESS, component_data=AltIIOP}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {SSLStruct, _Rest1, _Length1} = cdr_decode:dec_type(?SSLIOP_SSL, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=SSLStruct}|Components]); %% Fault Tolerant Components decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_GROUP, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?FT_TagFTGroupTaggedComponent, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_GROUP, component_data=DecodedData}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_PRIMARY, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?FT_TagFTPrimaryTaggedComponent, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_PRIMARY, component_data=DecodedData}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_FT_HEARTBEAT_ENABLED, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?FT_TagFTHeartbeatEnabledTaggedComponent, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_FT_HEARTBEAT_ENABLED, component_data=DecodedData}|Components]); %% Security - CSIIOP decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?CSIIOP_CompoundSecMechList, Version, R, 1, ByteOrder), NewDecodedData = DecodedData#'CSIIOP_CompoundSecMechList' {mechanism_list = decode_sec_mech(Version, DecodedData#'CSIIOP_CompoundSecMechList'.mechanism_list, [])}, decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_CSI_SEC_MECH_LIST, component_data=NewDecodedData}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_TLS_SEC_TRANS, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?CSIIOP_TLS_SEC_TRANS, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_TLS_SEC_TRANS, component_data=DecodedData}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS, component_data=Data}|Comps], Components) -> {ByteOrder, R} = cdr_decode:dec_byte_order(list_to_binary(Data)), {DecodedData, _Rest1, _Length1} = cdr_decode:dec_type(?CSIIOP_SECIOP_SEC_TRANS, Version, R, 1, ByteOrder), decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_SECIOP_SEC_TRANS, component_data=DecodedData}|Components]); decode_comp(Version, [#'IOP_TaggedComponent'{tag=?TAG_NULL_TAG, component_data=_Data}|Comps], Components) -> %% The body of the TAG_NULL_TAG component is a sequence of octets of %% length 0. decode_comp(Version, Comps, [#'IOP_TaggedComponent'{tag=?TAG_NULL_TAG, component_data=[]}|Components]); decode_comp(Version, [C|Comps], Components) -> %% Not used but we cannot discard it. decode_comp(Version, Comps, [C|Components]). decode_sec_mech(_Version, [], Acc) -> %% We must preserver the order!! lists:reverse(Acc); decode_sec_mech(Version, [#'CSIIOP_CompoundSecMech'{transport_mech = TagComp} = CSM|T], Acc) -> [DecTagComp] = decode_comp(Version, [TagComp], []), decode_sec_mech(Version, T, [CSM#'CSIIOP_CompoundSecMech' {transport_mech = DecTagComp}|Acc]). %%----------------------------------------------------------------- %% Func: hexstring_to_bytestring/1 %%----------------------------------------------------------------- hexstring_to_bytestring(HexString) -> ByteString = hexstring_to_bytestring(HexString, []), lists:reverse(ByteString). hexstring_to_bytestring([], Acc) -> Acc; hexstring_to_bytestring([H1, H2 |Rest], Acc) -> I1 = hex_to_int(H1), I2 = hex_to_int(H2), I = I1 * 16 + I2, Acc2 = cdrlib:enc_octet(I, Acc), hexstring_to_bytestring(Rest, Acc2). hex_to_int(H) when H >= $a -> 10 + H - $a; hex_to_int(H) when H >= $A -> 10 + H -$A; hex_to_int(H) -> H - $0. %%----------------------------------------------------------------- %% Func: bytestring_to_hexstring/1 %% Args: A byte string %% Returns: A list of hexadecimal digits (onebyte will be represented as %% two hexadecimal digits). %%----------------------------------------------------------------- bytestring_to_hexstring(ByteString) -> HexString = bytestring_to_hexstring(ByteString, []), lists:reverse(HexString). bytestring_to_hexstring([], Acc) -> Acc; bytestring_to_hexstring([B |Rest], Acc) -> [C1, C2] = int_to_hex(B), bytestring_to_hexstring(Rest,[C2, C1| Acc]). int_to_hex(B) when B < 256, B >= 0 -> N1 = B div 16, N2 = B rem 16, [code_character(N1), code_character(N2)]. code_character(N) when N < 10 -> $0 + N; code_character(N) -> $a + (N - 10).