CORBA applications test suites published

1 files changed, 316 insertions, 0 deletions

diff --git a/lib/cosEvent/test/event_channel_SUITE.erl b/lib/cosEvent/test/event_channel_SUITE.erl
new file mode 100644
index 0000000000..2b0cf1fe30
--- /dev/null
+++ b/lib/cosEvent/test/event_channel_SUITE.erl
@@ -0,0 +1,316 @@
+%%-----------------------------------------------------------------
+%%
+%% %CopyrightBegin%
+%% 
+%% Copyright Ericsson AB 1997-2009. All Rights Reserved.
+%% 
+%% The contents of this file are subject to the Erlang Public License,
+%% Version 1.1, (the "License"); you may not use this file except in
+%% compliance with the License. You should have received a copy of the
+%% Erlang Public License along with this software. If not, it can be
+%% retrieved online at http://www.erlang.org/.
+%% 
+%% Software distributed under the License is distributed on an "AS IS"
+%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+%% the License for the specific language governing rights and limitations
+%% under the License.
+%% 
+%% %CopyrightEnd%
+%%
+%%
+%%-----------------------------------------------------------------
+
+-module(event_channel_SUITE).
+
+-include("test_server.hrl").
+-include_lib("orber/include/corba.hrl").
+-include_lib("orber/COSS/CosNaming/CosNaming.hrl").
+-include_lib("orber/src/orber_iiop.hrl").
+
+%%-----------------------------------------------------------------
+%% Macros
+%%-----------------------------------------------------------------
+
+-define(default_timeout, ?t:minutes(5)).
+
+
+-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 ######~n~p~n",
+				  [AcTuAlReS]),
+			?line exit(AcTuAlReS)
+		end
+	end()).
+
+
+%%-----------------------------------------------------------------
+%% External exports
+%%-----------------------------------------------------------------
+-export([all/1, event_objects_api/1, events_api/1, events_sync_api/1, 
+	 cases/0, init_all/1, finish_all/1, 
+	 init_per_testcase/2, fin_per_testcase/2, app_test/1]).
+
+%%-----------------------------------------------------------------
+%% Internal exports
+%%-----------------------------------------------------------------
+
+all(doc) -> ["API tests for the cosEvent interfaces", ""];
+all(suite) -> {req,
+               [mnesia, orber],
+               {conf, init_all, cases(), finish_all}}.
+ 
+cases() ->
+    [events_api, events_sync_api, event_objects_api, app_test].
+
+%%-----------------------------------------------------------------
+%% Init and cleanup functions.
+%%-----------------------------------------------------------------
+
+init_per_testcase(_Case, Config) ->
+    ?line Dog=test_server:timetrap(?default_timeout),
+    [{watchdog, Dog}|Config].
+
+
+fin_per_testcase(_Case, Config) ->
+    Dog = ?config(watchdog, Config),
+    test_server:timetrap_cancel(Dog),
+    ok.
+
+init_all(Config) when is_list(Config) ->
+    Path = code:which(?MODULE),
+    code:add_pathz(filename:join(filename:dirname(Path), "idl_output")),
+    mnesia:delete_schema([node()]),
+    mnesia:create_schema([node()]),
+    orber:install([node()]),
+    application:start(mnesia),
+    application:start(orber),
+    cosEventApp:install(),
+    cosEventApp:start(),
+    oe_event_test_server:oe_register(),
+    Config.
+
+finish_all(Config) when is_list(Config) ->
+    oe_event_test_server:oe_unregister(),
+    cosEventApp:stop(),
+    cosEventApp:uninstall(),
+    application:stop(orber),
+    application:stop(mnesia),
+    mnesia:delete_schema([node()]),
+    Path = code:which(?MODULE),
+    code:del_path(filename:join(filename:dirname(Path), "idl_output")),
+    Config.
+
+%%-----------------------------------------------------------------
+%%  Tests app file
+%%-----------------------------------------------------------------
+app_test(doc) -> [];
+app_test(suite) -> [];
+app_test(_Config) ->
+    ok=test_server:app_test(cosEvent),
+    ok.
+
+
+
+event_objects_api(doc) -> ["Testing the CosEvent API to setup a complete service", ""];
+event_objects_api(suite) -> [];
+event_objects_api(_Config) ->
+
+    Ch = ?match({_,key,_,_,_,_}, cosEventApp:start_channel([{typecheck, true},
+							    {pull_interval, 300}])),
+
+    AC=?match({_,key,_,_,_,_},
+	      'CosEventChannelAdmin_EventChannel':for_consumers(Ch)),
+    AS=?match({_,key,_,_,_,_},
+	      'CosEventChannelAdmin_EventChannel':for_suppliers(Ch)),
+
+    PPushS=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_ConsumerAdmin':obtain_push_supplier(AC)),
+    PPullS=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_ConsumerAdmin':obtain_pull_supplier(AC)),
+    
+    PPushC=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_SupplierAdmin':obtain_push_consumer(AS)),
+    PPullC=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_SupplierAdmin':obtain_pull_consumer(AS)),
+    
+    PushC=?match({_,key,_,_,_,_},
+		    'event_test_PushC':oe_create([])),
+    PullC=?match({_,key,_,_,_,_},
+		    'event_test_PullC':oe_create(PPullC)),
+    
+    PushS=?match({_,key,_,_,_,_},
+		    'event_test_PushS':oe_create(PPushC)),
+
+    PullS=?match({_,key,_,_,_,_},
+		    'event_test_PullS':oe_create([])),
+    
+    NIL = corba:create_nil_objref(),
+
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPushSupplier':connect_push_consumer(PPushS, NIL)),
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPushSupplier':connect_push_consumer(PPushS, PullS)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPushSupplier':connect_push_consumer(PPushS, PushC)),
+    ?match({'EXCEPTION',{'CosEventChannelAdmin_AlreadyConnected',_}},
+	   'CosEventChannelAdmin_ProxyPushSupplier':connect_push_consumer(PPushS, PushC)),
+
+    ?match(ok, 'CosEventChannelAdmin_ProxyPullSupplier':connect_pull_consumer(PPullS, NIL)),
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPullSupplier':connect_pull_consumer(PPullS, PullS)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPullSupplier':connect_pull_consumer(PPullS, PullC)),
+    ?match({'EXCEPTION',{'CosEventChannelAdmin_AlreadyConnected',_}},
+	   'CosEventChannelAdmin_ProxyPullSupplier':connect_pull_consumer(PPullS, PullC)),
+
+    ?match(ok, 'CosEventChannelAdmin_ProxyPushConsumer':connect_push_supplier(PPushC, NIL)),
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPushConsumer':connect_push_supplier(PPushC, PullS)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPushConsumer':connect_push_supplier(PPushC, PushS)),
+    ?match({'EXCEPTION',{'CosEventChannelAdmin_AlreadyConnected',_}},
+	   'CosEventChannelAdmin_ProxyPushConsumer':connect_push_supplier(PPushC, PushS)),
+
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPullConsumer':connect_pull_supplier(PPullC, NIL)),
+    ?match({'EXCEPTION',{'BAD_PARAM',_,_,_}},
+	   'CosEventChannelAdmin_ProxyPullConsumer':connect_pull_supplier(PPullC, PushS)),    
+    ?match(ok, 'CosEventChannelAdmin_ProxyPullConsumer':connect_pull_supplier(PPullC, PullS)),
+    ?match({'EXCEPTION',{'CosEventChannelAdmin_AlreadyConnected',_}},
+	   'CosEventChannelAdmin_ProxyPullConsumer':connect_pull_supplier(PPullC, PullS)),
+
+
+    catch corba:dispose(AC),
+    %% Wait a couple of seconds to be sure all data removed from DB.
+    timer:sleep(2000),
+
+    %% Since we terminated ConsumerAdmin only the Supplier Proxies should be terminated.
+    ?match(true, corba_object:non_existent(AC)),
+    ?match(true, corba_object:non_existent(PPushS)),
+    ?match(true, corba_object:non_existent(PPullS)),
+
+    ?match(false, corba_object:non_existent(Ch)),
+    ?match(false, corba_object:non_existent(AS)),
+    ?match(false, corba_object:non_existent(PPullC)),
+    ?match(false, corba_object:non_existent(PPushC)),
+
+    %% Terminate a proxy and check that its admin is unaffected.
+    catch corba:dispose(PPullC),
+    timer:sleep(2000),
+    ?match(false, corba_object:non_existent(AS)),
+    ?match(true, corba_object:non_existent(PPullC)),
+
+    catch corba:dispose(Ch),
+    timer:sleep(2000),
+
+    ?match(true, corba_object:non_existent(Ch)),
+    ?match(true, corba_object:non_existent(AS)),
+    ?match(true, corba_object:non_existent(PPullC)),
+    ?match(true, corba_object:non_existent(PPushC)),
+    
+    %% The client should be notified; wait for a couple of seconds and check it.
+    timer:sleep(2000),
+    ?match(true, corba_object:non_existent(PushC)),
+    ?match(true, corba_object:non_existent(PullC)),
+    ?match(true, corba_object:non_existent(PushS)),
+    ?match(true, corba_object:non_existent(PullS)),
+
+    ok.
+
+events_api(doc) -> ["Testing the CosEvent API for sending events asynchronous", ""];
+events_api(suite) -> [];
+events_api(_Config) ->
+
+    Ch = ?match({_,key,_,_,_,_}, cosEventApp:start_channel([{typecheck, true},
+							    {pull_interval, 2},
+							    {blocking, false}])),
+    event_sender(Ch).
+
+
+events_sync_api(doc) -> ["Testing the CosEvent API for sending events synchronous", ""];
+events_sync_api(suite) -> [];
+events_sync_api(_Config) ->
+
+    Ch = ?match({_,key,_,_,_,_}, cosEventApp:start_channel([{typecheck, true},
+							    {pull_interval, 2},
+							    {blocking, true}])),
+    event_sender(Ch).
+
+event_sender(Ch) ->
+    Event1 = #any{typecode=tk_long, value = 1},
+    Event2 = #any{typecode=tk_long, value = 2},
+    Event3 = #any{typecode=tk_long, value = 3},
+    Event4 = #any{typecode=tk_long, value = 4},
+    Event5 = #any{typecode=tk_long, value = 5},
+    Event6 = #any{typecode=tk_long, value = 6},
+    
+    AC=?match({_,key,_,_,_,_},
+	      'CosEventChannelAdmin_EventChannel':for_consumers(Ch)),
+    AS=?match({_,key,_,_,_,_},
+	      'CosEventChannelAdmin_EventChannel':for_suppliers(Ch)),
+
+    PPushS=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_ConsumerAdmin':obtain_push_supplier(AC)),
+    PPullS=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_ConsumerAdmin':obtain_pull_supplier(AC)),
+    
+    PPushC=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_SupplierAdmin':obtain_push_consumer(AS)),
+    PPullC=?match({_,key,_,_,_,_},
+		  'CosEventChannelAdmin_SupplierAdmin':obtain_pull_consumer(AS)),
+
+    PushC=?match({_,key,_,_,_,_}, 'event_test_PushC':oe_create([])),
+    PullC=?match({_,key,_,_,_,_}, 'event_test_PullC':oe_create(PPullS)),
+    
+    PushS=?match({_,key,_,_,_,_}, 'event_test_PushS':oe_create(PPushC)),
+
+    PullS=?match({_,key,_,_,_,_}, 'event_test_PullS':oe_create([])),
+    
+    ?match(ok, 'CosEventChannelAdmin_ProxyPushSupplier':connect_push_consumer(PPushS, PushC)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPullSupplier':connect_pull_consumer(PPullS, PullC)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPushConsumer':connect_push_supplier(PPushC, PushS)),
+    ?match(ok, 'CosEventChannelAdmin_ProxyPullConsumer':connect_pull_supplier(PPullC, PullS)),
+
+    %% No events should be available at the consumer side at this point.
+    ?match({_, false}, event_test_PullC:do_try_pull(PullC)),
+    ?match([], event_test_PushC:get_data(PushC)),
+
+    %% Push an event and wait to be sure it have reached the destination.
+    ?match(ok, event_test_PushS:do_push(PushS, Event1)),
+    ?match(ok, event_test_PushS:do_push(PushS, Event2)),
+    ?match(ok, event_test_PushS:do_push(PushS, Event3)),
+    timer:sleep(2000),
+    ?match({Event1, true}, event_test_PullC:do_try_pull(PullC)),
+    ?match({Event2, true}, event_test_PullC:do_try_pull(PullC)),
+    ?match({Event3, true}, event_test_PullC:do_try_pull(PullC)),
+    ?match({_, false}, event_test_PullC:do_try_pull(PullC)),
+    ?match([Event1, Event2, Event3], event_test_PushC:get_data(PushC)),
+
+    ?match(ok, event_test_PullS:add_event(PullS, Event4)),
+    ?match(ok, event_test_PullS:add_event(PullS, Event5)),
+    ?match(ok, event_test_PullS:add_event(PullS, Event6)),
+
+    %% Since the pull operation is blocking we do not need to "sleep".
+    %% The ProxyPullConsumer will pull for events according to the pull_interval
+    %% parameter given when started the channel.
+    ?match(Event4, event_test_PullC:do_pull(PullC)),
+    ?match(Event5, event_test_PullC:do_pull(PullC)),
+    ?match(Event6, event_test_PullC:do_pull(PullC)),
+
+    timer:sleep(2000),
+    ?match([Event4, Event5, Event6], event_test_PushC:get_data(PushC)),
+   
+    
+    catch corba:dispose(Ch),
+    %% The client should be notified; wait for a couple of seconds and check it.
+    timer:sleep(2000),
+    ?match(true, corba_object:non_existent(PushC)),
+    ?match(true, corba_object:non_existent(PullC)),
+    ?match(true, corba_object:non_existent(PushS)),
+    ?match(true, corba_object:non_existent(PullS)),
+
+    ok.