%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 1999-2010. 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_server_impl).
-include_lib("orber/include/corba.hrl").
-include("idl_output/orber_test_server.hrl").
%%--------------- specified functions ------------------------
-export([stop_normal/2,
stop_brutal/2,
print/2,
%% Testing code and decode arguments
testing_iiop_float/3,
testing_iiop_double/3,
testing_iiop_short/3,
testing_iiop_ushort/3,
testing_iiop_long/3,
testing_iiop_longlong/3,
testing_iiop_ulong/3,
testing_iiop_ulonglong/3,
testing_iiop_char/3,
testing_iiop_wchar/3,
testing_iiop_bool/3,
testing_iiop_octet/3,
testing_iiop_any/3,
testing_iiop_obj/3,
testing_iiop_string/3,
testing_iiop_wstring/3,
testing_iiop_struct/3,
testing_iiop_union/3,
testing_iiop_union_d/3,
testing_iiop_enum/3,
testing_iiop_seq/3,
testing_iiop_uni_seq/3,
testing_iiop_struc_seq/3,
testing_iiop_array/3,
testing_iiop_fixed/3,
testing_iiop_void/2,
testing_iiop_context/2,
testing_iiop_server_marshal/3,
testing_iiop_rec_any/3,
testing_iiop_rec_struct/3,
testing_iiop_rec_union/3,
relay_call/3,
relay_cast/3,
%% Testing pseudo calls.
pseudo_call/2,
pseudo_cast/2,
pseudo_call_delay/3,
pseudo_cast_delay/3,
pseudo_call_raise_exc/3,
%% Testing raise locally defined exception.
raise_local_exception/2,
raise_complex_local_exception/2,
%% Test timeout functionality
testing_iiop_oneway_delay/3,
testing_iiop_twoway_delay/3]).
%%--------------- gen_server specific ------------------------
-export([init/1, terminate/2]).
-export([handle_call/3, handle_cast/2, handle_info/2, code_change/3]).
%%--------------- LOCAL DATA ---------------------------------
%%------------------------------------------------------------
%% function : init, terminate
%%------------------------------------------------------------
init(State) ->
process_flag(trap_exit,true),
{ok, State}.
terminate(Reason, State) ->
io:format("orber_test_server:terminate(~p ~p)~n",[Reason, State]),
ok.
code_change(_OldVsn, State, _Extra) ->
{ok, State}.
handle_call(_,_, State) ->
{noreply, State}.
handle_cast(_, State) ->
{noreply, State}.
handle_info(_Info, State) ->
{noreply, State}.
%%--------------- SERVER FUNCTIONS ---------------------------
print(Self, State) ->
io:format("orber_test_server:print(~p ~p)~n",[Self, State]),
{reply, ok, State}.
stop_normal(_Self, State) ->
{stop, normal, ok, State}.
stop_brutal(_Self, _State) ->
exit("killed_brutal").
%% Testing code and decode arguments
testing_iiop_float(_Self, State, Float) ->
{reply, {ok, Float}, State}.
testing_iiop_double(_Self, State, Double) ->
{reply, {ok, Double}, State}.
testing_iiop_short(_Self, State, Short) ->
{reply, {ok, Short}, State}.
testing_iiop_ushort(_Self, State, Ushort) ->
{reply, {ok, Ushort}, State}.
testing_iiop_long(_Self, State, Long) ->
{reply, {ok, Long}, State}.
testing_iiop_longlong(_Self, State, LLong) ->
{reply, {ok, LLong}, State}.
testing_iiop_ulong(_Self, State, Ulong) ->
{reply, {ok, Ulong}, State}.
testing_iiop_ulonglong(_Self, State, ULlong) ->
{reply, {ok, ULlong}, State}.
testing_iiop_char(_Self, State, Char) ->
{reply, {ok, Char}, State}.
testing_iiop_wchar(_Self, State, WChar) ->
{reply, {ok, WChar}, State}.
testing_iiop_bool(_Self, State, Boolean) ->
{reply, {ok, Boolean}, State}.
testing_iiop_octet(_Self, State, Octet) ->
{reply, {ok, Octet}, State}.
testing_iiop_any(_Self, State, Any) ->
{reply, {ok, Any}, State}.
testing_iiop_obj(_Self, State, Obj) ->
{reply, {ok, Obj}, State}.
testing_iiop_string(_Self, State, String) ->
{reply, {ok, String}, State}.
testing_iiop_wstring(_Self, State, WString) ->
{reply, {ok, WString}, State}.
testing_iiop_struct(_Self, State, Struct) ->
{reply, {ok, Struct}, State}.
testing_iiop_union(_Self, State, Union) ->
{reply, {ok, Union}, State}.
testing_iiop_union_d(_Self, State, Union) ->
{reply, {ok, Union}, State}.
testing_iiop_enum(_Self, State, Enum) ->
{reply, {ok, Enum}, State}.
testing_iiop_seq(_Self, State, Sequence) ->
{reply, {ok, Sequence}, State}.
testing_iiop_uni_seq(_Self, State, Sequence) ->
{reply, {ok, Sequence}, State}.
testing_iiop_struc_seq(_Self, State, Sequence) ->
{reply, {ok, Sequence}, State}.
testing_iiop_array(_Self, State, Array) ->
{reply, {ok, Array}, State}.
testing_iiop_fixed(_Self, State, Fixed) ->
{reply, {ok, Fixed}, State}.
testing_iiop_void(_Self, State) ->
{reply, ok, State}.
testing_iiop_context(_Self, State) ->
Ctx = get(oe_server_in_context),
io:format("orber_test_server:testing_iiop_context( ~p )~n", [Ctx]),
{reply, ok, State}.
testing_iiop_server_marshal(_Self, State, _String) ->
{reply, {ok, false}, State}.
testing_iiop_rec_any(_Self, State, RAny) ->
{reply, RAny, State}.
testing_iiop_rec_struct(_Self, State, RecS) ->
{reply, RecS, State}.
testing_iiop_rec_union(_Self, State, RecU) ->
{reply, RecU, State}.
testing_iiop_oneway_delay(_Self, State, Time) ->
timer:sleep(Time),
{noreply, State}.
testing_iiop_twoway_delay(_Self, State, Time) ->
timer:sleep(Time),
{reply, ok, State}.
raise_local_exception(_Self, State) ->
corba:raise(#'orber_test_server_UserDefinedException'{}),
{reply, ok, State}.
raise_complex_local_exception(_Self, State) ->
corba:raise(#'orber_test_server_ComplexUserDefinedException'{strseq=
[#orber_test_server_struc{a=1, b=2}]}),
{reply, ok, State}.
%% Testing relay calls/casts to, for example, test that sending implicit
%% Contexts works.
relay_call(_Self, State, Target) ->
io:format("orber_test_server:relay_call( ~p ) Pre~n", [get(oe_server_in_context)]),
orber_test_server:testing_iiop_context(Target),
io:format("orber_test_server:relay_call( ~p ) Post~n", [get(oe_server_in_context)]),
{reply, ok, State}.
relay_cast(_Self, State, Target) ->
io:format("orber_test_server:relay_cast( ~p ) Pre~n", [get(oe_server_in_context)]),
orber_test_server:testing_iiop_context(Target),
io:format("orber_test_server:relay_cast( ~p ) Post~n", [get(oe_server_in_context)]),
{noreply, State}.
%% Testing pseudo calls.
pseudo_call(_Self, State) ->
io:format("orber_test_server:pseudo_call( ~p )~n", [now()]),
{reply, ok, State}.
pseudo_cast(_Self, State) ->
io:format("orber_test_server:pseudo_cast( ~p )~n", [now()]),
{noreply, State}.
pseudo_call_delay(_Self, State, Time) ->
io:format("orber_test_server:pseudo_call_delay( ~p )~n", [now()]),
timer:sleep(Time),
io:format("orber_test_server:pseudo_call_delay( ~p )~n", [now()]),
{reply, {ok, Time}, State}.
pseudo_cast_delay(_Self, State, Time) ->
io:format("orber_test_server:pseudo_cast_delay( ~p )~n", [now()]),
timer:sleep(Time),
io:format("orber_test_server:pseudo_cast_delay( ~p )~n", [now()]),
{noreply, State}.
pseudo_call_raise_exc(_Self, State, 1) ->
io:format("orber_test_server:pseudo_call_raise_exc( ~p )~n",[1]),
{reply, {'EXCEPTION', #'BAD_QOS'{completion_status=?COMPLETED_NO}}, State};
pseudo_call_raise_exc(_Self, State, 2) ->
io:format("orber_test_server:pseudo_call_raise_exc( ~p )~n",[2]),
corba:raise(#'BAD_QOS'{completion_status=?COMPLETED_NO}),
{reply, ok, State}.
%%--------------- LOCAL FUNCTIONS ----------------------------
%%--------------- END OF MODULE ------------------------------
