path: root/lib/orber/test/orber_test_lib.erl

%%
%% %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_old/2,
	 get_options_old/3,
	 get_options_old/4,
	 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_old(Type, Role) ->
    get_options_old(Type, Role, 2, []).

get_options_old(ssl, Role, Level) ->
    get_options_old(ssl, Role, Level, []).

get_options_old(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_old(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_old(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].

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_options, [{depth, 2},
			{verify, 2},
			{certfile, filename:join([Dir, "server", "cert.pem"])},
			{cacertfile, filename:join([Dir, "server", "cacerts.pem"])},
			{keyfile, filename:join([Dir, "server", "key.pem"])}]},
     {ssl_client_options, [{depth, 2},
			{verify, 2},
			{certfile, filename:join([Dir, "client", "cert.pem"])},
			{cacertfile, filename:join([Dir, "client", "cacerts.pem"])},
			{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_options, [{depth, 1},
			{verify, 0},
			{certfile, filename:join([Dir, "server", "cert.pem"])},
			{cacertfile, filename:join([Dir, "server", "cacerts.pem"])},
			{keyfile, filename:join([Dir, "server", "key.pem"])}]},
     {ssl_client_options, [{depth, 1},
			{verify, 0},
			{certfile, filename:join([Dir, "client", "cert.pem"])},
			{cacertfile, filename:join([Dir, "client", "cacerts.pem"])},
			{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 ------------------------------