%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2012-2016. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%
%% %CopyrightEnd%
%%
%%%-------------------------------------------------------------------
%%% File: ct_system_error_SUITE
%%%
%%% Description:
%%%
%%% Test the group leader functionality in the test_server application.
%%%-------------------------------------------------------------------
-module(ct_group_leader_SUITE).
-compile(export_all).
-include_lib("common_test/include/ct.hrl").
-include_lib("common_test/include/ct_event.hrl").
-define(eh, ct_test_support_eh).
%%--------------------------------------------------------------------
%% TEST SERVER CALLBACK FUNCTIONS
%%--------------------------------------------------------------------
%%--------------------------------------------------------------------
%% Description: Since Common Test starts another Test Server
%% instance, the tests need to be performed on a separate node (or
%% there will be clashes with logging processes etc).
%%--------------------------------------------------------------------
init_per_suite(Config) ->
Config1 = ct_test_support:init_per_suite(Config),
Config1.
end_per_suite(Config) ->
ct_test_support:end_per_suite(Config).
init_per_testcase(TestCase, Config) ->
ct_test_support:init_per_testcase(TestCase, Config).
end_per_testcase(TestCase, Config) ->
ct_test_support:end_per_testcase(TestCase, Config).
suite() -> [{ct_hooks,[ts_install_cth]}].
all() ->
[
basic
].
%%--------------------------------------------------------------------
%% TEST CASES
%%--------------------------------------------------------------------
%%%-----------------------------------------------------------------
%%%
basic(Config) ->
TC = basic,
DataDir = ?config(data_dir, Config),
Suite = filename:join(DataDir, "group_leader_SUITE"),
{Opts,ERPid} = setup([{suite,Suite},{label,TC}], Config),
SuiteLog = execute(TC, Opts, ERPid, Config),
{ok,Data} = file:read_file(SuiteLog),
Lines = binary:split(Data, <<"\n">>, [global]),
{ok,RE} = re:compile("(\\S+):(\\S+)$"),
Cases0 = [begin
{match,[M,F]} = re:run(Case, RE, [{capture,all_but_first,list}]),
{list_to_atom(M),list_to_atom(F)}
end || <<"=case ",Case/binary>> <- Lines],
Cases = [MF || {_,F}=MF <- Cases0,
F =/= init_per_suite,
F =/= end_per_suite,
F =/= init_per_group,
F =/= end_per_group],
io:format("~p\n", [Cases]),
[] = verify_cases(events_to_check(TC), Cases, false),
ok.
verify_cases([{parallel,P}|Ts], Cases0, Par) ->
Cases = verify_cases(P, Cases0, true),
verify_cases(Ts, Cases, Par);
verify_cases([{?eh,tc_done,{M,F,_}}|Ts], Cases0, false) ->
[{M,F}|Cases] = Cases0,
verify_cases(Ts, Cases, false);
verify_cases([{?eh,tc_done,{M,F,_}}|Ts], Cases0, true) ->
case lists:member({M,F}, Cases0) of
true ->
Cases = Cases0 -- [{M,F}],
verify_cases(Ts, Cases, true);
false ->
io:format("~p not found\n", [{M,F}]),
?t:fail()
end;
verify_cases([{?eh,_,_}|Ts], Cases, Par) ->
verify_cases(Ts, Cases, Par);
verify_cases([], Cases, _) ->
Cases;
verify_cases([List|Ts], Cases0, Par) when is_list(List) ->
Cases = verify_cases(List, Cases0, false),
verify_cases(Ts, Cases, Par).
%%%-----------------------------------------------------------------
%%% HELP FUNCTIONS
%%%-----------------------------------------------------------------
setup(Test, Config) ->
Opts0 = ct_test_support:get_opts(Config),
Level = ?config(trace_level, Config),
EvHArgs = [{cbm,ct_test_support},{trace_level,Level}],
Opts = Opts0 ++ [{event_handler,{?eh,EvHArgs}}|Test],
ERPid = ct_test_support:start_event_receiver(Config),
{Opts,ERPid}.
execute(Name, Opts, ERPid, Config) ->
ok = ct_test_support:run(Opts, Config),
Events = ct_test_support:get_events(ERPid, Config),
ct_test_support:log_events(Name,
reformat(Events, ?eh),
?config(priv_dir, Config),
Opts),
TestEvents = events_to_check(Name),
ok = ct_test_support:verify_events(TestEvents, Events, Config),
{event,tc_logfile,_,{_,File}} =
lists:keyfind(tc_logfile, 2, [Ev || {?eh,Ev} <- Events]),
LogDir = filename:dirname(File),
filename:join(LogDir, "suite.log").
reformat(Events, EH) ->
ct_test_support:reformat(Events, EH).
%%%-----------------------------------------------------------------
%%% TEST EVENTS
%%%-----------------------------------------------------------------
events_to_check(_Test) ->
[{?eh,tc_done,{group_leader_SUITE,tc1,ok}},
{parallel,[{?eh,tc_start,{group_leader_SUITE,p1}},
{?eh,tc_done,{group_leader_SUITE,p1,ok}},
{?eh,tc_start,{group_leader_SUITE,p2}},
{?eh,tc_done,{group_leader_SUITE,p2,ok}}]},
{?eh,tc_done,{group_leader_SUITE,p_restart_my_io_server,ok}},
{?eh,tc_done,{group_leader_SUITE,p3,ok}},
{parallel,[
{?eh,tc_start,{group_leader_SUITE,p10}},
{?eh,tc_start,{group_leader_SUITE,p11}},
{?eh,tc_done,{group_leader_SUITE,p10,ok}},
{?eh,tc_done,{group_leader_SUITE,p11,ok}},
[{?eh,tc_done,{group_leader_SUITE,s1,ok}},
{?eh,tc_done,{group_leader_SUITE,s2,ok}},
{?eh,tc_done,{group_leader_SUITE,s3,ok}}],
{?eh,tc_start,{group_leader_SUITE,p12}},
{?eh,tc_done,{group_leader_SUITE,p12,ok}},
[{?eh,tc_done,{group_leader_SUITE,s4,ok}},
{?eh,tc_done,{group_leader_SUITE,s5,ok}}],
{?eh,tc_start,{group_leader_SUITE,p13}},
{?eh,tc_done,{group_leader_SUITE,p13,ok}} ]},
{?eh,tc_done,{group_leader_SUITE,cap1,ok}},
{?eh,tc_done,{group_leader_SUITE,cap2,ok}},
{parallel,[{?eh,tc_start,{group_leader_SUITE,cap1}},
{?eh,tc_done,{group_leader_SUITE,cap1,ok}},
{?eh,tc_start,{group_leader_SUITE,cap2}},
{?eh,tc_done,{group_leader_SUITE,cap2,ok}}]},
{parallel,[{?eh,tc_start,{group_leader_SUITE,unexp1}},
{?eh,tc_done,{group_leader_SUITE,unexp1,ok}},
{?eh,tc_start,{group_leader_SUITE,unexp2}},
{?eh,tc_done,{group_leader_SUITE,unexp2,ok}}]},
{?eh,test_done,{'DEF','STOP_TIME'}},
{?eh,stop_logging,[]}
].
