%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2006-2011. 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 : z_SUITE.erl
%%% Author : Rickard Green <[email protected]>
%%% Description : Misc tests that should be run last
%%%
%%% Created : 15 Jul 2005 by Rickard Green <[email protected]>
%%%-------------------------------------------------------------------
-module(z_SUITE).
-author('[email protected]').
%-define(line_trace, 1).
-include_lib("common_test/include/ct.hrl").
-export([all/0, suite/0]).
-export([schedulers_alive/1, node_container_refc_check/1,
long_timers/1, pollset_size/1,
check_io_debug/1, get_check_io_info/0]).
suite() ->
[{ct_hooks,[ts_install_cth]},
{timetrap, {minutes, 5}}].
all() ->
[schedulers_alive, node_container_refc_check,
long_timers, pollset_size, check_io_debug].
%%%
%%% The test cases -------------------------------------------------------------
%%%
%% Tests that all schedulers are actually used
schedulers_alive(Config) when is_list(Config) ->
?line Master = self(),
?line NoSchedulersOnline = erlang:system_flag(
schedulers_online,
erlang:system_info(schedulers)),
?line NoSchedulers = erlang:system_info(schedulers),
UsedScheds =
try
?line io:format("Number of schedulers configured: ~p~n", [NoSchedulers]),
?line case erlang:system_info(multi_scheduling) of
blocked ->
?line ct:fail(multi_scheduling_blocked);
disabled ->
?line ok;
enabled ->
io:format("Testing blocking process exit~n"),
BF = fun () ->
blocked = erlang:system_flag(multi_scheduling,
block),
Master ! {self(), blocking},
receive after infinity -> ok end
end,
?line Blocker = spawn_link(BF),
?line Mon = erlang:monitor(process, Blocker),
?line receive {Blocker, blocking} -> ok end,
?line [Blocker]
= erlang:system_info(multi_scheduling_blockers),
?line unlink(Blocker),
?line exit(Blocker, kill),
?line receive {'DOWN', Mon, _, _, _} -> ok end,
?line enabled = erlang:system_info(multi_scheduling),
?line [] = erlang:system_info(multi_scheduling_blockers),
?line ok
end,
io:format("Testing blocked~n"),
?line erlang:system_flag(multi_scheduling, block),
?line case erlang:system_info(multi_scheduling) of
enabled ->
?line ct:fail(multi_scheduling_enabled);
blocked ->
?line [Master] = erlang:system_info(multi_scheduling_blockers);
disabled -> ?line ok
end,
?line Ps = lists:map(
fun (_) ->
spawn_link(fun () ->
run_on_schedulers(none,
[],
Master)
end)
end,
lists:seq(1,NoSchedulers)),
?line receive after 1000 -> ok end,
?line {_, 1} = verify_all_schedulers_used({[],0}, 1),
?line lists:foreach(fun (P) ->
unlink(P),
exit(P, bang)
end,
Ps),
?line case erlang:system_flag(multi_scheduling, unblock) of
blocked -> ?line ct:fail(multi_scheduling_blocked);
disabled -> ?line ok;
enabled -> ?line ok
end,
erts_debug:set_internal_state(available_internal_state, true),
%% node_and_dist_references will use emulator interal thread blocking...
erts_debug:get_internal_state(node_and_dist_references),
erts_debug:set_internal_state(available_internal_state, false),
io:format("Testing not blocked~n"),
?line Ps2 = lists:map(
fun (_) ->
spawn_link(fun () ->
run_on_schedulers(none,
[],
Master)
end)
end,
lists:seq(1,NoSchedulers)),
?line receive after 1000 -> ok end,
?line {_, NoSIDs} = verify_all_schedulers_used({[],0},NoSchedulers),
?line lists:foreach(fun (P) ->
unlink(P),
exit(P, bang)
end,
Ps2),
NoSIDs
after
NoSchedulers = erlang:system_flag(schedulers_online,
NoSchedulersOnline),
NoSchedulersOnline = erlang:system_info(schedulers_online)
end,
?line {comment, "Number of schedulers " ++ integer_to_list(UsedScheds)}.
run_on_schedulers(LastSID, SIDs, ReportTo) ->
case erlang:system_info(scheduler_id) of
LastSID ->
erlang:yield(),
run_on_schedulers(LastSID, SIDs, ReportTo);
SID ->
NewSIDs = case lists:member(SID, SIDs) of
true ->
SIDs;
false ->
ReportTo ! {scheduler_used, SID},
[SID | SIDs]
end,
erlang:yield(),
run_on_schedulers(SID, NewSIDs, ReportTo)
end.
wait_on_used_scheduler({SIDs, SIDsLen} = State) ->
receive
{scheduler_used, SID} ->
case lists:member(SID, SIDs) of
true ->
wait_on_used_scheduler(State);
false ->
io:format("Scheduler ~p used~n", [SID]),
{[SID|SIDs], SIDsLen+1}
end
end.
verify_all_schedulers_used({UsedSIDs, UsedSIDsLen} = State, NoSchedulers) ->
?line case NoSchedulers of
UsedSIDsLen ->
?line State;
NoSchdlrs when NoSchdlrs < UsedSIDsLen ->
?line ct:fail({more_schedulers_used_than_exist,
{existing_schedulers, NoSchdlrs},
{used_schedulers, UsedSIDsLen},
{used_scheduler_ids, UsedSIDs}});
_ ->
?line NewState = wait_on_used_scheduler(State),
?line verify_all_schedulers_used(NewState, NoSchedulers)
end.
node_container_refc_check(Config) when is_list(Config) ->
?line node_container_SUITE:node_container_refc_check(node()),
?line ok.
long_timers(Config) when is_list(Config) ->
?line ok = long_timers_test:check_result().
pollset_size(Config) when is_list(Config) ->
?line Name = pollset_size_testcase_initial_state_holder,
?line Mon = erlang:monitor(process, Name),
?line (catch Name ! {get_initial_check_io_result, self()}),
?line InitChkIo = receive
{initial_check_io_result, ICIO} ->
?line erlang:demonitor(Mon, [flush]),
?line ICIO;
{'DOWN', Mon, _, _, Reason} ->
?line ct:fail({non_existing, Name, Reason})
end,
?line FinChkIo = get_check_io_info(),
?line io:format("Initial: ~p~nFinal: ~p~n", [InitChkIo, FinChkIo]),
?line InitPollsetSize = lists:keysearch(total_poll_set_size, 1, InitChkIo),
?line FinPollsetSize = lists:keysearch(total_poll_set_size, 1, FinChkIo),
HasGethost = case has_gethost() of true -> 1; _ -> 0 end,
?line case InitPollsetSize =:= FinPollsetSize of
true ->
case InitPollsetSize of
{value, {total_poll_set_size, Size}} ->
?line {comment,
"Pollset size: " ++ integer_to_list(Size)};
_ ->
?line {skipped,
"Pollset size information not available"}
end;
false ->
%% Somtimes we have fewer descriptors in the
%% pollset at the end than when we started, but
%% that is ok as long as there are at least 2
%% descriptors (dist listen socket and
%% epmd socket) in the pollset.
?line {value, {total_poll_set_size, InitSize}}
= InitPollsetSize,
?line {value, {total_poll_set_size, FinSize}}
= FinPollsetSize,
?line true = FinSize < (InitSize + HasGethost),
?line true = 2 =< FinSize,
?line {comment,
"Start pollset size: "
++ integer_to_list(InitSize)
++ " End pollset size: "
++ integer_to_list(FinSize)}
end.
check_io_debug(Config) when is_list(Config) ->
?line case lists:keysearch(name, 1, erlang:system_info(check_io)) of
{value, {name, erts_poll}} -> ?line check_io_debug_test();
_ -> ?line {skipped, "Not implemented in this emulator"}
end.
check_io_debug_test() ->
erlang:display(get_check_io_info()),
erts_debug:set_internal_state(available_internal_state, true),
{NoErrorFds, NoUsedFds, NoDrvSelStructs, NoDrvEvStructs} = CheckIoDebug
= erts_debug:get_internal_state(check_io_debug),
erts_debug:set_internal_state(available_internal_state, false),
HasGetHost = has_gethost(),
ct:log("check_io_debug: ~p~n"
"HasGetHost: ~p",[CheckIoDebug, HasGetHost]),
0 = NoErrorFds,
if
NoUsedFds == NoDrvSelStructs ->
ok;
HasGetHost andalso (NoUsedFds == (NoDrvSelStructs - 1)) ->
%% If the inet_gethost port is alive, we may have
%% one extra used fd that is not selected on.
%% This happens when the initial setup of the
%% port returns an EAGAIN
ok
end,
?line 0 = NoDrvEvStructs,
?line ok.
has_gethost() ->
has_gethost(erlang:ports()).
has_gethost([P|T]) ->
case erlang:port_info(P, name) of
{name,"inet_gethost"++_} ->
true;
_ ->
has_gethost(T)
end;
has_gethost([]) ->
false.
%%
%% Internal functions...
%%
display_check_io(ChkIo) ->
catch erlang:display('--- CHECK IO INFO ---'),
catch erlang:display(ChkIo),
catch erts_debug:set_internal_state(available_internal_state, true),
NoOfErrorFds = (catch element(1, erts_debug:get_internal_state(check_io_debug))),
catch erlang:display({'NoOfErrorFds', NoOfErrorFds}),
catch erts_debug:set_internal_state(available_internal_state, false),
catch erlang:display('--- CHECK IO INFO ---'),
ok.
get_check_io_info() ->
ChkIo = erlang:system_info(check_io),
PendUpdNo = case lists:keysearch(pending_updates, 1, ChkIo) of
{value, {pending_updates, PendNo}} ->
PendNo;
false ->
0
end,
{value, {active_fds, ActFds}} = lists:keysearch(active_fds, 1, ChkIo),
case {PendUpdNo, ActFds} of
{0, 0} ->
display_check_io(ChkIo),
ChkIo;
_ ->
receive after 100 -> ok end,
get_check_io_info()
end.
