%% %% %CopyrightBegin% %% %% Copyright Ericsson AB 1999-2011. 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% %% %% -module(orber_test_lib). -include("test_server.hrl"). -include_lib("orber/include/corba.hrl"). -include_lib("orber/include/ifr_types.hrl"). -include_lib("orber/src/orber_iiop.hrl"). -include("idl_output/orber_test_server.hrl"). -include_lib("orber/COSS/CosNaming/CosNaming.hrl"). -define(match(ExpectedRes,Expr), fun() -> AcTuAlReS = (catch (Expr)), case AcTuAlReS of ExpectedRes -> io:format("------ CORRECT RESULT ------~n~p~n", [AcTuAlReS]), AcTuAlReS; _ -> io:format("###### ERROR ERROR ######~nRESULT: ~p~n", [AcTuAlReS]), ?line exit(AcTuAlReS) end end()). -export([js_node/2, js_node/1, js_node/0, slave_sup/0, remote_apply/4, install_test_data/1, light_tests/3, uninstall_test_data/1, destroy_node/2, lookup/2, alternate_iiop_address/2, create_alternate_iiop_address/2, alternate_ssl_iiop_address/3, create_alternate_ssl_iiop_address/3, test_coding/1, test_coding/2, corba_object_tests/2, timeouts/3, precond/3, postcond/4, oe_get_interface/0, create_components_IOR/1, get_options/2, get_options/3, get_options/4, version_ok/0, ssl_version/0, get_loopback_interface/0, get_loopback_interface/1, get_host/0, get_host/1]). %% Interceptor functions. -export([new_out_connection/3, new_in_connection/3, closed_in_connection/1, closed_out_connection/1, in_request_encoded/6, in_reply_encoded/6, out_reply_encoded/6, out_request_encoded/6, in_request/6, in_reply/6, out_reply/6, out_request/6]). %%------------------------------------------------------------ %% function : ssl_version %% Arguments: %% Returns : integer() %% Effect : %% %%------------------------------------------------------------ ssl_version() -> try ssl:module_info(), case catch erlang:system_info(otp_release) of Version when is_list(Version) -> if "R12B" < Version -> 3; true -> 2 end; _ -> 2 end catch error:undef -> no_ssl end. %%------------------------------------------------------------ %% function : version_ok %% Arguments: %% Returns : true | {skipped, Reason} %% Effect : %% %%------------------------------------------------------------ version_ok() -> {ok, Hostname} = inet:gethostname(), case inet:getaddr(Hostname, inet6) of {error,nxdomain} -> {skipped, "Inet cannot handle IPv6"}; _ -> case inet:getaddr("0:0:0:0:0:FFFF:127.0.0.1", inet6) of {error,nxdomain} -> {skipped, "Inet cannot handle IPv6"}; _ -> case gen_tcp:listen(0, [{reuseaddr, true}, inet6]) of {ok, LSock} -> {ok, Port} = inet:port(LSock), case gen_tcp:connect(Hostname, Port, [inet6]) of {error, _} -> gen_tcp:close(LSock), {skipped, "Inet cannot handle IPv6"}; {ok, Socket} -> gen_tcp:close(Socket), gen_tcp:close(LSock), true end; {error, _} -> {skipped, "Inet cannot handle IPv6"} end end end. %%------------------------------------------------------------ %% function : get_host %% Arguments: Family - inet | inet6 %% Returns : string() %% Effect : %% %%------------------------------------------------------------ get_host() -> get_host(inet). get_host(Family) -> case os:type() of {win32, _} -> case os:version() of {6, _, _} when Family == inet -> "127.0.0.1"; {6, _, _} -> "0:0:0:0:0:FFFF:7F00:0001"; _ -> [IP] = ?match([_], orber:host()), IP end; _ -> [IP] = ?match([_], orber:host()), IP end. %%------------------------------------------------------------ %% function : get_loopback_interface %% Arguments: Family - inet | inet6 %% Returns : string() %% Effect : %% %%------------------------------------------------------------ get_loopback_interface() -> get_loopback_interface(inet). get_loopback_interface(Family) -> case os:type() of {win32, _} -> case os:version() of {6, _, _} when Family == inet -> "127.0.0.2"; {6, _, _} -> "0:0:0:0:0:FFFF:7F00:0002"; _ when Family == inet -> "127.0.0.1"; _ -> "0:0:0:0:0:FFFF:7F00:0001" end; _ when Family == inet -> "127.0.0.1"; _ -> "0:0:0:0:0:FFFF:7F00:0001" end. %%------------------------------------------------------------ %% function : js_node/4 %% Arguments: Port - which iiop_port (integer()) %% InitOptions - [{Key, Value}] %% {Type, StartOptions} - {lightweight, [{Key, Value}]} %% Returns : {ok, Node} | {error, _} %% Effect : Starts a new slave-node with given (optinally) %% extra arguments. If fails it retries 'Retries' times. %%------------------------------------------------------------ js_node() -> js_node([], []). js_node(InitOptions) when is_list(InitOptions) -> js_node(InitOptions, []). js_node(InitOptions, StartOptions) when is_list(InitOptions) -> {A,B,C} = erlang:now(), [_, Host] = string:tokens(atom_to_list(node()), [$@]), _NewInitOptions = check_options(InitOptions), js_node_helper(Host, 0, lists:concat([A,'_',B,'_',C]), InitOptions, 10, StartOptions). js_node_helper(Host, Port, Name, Options, Retries, StartOptions) -> case starter(Host, Name, create_paths()) of {ok, NewNode} -> case net_adm:ping(NewNode) of pong -> start_ssl(lists:member({secure, ssl}, Options), NewNode), {ok, Cwd} = file:get_cwd(), Path = code:get_path(), ok = rpc:call(NewNode, file, set_cwd, [Cwd]), true = rpc:call(NewNode, code, set_path, [Path]), rpc:call(NewNode, application, load, [orber]), ok = rpc:call(NewNode, corba, orb_init, [[{iiop_port, Port}, {orber_debug_level, 10}|Options]]), start_orber(StartOptions, NewNode), spawn_link(NewNode, ?MODULE, slave_sup, []), rpc:multicall([node() | nodes()], global, sync, []), ok = rpc:call(NewNode, orber, info, [io]), {ok, NewNode, Host}; _ -> {error, "net_adm:ping(Node) failed"} end; {error, Reason} when Retries == 0 -> {error, Reason}; {error, Reason} -> io:format("Could not start slavenode ~p:~p due to: ~p~n", [Host, Port, Reason]), timer:sleep(500), js_node_helper(Host, Port, Name, Options, Retries-1, StartOptions) end. check_options(Options) -> case {os:type(), os:version()} of {{win32, _}, {6, _, _}} -> %% Vista, need to run additional checks. case {orber_tb:keysearch(ip_address, Options), orber_tb:keysearch(flags, Options, 0)} of {undefined, Flags} -> case ?ORB_FLAG_TEST(Flags, ?ORB_ENV_USE_IPV6) of true -> [{ip_address, get_host(inet6)}|Options]; false -> [{ip_address, get_host(inet)}|Options] end; _ -> Options end; _ -> Options end. starter(Host, Name, Args) -> case os:type() of vxworks -> test_server:start_node(Name, slave, [{args,Args}]); _ -> slave:start_link(Host, Name, Args) end. slave_sup() -> process_flag(trap_exit, true), receive {'EXIT', _, _} -> case os:type() of vxworks -> erlang:halt(); _ -> ignore end end. start_ssl(true, Node) -> rpc:call(Node, ssl, start, []), rpc:call(Node, crypto, start, []); start_ssl(_, _) -> ok. start_orber({lightweight, Options}, Node) -> ok = rpc:call(Node, mnesia, start, []), ok = rpc:call(Node, orber, start_lightweight, [Options]); start_orber(lightweight, Node) -> ok = rpc:call(Node, mnesia, start, []), ok = rpc:call(Node, orber, start_lightweight, []); start_orber(_, Node) -> ok = rpc:call(Node, orber, jump_start, []). %%----------------------------------------------------------------- %% Type - ssl | iiop_ssl %% Role - 'server' | 'client' %% Options - [{Key, Value}] %%----------------------------------------------------------------- get_options(Type, Role) -> get_options(Type, Role, 2, []). get_options(ssl, Role, Level) -> get_options(ssl, Role, Level, []). get_options(ssl, Role, 2, Options) -> Dir = filename:join([code:lib_dir(ssl), "examples", "certs", "etc"]), [{depth, 2}, {verify, 2}, {keyfile, filename:join([Dir, Role, "key.pem"])}, {cacertfile, filename:join([Dir, Role, "cacerts.pem"])}, {certfile, filename:join([Dir, Role, "cert.pem"])}|Options]; get_options(iiop_ssl, _Role, 2, Options) -> Dir = filename:join([code:lib_dir(ssl), "examples", "certs", "etc"]), [{ssl_server_depth, 2}, {ssl_server_verify, 2}, {ssl_server_certfile, filename:join([Dir, "server", "cert.pem"])}, {ssl_server_cacertfile, filename:join([Dir, "server", "cacerts.pem"])}, {ssl_server_keyfile, filename:join([Dir, "server", "key.pem"])}, {ssl_client_depth, 2}, {ssl_client_verify, 2}, {ssl_client_certfile, filename:join([Dir, "client", "cert.pem"])}, {ssl_client_cacertfile, filename:join([Dir, "client", "cacerts.pem"])}, {ssl_client_keyfile, filename:join([Dir, "client", "key.pem"])}, {secure, ssl}|Options]; get_options(iiop_ssl, _Role, 1, Options) -> Dir = filename:join([code:lib_dir(ssl), "examples", "certs", "etc"]), [{ssl_server_depth, 1}, {ssl_server_verify, 0}, {ssl_server_certfile, filename:join([Dir, "server", "cert.pem"])}, {ssl_server_cacertfile, filename:join([Dir, "server", "cacerts.pem"])}, {ssl_server_keyfile, filename:join([Dir, "server", "key.pem"])}, {ssl_client_depth, 1}, {ssl_client_verify, 0}, {ssl_client_certfile, filename:join([Dir, "client", "cert.pem"])}, {ssl_client_cacertfile, filename:join([Dir, "client", "cacerts.pem"])}, {ssl_client_keyfile, filename:join([Dir, "client", "key.pem"])}, {secure, ssl}|Options]. create_paths() -> Path = filename:dirname(code:which(?MODULE)), " -pa " ++ Path ++ " -pa " ++ filename:join(Path, "idl_output") ++ " -pa " ++ filename:join(Path, "all_SUITE_data") ++ " -pa " ++ filename:dirname(code:which(orber)). %%------------------------------------------------------------ %% function : destroy_node %% Arguments: Node - which node to destroy. %% Type - normal | ssl %% Returns : %% Effect : %%------------------------------------------------------------ destroy_node(Node, Type) -> stopper(Node, Type). stopper(Node, _Type) -> case os:type() of vxworks -> test_server:stop_node(Node); _ -> slave:stop(Node) end. %%------------------------------------------------------------ %% function : remote_apply %% Arguments: N - Node, M - Module, %% F - Function, A - Arguments (list) %% Returns : %% Effect : %%------------------------------------------------------------ remote_apply(N, M,F,A) -> case rpc:call(N, M, F, A) of {badrpc, Reason} -> exit(Reason); Other -> Other end. %%------------------------------------------------------------ %% function : install_test_data %% Arguments: WhichSuite %% Returns : ok %% Effect : Installs test data associated with 'WhichSuite' %%------------------------------------------------------------ install_test_data(nameservice) -> oe_orber_test_server:oe_register(), Mamba = orber_test_server:oe_create([], [{regname, {local, mamba}}]), true = corba:add_initial_service("Mamba", Mamba), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), 'CosNaming_NamingContext':bind(NS, N,Mamba); install_test_data({nameservice, AltAddr, AltPort}) -> oe_orber_test_server:oe_register(), Obj = orber_test_server:oe_create([], [{regname, {local, mamba}}]), Mamba = corba:add_alternate_iiop_address(Obj, AltAddr, AltPort), true = corba:add_initial_service("Mamba", Mamba), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), 'CosNaming_NamingContext':bind(NS, N,Mamba); install_test_data(timeout) -> oe_orber_test_server:oe_register(), Mamba = orber_test_server:oe_create([], {local, mamba}), Viper = orber_test_timeout_server:oe_create([], {local, viper}), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N1 = lname:insert_component(lname:create(), 1, NC1), NC2 = lname_component:set_id(lname_component:create(), "viper"), N2 = lname:insert_component(lname:create(), 1, NC2), 'CosNaming_NamingContext':bind(NS, N1, Mamba), 'CosNaming_NamingContext':bind(NS, N2, Viper); install_test_data(pseudo) -> oe_orber_test_server:oe_register(), Mamba = orber_test_server:oe_create([], [{pseudo,true}]), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), 'CosNaming_NamingContext':bind(NS, N,Mamba); install_test_data(ssl) -> oe_orber_test_server:oe_register(), Mamba = orber_test_server:oe_create([], [{regname, {local, mamba}}]), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), 'CosNaming_NamingContext':bind(NS, N,Mamba); install_test_data(ssl_simple) -> oe_orber_test_server:oe_register(); install_test_data(light) -> %% Nothing to do at the moment but we might in the future ok; install_test_data(_) -> {error, "no_implement"}. %%------------------------------------------------------------ %% function : uninstall_test_data %% Arguments: WhichSuite %% Returns : ok %% Effect : Uninstalls test data associated with 'WhichSuite' %%------------------------------------------------------------ uninstall_test_data(pseudo) -> NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), _Obj = (catch 'CosNaming_NamingContext':resolve(NS, N)), catch 'CosNaming_NamingContext':destroy(NS), oe_orber_test_server:oe_unregister(); uninstall_test_data(timeout) -> NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N1 = lname:insert_component(lname:create(), 1, NC1), NC2 = lname_component:set_id(lname_component:create(), "viper"), N2 = lname:insert_component(lname:create(), 1, NC2), Mamba = (catch 'CosNaming_NamingContext':resolve(NS, N1)), Viper = (catch 'CosNaming_NamingContext':resolve(NS, N2)), catch corba:dispose(Mamba), catch corba:dispose(Viper), catch 'CosNaming_NamingContext':destroy(NS), oe_orber_test_server:oe_unregister(); uninstall_test_data(nameservice) -> true = corba:remove_initial_service("Mamba"), NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), Obj = (catch 'CosNaming_NamingContext':resolve(NS, N)), catch corba:dispose(Obj), catch 'CosNaming_NamingContext':destroy(NS), oe_orber_test_server:oe_unregister(); uninstall_test_data(ssl) -> NS = corba:resolve_initial_references("NameService"), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N = lname:insert_component(lname:create(), 1, NC1), Obj = (catch 'CosNaming_NamingContext':resolve(NS, N)), catch corba:dispose(Obj), catch 'CosNaming_NamingContext':destroy(NS), oe_orber_test_server:oe_unregister(); uninstall_test_data(ssl_simple) -> oe_orber_test_server:oe_unregister(); uninstall_test_data(light) -> %% Nothing to do at the moment but we might in the future ok; uninstall_test_data(_) -> {error, "no_implement"}. %%------------------------------------------------------------ %% function : corba_object_tests %% Arguments: TestServerObj a orber_test_server ref %% OtherObj - any other Orber object. %% Returns : term() %% Effect : %%------------------------------------------------------------ corba_object_tests(TestServerObj, OtherObj) -> ?match(false, corba_object:is_a(TestServerObj, "IDL:orber_parent/inherrit:1.0")), ?match(true, corba_object:is_a(TestServerObj, "IDL:omg.org/orber_parent/inherrit:1.0")), ?match(true, corba_object:is_a(TestServerObj, "IDL:omg.org/orber_test/server:1.0")), ?match(false, corba_object:is_a(TestServerObj, "IDL:orber_test/server:1.0")), ?match(false, corba_object:is_a(TestServerObj, "IDL:omg.org/orber_parent/inherrit:1.1")), ?match(false, corba_object:is_a(TestServerObj, "NotValidIFRID")), ?match(false, corba_object:is_nil(TestServerObj)), ?match(false, corba_object:is_equivalent(OtherObj,TestServerObj)), ?match(true, corba_object:is_equivalent(TestServerObj,TestServerObj)), ?match(false, corba_object:non_existent(TestServerObj)), ?match(false, corba_object:not_existent(TestServerObj)), ?match(#fullinterfacedescription{}, corba_object:get_interface(TestServerObj)), ok. %%------------------------------------------------------------ %% function : lookup %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ lookup(Host, Port) -> Key = Host++":"++integer_to_list(Port), NSR = corba:resolve_initial_references_remote("NameService", ["iiop://"++Key]), NC1 = lname_component:set_id(lname_component:create(), "not_exist"), N1 = lname:insert_component(lname:create(), 1, NC1), ?match({'EXCEPTION',{'CosNaming_NamingContext_NotFound',_,_,_}}, 'CosNaming_NamingContext':resolve(NSR, N1)), NC2 = lname_component:set_id(lname_component:create(), "mamba"), N2 = lname:insert_component(lname:create(), 1, NC2), Obj = ?match({'IOP_IOR',"IDL:omg.org/orber_test/server:1.0",_}, 'CosNaming_NamingContext':resolve(NSR, N2)), orber_test_server:print(Obj), Obj2 = ?match({'IOP_IOR',"IDL:omg.org/orber_test/server:1.0",_}, corba:string_to_object("corbaname:iiop:1.1@"++Key++"/NameService#mamba")), orber_test_server:print(Obj2), NSR2 = ?match({'IOP_IOR',"IDL:omg.org/CosNaming/NamingContextExt:1.0",_}, corba:string_to_object("corbaloc:iiop:1.1@"++Key++"/NameService")), Obj3 = ?match({'IOP_IOR',"IDL:omg.org/orber_test/server:1.0",_}, 'CosNaming_NamingContext':resolve(NSR2, N2)), orber_test_server:print(Obj3). %%------------------------------------------------------------ %% function : alternate_iiop_address %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ alternate_iiop_address(Host, Port) -> IOR = create_alternate_iiop_address(Host, Port), ?match(false, corba_object:non_existent(IOR)), ?match({'object_forward',_}, corba:locate(IOR)), ?match({'object_forward',_}, corba:locate(IOR, 10000)), ok. %%------------------------------------------------------------ %% function : create_alternate_iiop_address %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ create_alternate_iiop_address(Host, Port) -> MC = [#'IOP_TaggedComponent'{tag = ?TAG_ORB_TYPE, component_data = ?ORBER_ORB_TYPE_1}, #'IOP_TaggedComponent'{tag = ?TAG_CODE_SETS, component_data = ?DEFAULT_CODESETS}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = Port}}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = 8000}}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = 8000}}], #'IOP_IOR'{type_id=TypeID, profiles=P1} = _IORA = iop_ior:create({1,2}, "IDL:omg.org/CosNaming/NamingContextExt:1.0", [Host], 8000, -1, "NameService", MC, 0, 0), #'IOP_IOR'{profiles=P2} = _IORB = iop_ior:create({1,1}, "IDL:omg.org/CosNaming/NamingContextExt:1.0", [Host], 8000, -1, "NameService", [], 0, 0), #'IOP_IOR'{type_id=TypeID, profiles=P2++P1}. %%------------------------------------------------------------ %% function : create_components_IOR %% Arguments: %% Returns : term() %% Effect : %%------------------------------------------------------------ create_components_IOR(Version) -> MC = [#'IOP_TaggedComponent'{tag = ?TAG_ORB_TYPE, component_data = ?ORBER_ORB_TYPE_1}, #'IOP_TaggedComponent'{tag = ?TAG_CODE_SETS, component_data = ?DEFAULT_CODESETS}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = "127.0.0.1", 'Port' = 4001}}, #'IOP_TaggedComponent'{tag = ?TAG_SSL_SEC_TRANS, component_data = #'SSLIOP_SSL'{target_supports = 0, target_requires = 1, port = 2}}, #'IOP_TaggedComponent'{tag = ?TAG_FT_GROUP, component_data = #'FT_TagFTGroupTaggedComponent' {version = #'GIOP_Version'{major = 1, minor = 2}, ft_domain_id = "FT_FTDomainId", object_group_id = ?ULONGLONGMAX, object_group_ref_version = ?LONGMAX}}, #'IOP_TaggedComponent'{tag = ?TAG_FT_PRIMARY, component_data = #'FT_TagFTPrimaryTaggedComponent'{primary = true}}, #'IOP_TaggedComponent'{tag = ?TAG_FT_HEARTBEAT_ENABLED, component_data = #'FT_TagFTHeartbeatEnabledTaggedComponent'{heartbeat_enabled = true}}, #'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 = "127.0.0.1", port = 6001}]}}, 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}}, #'CSIIOP_CompoundSecMech' {target_requires = 6, transport_mech = #'IOP_TaggedComponent' {tag=?TAG_NULL_TAG, component_data=[]}, 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}}, #'CSIIOP_CompoundSecMech' {target_requires = 6, transport_mech = #'IOP_TaggedComponent' {tag=?TAG_SECIOP_SEC_TRANS, component_data=#'CSIIOP_SECIOP_SEC_TRANS' {target_supports = 7, target_requires = 8, mech_oid = [0,255], target_name = [0,255], addresses = [#'CSIIOP_TransportAddress'{host_name = "127.0.0.1", port = 6001}]}}, 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}}]}}], iop_ior:create(Version, "IDL:omg.org/CosNaming/NamingContextExt:1.0", ["127.0.0.1"], 5001, -1, "NameService", MC, 0, 0). %%------------------------------------------------------------ %% function : alternate_ssl_iiop_address %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ alternate_ssl_iiop_address(Host, Port, SSLPort) -> IOR = create_alternate_ssl_iiop_address(Host, Port, SSLPort), ?match(false, corba_object:non_existent(IOR)), ?match({'object_forward',_}, corba:locate(IOR)), ?match({'object_forward',_}, corba:locate(IOR, 10000)), ok. %%------------------------------------------------------------ %% function : create_alternate_ssl_iiop_address %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ create_alternate_ssl_iiop_address(Host, Port, SSLPort) -> MC = [#'IOP_TaggedComponent'{tag = ?TAG_ORB_TYPE, component_data = ?ORBER_ORB_TYPE_1}, #'IOP_TaggedComponent'{tag = ?TAG_CODE_SETS, component_data = ?DEFAULT_CODESETS}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = Port}}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = 8000}}, #'IOP_TaggedComponent'{tag = ?TAG_ALTERNATE_IIOP_ADDRESS, component_data = #'ALTERNATE_IIOP_ADDRESS'{ 'HostID' = Host, 'Port' = 8000}}, #'IOP_TaggedComponent'{tag=?TAG_SSL_SEC_TRANS, component_data=#'SSLIOP_SSL'{target_supports = 2, target_requires = 2, port = SSLPort}}], #'IOP_IOR'{type_id=TypeID, profiles=P1} = _IORA = iop_ior:create_external({1,2}, "IDL:omg.org/CosNaming/NamingContextExt:1.0", Host, 8000, "NameService", MC), #'IOP_IOR'{profiles=P2} = _IORB = iop_ior:create_external({1,1}, "IDL:omg.org/CosNaming/NamingContextExt:1.0", Host, 8000, "NameService", []), #'IOP_IOR'{type_id=TypeID, profiles=P2++P1}. %%------------------------------------------------------------ %% function : timeouts %% Arguments: Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ timeouts(Host, Port, ReqT) -> NSR = corba:resolve_initial_references_remote("NameService", ["iiop://"++Host++":"++integer_to_list(Port)]), NC1 = lname_component:set_id(lname_component:create(), "mamba"), N1 = lname:insert_component(lname:create(), 1, NC1), NC2 = lname_component:set_id(lname_component:create(), "viper"), N2 = lname:insert_component(lname:create(), 1, NC2), Mamba = 'CosNaming_NamingContext':resolve(NSR, N1), Viper = 'CosNaming_NamingContext':resolve(NSR, N2), ?match({'EXCEPTION',{'TIMEOUT',_,_,_}}, orber_test_timeout_server:twoway_function(Viper, ReqT, ReqT*2)), ?match(ok, orber_test_timeout_server:oneway_function(Viper, ReqT*2)), ?match({'EXCEPTION',{'TIMEOUT',_,_,_}}, orber_test_server:testing_iiop_twoway_delay(Mamba, ReqT)), ?match(ok, orber_test_server:testing_iiop_oneway_delay(Mamba, ReqT)), %% Since the objects are stalled we must wait until they are available again %% to be able to run any more tests and get the correct results. timer:sleep(ReqT*4), ?match(ok, orber_test_timeout_server:twoway_function(Viper, ReqT*2, ReqT)), ?match(ok, orber_test_timeout_server:oneway_function(Viper, ReqT*2)), ?match(ok, orber_test_server:testing_iiop_twoway_delay(Mamba, 0)), ?match(ok, orber_test_server:testing_iiop_oneway_delay(Mamba, 0)), timer:sleep(ReqT*4), ok. %%------------------------------------------------------------ %% function : light_tests %% Arguments: Host - which node to contact. %% Port - which port the other orb uses. %% Returns : term() %% Effect : %%------------------------------------------------------------ light_tests(Host, Port, ObjName) -> NSR = corba:resolve_initial_references_remote("NameService", ["iiop://"++Host++":"++integer_to_list(Port)]), NC1 = lname_component:set_id(lname_component:create(), "not_exist"), N1 = lname:insert_component(lname:create(), 1, NC1), %% We cannot handle any unknown replies (besides those found in stub). ?match({'EXCEPTION', {'CosNaming_NamingContext_NotFound', "IDL:omg.org/CosNaming/NamingContext/NotFound:1.0",_,_}}, 'CosNaming_NamingContext':resolve(NSR, N1)), NC2 = lname_component:set_id(lname_component:create(), ObjName), N2 = lname:insert_component(lname:create(), 1, NC2), Obj = ?match({'IOP_IOR',"IDL:omg.org/orber_test/server:1.0",_}, 'CosNaming_NamingContext':resolve(NSR, N2)), Nodes = orber:get_lightweight_nodes(), io:format("Light Nodes: ~p~n", [Nodes]), orber_test_server:print(Obj), test_coding(Obj), ok. %%------------------------------------------------------------ %% function : test_coding_simple %% Arguments: ObjReference %% Returns : term() %% Effect : test encode/decode for all simple datatypes. %%------------------------------------------------------------ test_coding(Obj) -> test_coding(Obj, false). test_coding(Obj, Local) -> %%--- Testing code and decode arguments --- ?match({ok, 1.5}, orber_test_server:testing_iiop_float(Obj, 1.5)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_float(Obj, atom)), ?match({ok,1.0}, orber_test_server:testing_iiop_double(Obj, 1.0)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_double(Obj, "wrong")), ?match({ok,0}, orber_test_server:testing_iiop_short(Obj, 0)), ?match({ok,?SHORTMAX}, orber_test_server:testing_iiop_short(Obj, ?SHORTMAX)), ?match({ok,?SHORTMIN}, orber_test_server:testing_iiop_short(Obj, ?SHORTMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_short(Obj, atomic)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_short(Obj, ?SHORTMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_short(Obj, ?SHORTMIN-1)), ?match({ok,0}, orber_test_server:testing_iiop_ushort(Obj, 0)), ?match({ok,?USHORTMAX}, orber_test_server:testing_iiop_ushort(Obj, ?USHORTMAX)), ?match({ok,?USHORTMIN}, orber_test_server:testing_iiop_ushort(Obj, ?USHORTMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ushort(Obj, ?USHORTMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ushort(Obj, ?USHORTMIN-1)), ?match({ok,0}, orber_test_server:testing_iiop_long(Obj, 0)), ?match({ok,?LONGMAX}, orber_test_server:testing_iiop_long(Obj, ?LONGMAX)), ?match({ok,?LONGMIN}, orber_test_server:testing_iiop_long(Obj, ?LONGMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_long(Obj, "wrong")), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_long(Obj, ?LONGMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_long(Obj, ?LONGMIN-1)), ?match({ok,0}, orber_test_server:testing_iiop_longlong(Obj, 0)), ?match({ok,?LONGLONGMAX}, orber_test_server:testing_iiop_longlong(Obj, ?LONGLONGMAX)), ?match({ok,?LONGLONGMIN}, orber_test_server:testing_iiop_longlong(Obj, ?LONGLONGMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_longlong(Obj, "wrong")), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_longlong(Obj, ?LONGLONGMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_longlong(Obj, ?LONGLONGMIN-1)), ?match({ok,0}, orber_test_server:testing_iiop_ulong(Obj, 0)), ?match({ok,?ULONGMAX}, orber_test_server:testing_iiop_ulong(Obj, ?ULONGMAX)), ?match({ok,?ULONGMIN}, orber_test_server:testing_iiop_ulong(Obj, ?ULONGMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ulong(Obj, ?ULONGMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ulong(Obj, ?ULONGMIN-1)), ?match({ok,0}, orber_test_server:testing_iiop_ulonglong(Obj, 0)), ?match({ok,?ULONGLONGMAX}, orber_test_server:testing_iiop_ulonglong(Obj, ?ULONGLONGMAX)), ?match({ok,?ULONGLONGMIN}, orber_test_server:testing_iiop_ulonglong(Obj, ?ULONGLONGMIN)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ulonglong(Obj, ?ULONGLONGMAX+1)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_ulonglong(Obj, ?ULONGLONGMIN-1)), ?match({ok,98}, orber_test_server:testing_iiop_char(Obj, 98)), ?match({ok,$b}, orber_test_server:testing_iiop_char(Obj, $b)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_char(Obj, atomic)), ?match({ok,65535}, orber_test_server:testing_iiop_wchar(Obj, 65535)), ?match({ok,$b}, orber_test_server:testing_iiop_wchar(Obj, $b)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_wchar(Obj, atomic)), ?match({ok,true}, orber_test_server:testing_iiop_bool(Obj, true)), ?match({ok,false}, orber_test_server:testing_iiop_bool(Obj, false)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_bool(Obj, atom)), ?match({ok,1}, orber_test_server:testing_iiop_octet(Obj, 1)), % No real guards for this case. % ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, % orber_test_server:testing_iiop_octet(Obj, 1.5)), IOR12 = create_components_IOR({1,2}), ?match({ok,Obj}, orber_test_server:testing_iiop_obj(Obj, Obj)), ?match({ok,IOR12}, orber_test_server:testing_iiop_obj(Obj, IOR12)), PObj = orber_test_server:oe_create([], [{pseudo,true}]), ?match({ok, _}, orber_test_server:testing_iiop_obj(Obj, PObj)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_obj(Obj, "no_object")), ?match({ok,"string"}, orber_test_server:testing_iiop_string(Obj, "string")), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_string(Obj, "ToLongString")), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_string(Obj, atomic)), ?match({ok,[65535]}, orber_test_server:testing_iiop_wstring(Obj, [65535])), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_wstring(Obj, "ToLongWstring")), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_wstring(Obj, atomic)), ?match({ok, one}, orber_test_server:testing_iiop_enum(Obj, one)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_enum(Obj, three)), ?match({ok,[1,2,3]}, orber_test_server:testing_iiop_seq(Obj, [1,2,3])), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_seq(Obj, [1,2,3,4])), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_seq(Obj, false)), ?match({ok,[#orber_test_server_struc{a=1, b=2}]}, orber_test_server:testing_iiop_struc_seq(Obj, [#orber_test_server_struc{a=1, b=2}])), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_struc_seq(Obj, false)), ?match({ok,[#orber_test_server_uni{label=1, value=66}]}, orber_test_server:testing_iiop_uni_seq(Obj, [#orber_test_server_uni{label=1, value=66}])), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_uni_seq(Obj, false)), ?match({ok,{"one", "two"}}, orber_test_server:testing_iiop_array(Obj, {"one", "two"})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_array(Obj, {"one", "two", "three"})), ?match({ok,#orber_test_server_struc{a=1, b=2}}, orber_test_server:testing_iiop_struct(Obj, #orber_test_server_struc{a=1, b=2})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_struct(Obj, #orber_test_server_struc{a="WRONG", b=2})), ?match({ok,#orber_test_server_uni{label=1, value=66}}, orber_test_server:testing_iiop_union(Obj, #orber_test_server_uni{label=1, value=66})), ?match({ok,#orber_test_server_uni_d{label=1, value=66}}, orber_test_server:testing_iiop_union_d(Obj, #orber_test_server_uni_d{label=1, value=66})), ?match({ok,#orber_test_server_uni_d{label=2, value=true}}, orber_test_server:testing_iiop_union_d(Obj, #orber_test_server_uni_d{label=2, value=true})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_union_d(Obj, #orber_test_server_uni_d{label=2, value=66})), case Local of true -> ?match({ok,#orber_test_server_uni{label=2, value=66}}, orber_test_server:testing_iiop_union(Obj, #orber_test_server_uni{label=2, value=66})); false -> ?match({ok,#orber_test_server_uni{label=2, value=undefined}}, orber_test_server:testing_iiop_union(Obj, #orber_test_server_uni{label=2, value=66})) end, C1 = orber_test_server:fixed52const1(), C2 = orber_test_server:fixed52const2(), C3 = orber_test_server:fixed52const3(), C4 = orber_test_server:fixed52negconst1(), C5 = orber_test_server:fixed52negconst2(), C6 = orber_test_server:fixed52negconst3(), ?match({ok,C1}, orber_test_server:testing_iiop_fixed(Obj, C1)), ?match({ok,C2}, orber_test_server:testing_iiop_fixed(Obj, C2)), ?match({ok,C3}, orber_test_server:testing_iiop_fixed(Obj, C3)), ?match({ok,C4}, orber_test_server:testing_iiop_fixed(Obj, C4)), ?match({ok,C5}, orber_test_server:testing_iiop_fixed(Obj, C5)), ?match({ok,C6}, orber_test_server:testing_iiop_fixed(Obj, C6)), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_fixed(Obj, #fixed{digits = 5, scale = 2, value = 123450})), ?match(ok, orber_test_server:testing_iiop_void(Obj)), ?match({'EXCEPTION',{'BAD_QOS',_,_,_}}, orber_test_server:pseudo_call_raise_exc(Obj, 1)), ?match({'EXCEPTION',{'BAD_QOS',_,_,_}}, orber_test_server:pseudo_call_raise_exc(Obj, 2)), ?match({'EXCEPTION',{'orber_test_server_UserDefinedException',_}}, orber_test_server:raise_local_exception(Obj)), ?match({'EXCEPTION',{'orber_test_server_ComplexUserDefinedException',_, [#orber_test_server_struc{a=1, b=2}]}}, orber_test_server:raise_complex_local_exception(Obj)), %% Test all TypeCodes ?match({ok, #any{typecode = tk_long, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_long, value = 1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_long, value = "wrong"})), ?match({ok, #any{typecode = tk_float, value = 1.5}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_float, value = 1.5})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_long, value = "wrong"})), ?match({ok, #any{typecode = tk_double}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_double, value = 1.0})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_double, value = "wrong"})), ?match({ok, #any{typecode = tk_short, value = -1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_short, value = -1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_short, value = atomic})), ?match({ok, #any{typecode = tk_ushort, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ushort, value = 1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ushort, value = -1})), ?match({ok, #any{typecode = tk_long, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_long, value = 1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_long, value = "wrong"})), ?match({ok, #any{typecode = tk_longlong, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_longlong, value = 1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_longlong, value = "wrong"})), ?match({ok, #any{typecode = tk_ulong, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulong, value = 1})), ?match({ok, #any{typecode = tk_ulong, value = 4294967295}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulong, value = 4294967295})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulong, value = 4294967296})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulong, value = -1})), ?match({ok, #any{typecode = tk_ulonglong, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulonglong, value = 1})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_ulonglong, value = -1})), ?match({ok, #any{typecode = tk_char, value = 98}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_char, value = 98})), ?match({ok, #any{typecode = tk_char, value = $b}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_char, value = $b})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_char, value = atomic})), ?match({ok, #any{typecode = tk_wchar, value = 65535}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_wchar, value = 65535})), ?match({ok, #any{typecode = tk_wchar, value = $b}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_wchar, value = $b})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_wchar, value = atomic})), ?match({ok, #any{typecode = tk_boolean, value = true}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_boolean, value = true})), ?match({ok, #any{typecode = tk_boolean, value = false}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_boolean, value = false})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_boolean, value = 1})), ?match({ok, #any{typecode = tk_octet, value = 1}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_octet, value = 1})), ?match({ok, #any{typecode = {tk_objref, "IDL:omg.org/orber_test/server:1.0", "server"}, value = Obj}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_objref, "IDL:omg.org/orber_test/server:1.0", "server"}, value = Obj})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_objref, "IDL:omg.org/orber_test/server:1.0", "server"}, value = "No Object"})), ?match({ok, #any{typecode = {tk_string, 6}, value = "string"}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_string, 6}, value = "string"})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = tk_string, value = atomic})), ?match({ok, #any{typecode = {tk_wstring, 1}, value = [65535]}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_wstring, 1}, value = [65535]})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_wstring, 1}, value = atomic})), ?match({ok, #any{typecode = {tk_enum, "IDL:omg.org/orber_test/server/enumerant:1.0", "enumerant", ["one","two"]}, value = two}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_enum, "IDL:omg.org/orber_test/server/enumerant:1.0", "enumerant", ["one","two"]}, value = two})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_enum, "IDL:omg.org/orber_test/server/enumerant:1.0", "enumerant", ["one","two"]}, value = three})), ?match({ok, #any{typecode = {tk_sequence, tk_long, 3}, value = [1,2,3]}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_sequence, tk_long, 3}, value = [1,2,3]})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_sequence, tk_long, 3}, value = false})), ?match({ok, #any{typecode = {tk_array,{tk_string,0},2}, value = {"one", "two"}}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_array,{tk_string,0},2}, value = {"one", "two"}})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_array,{tk_string,0},2}, value = {"one", "two", "three"}})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_array,{tk_string,0},2}, value = {1, 2}})), ?match({ok, #any{typecode = {tk_struct,"IDL:omg.org/orber_test/server/struc:1.0", "struc", [{"a",tk_long},{"b",tk_short}]}, value = #orber_test_server_struc{a=1, b=2}}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_struct,"IDL:omg.org/orber_test/server/struc:1.0", "struc", [{"a",tk_long},{"b",tk_short}]}, value = #orber_test_server_struc{a=1, b=2}})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_struct,"IDL:omg.org/orber_test/server/struc:1.0", "struc", [{"a",tk_long},{"b",tk_short}]}, value = #orber_test_server_struc{a=1, b="string"}})), ?match({ok, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=1, value=66}}}, orber_test_server: testing_iiop_any(Obj, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=1, value=66}})), case Local of true -> ?match({ok, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=2, value=66}}}, orber_test_server: testing_iiop_any(Obj, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=2, value=66}})); false -> ?match({ok, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=2, value=undefined}}}, orber_test_server: testing_iiop_any(Obj, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=2, value=66}})) end, ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server: testing_iiop_any(Obj, #any{typecode = {tk_union,"IDL:omg.org/orber_test/server/uni:1.0", "uni", tk_long, -1, [{1,"a",tk_long}]}, value = #orber_test_server_uni{label=1, value="string"}})), ?match({ok, #any{typecode = {tk_fixed,5,2}, value = #fixed{digits = 5, scale = 2, value = 12345}}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_fixed,5,2}, value = #fixed{digits = 5, scale = 2, value = 12345}})), ?match({ok, #any{typecode = {tk_fixed,10,2}, value = #fixed{digits = 10, scale = 2, value = 1234567890}}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_fixed,10,2}, value = #fixed{digits = 10, scale = 2, value = 1234567890}})), ?match({ok, #any{typecode = {tk_fixed,6,2}, value = #fixed{digits = 6, scale = 2, value = 300000}}}, orber_test_server:testing_iiop_any(Obj, #any{typecode = {tk_fixed,6,2}, value = #fixed{digits = 6, scale = 2, value = 300000}})), ?match({'EXCEPTION',{'MARSHAL',_,_,_}}, orber_test_server: testing_iiop_server_marshal(Obj, "string")), RecS = #orber_test_server_rec_struct{chain = [#orber_test_server_rec_struct{chain = []}]}, ?match(RecS, orber_test_server:testing_iiop_rec_struct(Obj, RecS)), RecU = #orber_test_server_rec_union{label = 'RecursiveType', value = [#orber_test_server_rec_union{label = 'RecursiveType', value = []}]}, ?match(RecU, orber_test_server:testing_iiop_rec_union(Obj, RecU)), %% RecA1 = #any{typecode = unsupported, value = RecS}, %% RecA2 = #any{typecode = unsupported, value = RecU}, %% ?match(RecA1, %% orber_test_server:testing_iiop_rec_any(Obj, RecA1)), %% ?match(RecA2, %% orber_test_server:testing_iiop_rec_any(Obj, RecA2)), ok. %%--------------- Testing Post- & Pre-cond ------------------- precond(Module, Function, Args) -> error_logger:info_msg("=============== pre-condition ============ Module : ~p Function : ~p Arguments : ~p ==========================================~n", [Module, Function, Args]), ok. postcond(Module, Function, Args, Result) -> error_logger:info_msg("=============== post-condition =========== Module : ~p Function : ~p Arguments : ~p Result : ~p ==========================================~n", [Module, Function, Args, Result]), ok. %%--------------- Testing Missing Module --------------------- oe_get_interface() -> non_existing_module:tc(foo). %%--------------- INTERCEPTOR FUNCTIONS ---------------------- %%------------------------------------------------------------ %% function : new_in_connection %% Arguments: %% Returns : %%------------------------------------------------------------ new_in_connection(Arg, CHost, Port) -> Host = node(), [{SHost, SPort}] = orber:find_sockname_by_peername(CHost, Port), Peers = orber:find_peername_by_sockname(SHost, SPort), error_logger:info_msg("=============== new_in_connection ======== Node : ~p From Host : ~p From Port : ~p To Host : ~p To Port : ~p Peers : ~p Arg : ~p ==========================================~n", [Host, CHost, Port, SHost, SPort, Peers, Arg]), {Host}. %%------------------------------------------------------------ %% function : new_out_connection %% Arguments: %% Returns : %%------------------------------------------------------------ new_out_connection(Arg, SHost, Port) -> Host = node(), error_logger:info_msg("=============== new_out_connection ======= Node : ~p To Host : ~p To Port : ~p Arg : ~p ==========================================~n", [Host, SHost, Port, Arg]), {Host}. %%------------------------------------------------------------ %% function : closed_in_connection %% Arguments: %% Returns : %%------------------------------------------------------------ closed_in_connection(Arg) -> error_logger:info_msg("=============== closed_in_connection ===== Node : ~p Connection: ~p ==========================================~n", [node(), Arg]), Arg. %%------------------------------------------------------------ %% function : closed_out_connection %% Arguments: %% Returns : %%------------------------------------------------------------ closed_out_connection(Arg) -> error_logger:info_msg("=============== closed_out_connection ==== Node : ~p Connection: ~p ==========================================~n", [node(), Arg]), Arg. %%------------------------------------------------------------ %% function : in_request_encoded %% Arguments: %% Returns : %%------------------------------------------------------------ in_request_encoded(Ref, _ObjKey, Ctx, Op, <<100:8,101:8,102:8,103:8,104:8,105:8,106:8,107:8,108:8,109:8,110:8,T/binary>>, _Args) -> error_logger:info_msg("=============== in_request_encoded ======= Connection: ~p Operation : ~p Body : ~p Context : ~p ==========================================~n", [Ref, Op, T, Ctx]), {T, "NewArgs"}. %%------------------------------------------------------------ %% function : in_reply_encoded %% Arguments: %% Returns : %%------------------------------------------------------------ in_reply_encoded(Ref, _ObjKey, Ctx, Op, <<100:8,101:8,102:8,103:8,104:8,105:8,106:8,107:8,108:8,109:8,110:8,T/binary>>, _Args) -> error_logger:info_msg("============== in_reply_encoded ========== Connection: ~p Operation : ~p Body : ~p Context : ~p ==========================================~n", [Ref, Op, T, Ctx]), {T, "NewArgs"}. %%------------------------------------------------------------ %% function : out_reply_encoded %% Arguments: %% Returns : %%------------------------------------------------------------ out_reply_encoded(Ref, _ObjKey, Ctx, Op, List, _Args) -> error_logger:info_msg("============== out_reply_encoded ========= Connection: ~p Operation : ~p Body : ~p Context : ~p ==========================================~n", [Ref, Op, List, Ctx]), {list_to_binary([<<100:8,101:8,102:8,103:8,104:8,105:8,106:8,107:8,108:8,109:8,110:8>>|List]), "NewArgs"}. %%------------------------------------------------------------ %% function : out_request_encoded %% Arguments: %% Returns : %%------------------------------------------------------------ out_request_encoded(Ref, _ObjKey, Ctx, Op, List, _Args) -> error_logger:info_msg("============== out_request_encoded ======= Connection: ~p Operation : ~p Body : ~p Context : ~p ==========================================~n", [Ref, Op, List, Ctx]), {list_to_binary([<<100:8,101:8,102:8,103:8,104:8,105:8,106:8,107:8,108:8,109:8,110:8>>|List]), "NewArgs"}. %%------------------------------------------------------------ %% function : in_request %% Arguments: %% Returns : %%------------------------------------------------------------ in_request(Ref, _ObjKey, Ctx, Op, Params, _Args) -> error_logger:info_msg("=============== in_request =============== Connection: ~p Operation : ~p Parameters: ~p Context : ~p ==========================================~n", [Ref, Op, Params, Ctx]), {Params, "NewArgs"}. %%------------------------------------------------------------ %% function : in_reply %% Arguments: %% Returns : %%------------------------------------------------------------ in_reply(Ref, _ObjKey, Ctx, Op, Reply, _Args) -> error_logger:info_msg("=============== in_reply ================= Connection: ~p Operation : ~p Reply : ~p Context : ~p ==========================================~n", [Ref, Op, Reply, Ctx]), {Reply, "NewArgs"}. %%------------------------------------------------------------ %% function : postinvoke %% Arguments: %% Returns : %%------------------------------------------------------------ out_reply(Ref, _ObjKey, Ctx, Op, Reply, _Args) -> error_logger:info_msg("=============== out_reply ================ Connection: ~p Operation : ~p Reply : ~p Context : ~p ==========================================~n", [Ref, Op, Reply, Ctx]), {Reply, "NewArgs"}. %%------------------------------------------------------------ %% function : postinvoke %% Arguments: %% Returns : %%------------------------------------------------------------ out_request(Ref, _ObjKey, Ctx, Op, Params, _Args) -> error_logger:info_msg("=============== out_request ============== Connection: ~p Operation : ~p Parameters: ~p Context : ~p ==========================================~n", [Ref, Op, Params, Ctx]), {Params, "NewArgs"}. %%--------------- END OF MODULE ------------------------------