%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2015-2018. 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%
%%
-module(beam_utils_SUITE).
-export([all/0,suite/0,groups/0,init_per_suite/1,end_per_suite/1,
init_per_group/2,end_per_group/2,
apply_fun/1,apply_mf/1,bs_init/1,bs_save/1,
is_not_killed/1,is_not_used_at/1,
select/1,y_catch/1,otp_8949_b/1,liveopt/1,coverage/1,
y_registers/1,user_predef/1,scan_f/1,cafu/1,
receive_label/1,read_size_file_version/1,not_used/1,
is_used_fr/1]).
-export([id/1]).
suite() -> [{ct_hooks,[ts_install_cth]}].
all() ->
test_lib:recompile(?MODULE),
[{group,p}].
groups() ->
[{p,[parallel],
[apply_fun,
apply_mf,
bs_init,
bs_save,
is_not_killed,
is_not_used_at,
select,
y_catch,
otp_8949_b,
liveopt,
coverage,
y_registers,
user_predef,
scan_f,
cafu,
read_size_file_version,
not_used,
is_used_fr
]}].
init_per_suite(Config) ->
Config.
end_per_suite(_Config) ->
ok.
init_per_group(_GroupName, Config) ->
Config.
end_per_group(_GroupName, Config) ->
Config.
apply_fun(_Config) ->
3 = do_apply_fun(false, false),
3 = do_apply_fun(false, true),
3 = do_apply_fun(true, false),
2 = do_apply_fun(true, true),
ok.
do_apply_fun(X, Y) ->
F = fun(I) -> I+1 end,
Arg = case X andalso id(Y) of
true -> 1;
false -> 2
end,
F(Arg).
apply_mf(_Config) ->
ok = do_apply_mf_used({a,b}, ?MODULE, id),
error = do_apply_mf_used([a], ?MODULE, id),
{'EXIT',{{case_clause,{[],b}},_}} = (catch do_apply_mf_used({[],b}, ?MODULE, id)),
error = do_apply_mf_killed({error,[a]}, ?MODULE, id),
ok = do_apply_mf_killed([b], ?MODULE, id),
{'EXIT',{{case_clause,{a,[b]}},_}} = (catch do_apply_mf_killed({a,[b]}, ?MODULE, id)),
{'EXIT',{{case_clause,{error,[]}},_}} = (catch do_apply_mf_killed({error,[]}, ?MODULE, id)),
ok.
do_apply_mf_used(Arg, Mod, Func) ->
Res = case id(Arg) of
{Decoded,_} when Decoded =/= [] ->
ok;
List when is_list(List) ->
error
end,
Mod:Func(Res).
do_apply_mf_killed(Arg, Mod, Func) ->
Res = case id(Arg) of
{Tag,Decoded} when Decoded =/= [], Tag =:= error ->
error;
List when is_list(List) ->
ok
end,
Mod:Func(Res).
bs_init(_Config) ->
<<7>> = do_bs_init_1([?MODULE], 7),
error = do_bs_init_1([?MODULE], 0.0),
error = do_bs_init_1([?MODULE], -43),
error = do_bs_init_1([?MODULE], 42),
<<>> = do_bs_init_2([]),
<<0:32,((1 bsl 32)-1):32>> = do_bs_init_2([0,(1 bsl 32)-1]),
{'EXIT',{badarg,_}} = (catch do_bs_init_2([0.5])),
{'EXIT',{badarg,_}} = (catch do_bs_init_2([-1])),
{'EXIT',{badarg,_}} = (catch do_bs_init_2([1 bsl 32])),
<<>> = do_bs_init_3({tag,0}, 0, 0),
<<0>> = do_bs_init_3({tag,0}, 2, 1),
<<"_build/shared">> = do_bs_init_4([], false),
<<"abc/shared">> = do_bs_init_4(<<"abc">>, false),
<<"foo/foo">> = do_bs_init_4(<<"foo">>, true),
error = do_bs_init_4([], not_boolean),
Id = 17575,
Domain = -8798798,
[<<10,1:16,Id:16/signed>>,<<8,2:16,Domain:32/signed>>] =
do_bs_init_5(#{tag=>value,id=>Id,domain=>Domain}),
{'EXIT',{{required,id},[_|_]}} =
(catch do_bs_init_5(#{tag=>value,id=>nil,domain=>Domain})),
{'EXIT',{{required,domain},[_|_]}} =
(catch do_bs_init_5(#{tag=>value,id=>Id,domain=>nil})),
ok.
do_bs_init_1([?MODULE], Sz) ->
if
is_integer(Sz), Sz >= -42, Sz < 42 ->
id(<<Sz:8>>);
true ->
error
end.
do_bs_init_2(SigNos) ->
<< <<SigNo:32>> ||
SigNo <- SigNos,
(is_integer(SigNo) andalso SigNo >= 0 andalso SigNo < (1 bsl 32)) orelse
erlang:error(badarg)
>>.
do_bs_init_3({tag,Pos}, Offset, Len) ->
N0 = Offset - Pos,
N = if N0 > Len -> Len;
true -> N0
end,
<<0:N/unit:8>>.
do_bs_init_4(Arg1, Arg2) ->
Build =
case id(Arg1) of
X when X =:= [] orelse X =:= false -> <<"_build">>;
X -> X
end,
case id(Arg2) of
true ->
id(<<case Build of
Rewrite when is_binary(Rewrite) ->
Rewrite;
Rewrite ->
id(Rewrite)
end/binary,
"/",
case id(<<"foo">>) of
Rewrite when is_binary(Rewrite) ->
Rewrite;
Rewrite ->
id(Rewrite)
end/binary>>);
false ->
id(<<case Build of
Rewrite when is_binary(Rewrite) ->
Rewrite;
Rewrite ->
id(Rewrite)
end/binary,
"/shared">>);
Other ->
error
end.
do_bs_init_5(#{tag := value, id := Id, domain := Domain}) ->
[case Id of
nil ->
error(id({required, id}));
_ ->
<<10, 1:16/signed, Id:16/signed>>
end,
case Domain of
nil ->
error(id({required, domain}));
_ ->
<<8, 2:16/signed, Domain:32/signed>>
end].
bs_save(_Config) ->
{a,30,<<>>} = do_bs_save(<<1:1,30:5>>),
{b,127,<<>>} = do_bs_save(<<1:1,31:5,0:1,127:7>>),
{c,127,<<>>} = do_bs_save(<<1:1,31:5,1:1,127:7>>),
{c,127,<<>>} = do_bs_save(<<0:1,31:5,1:1,127:7>>),
{d,1024,<<>>} = do_bs_save(<<0:1,31:5>>),
ok.
do_bs_save(<<_:1, Tag:5, T/binary>>) when Tag < 31 ->
{a,Tag,T};
do_bs_save(<<1:1, 31:5, 0:1, Tag:7, T/binary>>) ->
{b,Tag,T};
do_bs_save(<<_:1, 31:5, 1:1, Tag:7, T/binary>>) ->
{c,Tag,T};
do_bs_save(<<_:1, 31:5, T/binary>>) ->
{d,1024,T}.
is_not_killed(_Config) ->
{Pid,Ref} = spawn_monitor(fun() -> exit(banan) end),
receive
{'DOWN', Ref, process, Pid, banan} ->
ok
end,
receive after 0 -> ok end.
is_not_used_at(_Config) ->
{a,b} = do_is_not_used_at(a, [{a,b}]),
{a,b} = do_is_not_used_at(a, [x,{a,b}]),
{a,b} = do_is_not_used_at(a, [{x,y},{a,b}]),
none = do_is_not_used_at(z, [{a,b}]),
none = do_is_not_used_at(a, [x]),
none = do_is_not_used_at(a, [{x,y}]),
ok.
do_is_not_used_at(Key, [P|Ps]) ->
if
tuple_size(P) >= 1, element(1, P) =:= Key ->
P;
true ->
do_is_not_used_at(Key, Ps)
end;
do_is_not_used_at(_Key, []) -> none.
-record(select, {fixed=false}).
select(_Config) ->
a = do_select(#select{}, 0, 0),
b = do_select(#select{}, 0, 1),
c = do_select(#select{fixed=true}, 0, 0),
c = do_select(#select{fixed=true}, 0, 1),
ok.
do_select(Head, OldSize, BSize) ->
Overwrite0 =
if
OldSize =:= BSize -> same;
true -> true
end,
Overwrite =
if
Head#select.fixed =/= false ->
false;
true ->
Overwrite0
end,
if
Overwrite =:= same ->
a;
Overwrite ->
b;
true ->
c
end.
y_catch(_Config) ->
ok = try
do_y_catch(<<"<?xmlX">>, {state}),
failed
catch
throw:{<<"<?xmlX">>,{state}} ->
ok
end.
do_y_catch(<<"<?xml",Rest0/binary>> = Bytes, State0) ->
{Rest1,State1} =
case do_y_catch_1(Rest0, State0) of
false ->
{Bytes,State0};
true ->
{_XmlAttributes, R, S} = do_y_catch_2(Rest0),
{R,S}
end,
case catch id({Rest1,State1}) of
Other ->
throw(Other)
end.
do_y_catch_1(<<_,_/binary>>, _) ->
false.
do_y_catch_2(_) -> {a,b,c}.
otp_8949_b(_Config) ->
self() ! something,
value = otp_8949_b([], false),
{'EXIT',_} = (catch otp_8949_b([], true)),
ok.
%% Would cause an endless loop in beam_utils.
otp_8949_b(A, B) ->
Var = id(value),
if
A == [], B == false ->
ok
end,
receive
something ->
id(Var)
end.
-record(alarmInfo, {type,cause,origin}).
liveopt(_Config) ->
F = liveopt_fun(42, pebkac, user),
void = F(42, #alarmInfo{type=sctp,cause=pebkac,origin=user}),
A = {#alarmInfo{cause = {abc, def}}, ghi},
A = liveopt_guard_bif(A),
B = {#alarmInfo{cause = {abc}}, def},
{#alarmInfo{cause = {{abc}}}, def} = liveopt_guard_bif(B),
ok.
liveopt_fun(Peer, Cause, Origin) ->
fun(PeerNo, AlarmInfo)
when PeerNo == Peer andalso
AlarmInfo == #alarmInfo{type=sctp,
cause=Cause,
origin=Origin} ->
void
end.
liveopt_guard_bif({#alarmInfo{cause=F}=R, X}=A) ->
%% ERIERL-48
if
is_tuple(F), tuple_size(F) == 2 -> A;
true ->
R2 = R#alarmInfo{cause={F}},
{R2,X}
end.
%% Thanks to QuickCheck.
coverage(_Config) ->
42+7 = merchant([[],7,false]),
{'EXIT',{{try_clause,0},_}} = (catch resulting([0], stone)),
0.0 = resulting([true], stone),
{'EXIT',{if_clause,_}} = (catch clinic(false)),
{'EXIT',{{try_clause,"trials"},_}} = (catch clinic(true)),
{'EXIT',{function_clause,_}} = (catch town(overall, {{abc},alcohol})),
self() ! junk_message,
{"url",#{true:="url"}} = appointment(#{"resolution" => "url"}),
ok.
%% Cover check_liveness/3.
merchant([Merchant, Laws, Electric]) ->
id(42),
oklahoma([[] || 0 <- Merchant],
if true; Electric -> Laws end) + 42.
oklahoma([], Int) -> Int.
town(overall, {{If}, Healing = alcohol})
when Healing#{[] => Healing}; include ->
[If || Healing <- awareness].
%% Cover is_reg_used_at/3.
resulting([Conservation], stone) ->
try 0 of
Conservation when Conservation -> Conservation;
_ when Conservation; 0 -> 0.0
after
Conservation
end.
%% Cover is_reg_used_at_1/3.
clinic(Damage) ->
if
Damage ->
try "trials" of Damage when Damage -> Damage catch true -> [] end
end,
carefully.
y_registers(_Config) ->
{'EXIT',{{badfun,0},_}} = (catch economic(0.0, jim)),
{'EXIT',{{badmatch,apartments},_}} = (catch louisiana()),
{a,b} = (boxes(true))({a,b}),
{'EXIT',{{case_clause,webmaster},_}} = (catch yellow(true)),
ok.
economic(0.0 = Serves, Existence) ->
case Serves of
Serves -> 0
end,
Existence = jim,
0(),
Serves,
Existence.
louisiana() ->
{catch necessarily,
try
[] == reg,
true = apartments
catch [] -> barbara
end}.
boxes(Call) ->
case Call of
Call -> approval
end,
Call,
fun id/1.
yellow(Hill) ->
case webmaster of
station -> eyes; Hill ->
"under"
end,
Hill,
id(42).
do(A, B) -> {A,B}.
appointment(#{"resolution" := Url}) ->
do(receive _ -> Url end, #{true => Url}).
%% From epp.erl.
user_predef(_Config) ->
#{key:="value"} = user_predef({key,"value"}, #{}),
#{key:="value"} = user_predef({key,"value"}, #{key=>defined}),
error = user_predef({key,"value"}, #{key=>[defined]}),
ok.
user_predef({M,Val}, Ms) ->
case Ms of
#{M:=Defs} when is_list(Defs) ->
error;
_ ->
Ms#{M=>Val}
end.
%% From disk_log_1.erl.
scan_f(_Config) ->
{1,<<>>,[]} = scan_f(<<1:32>>, 1, []),
{1,<<>>,[<<156>>]} = scan_f(<<1:32,156,1:32>>, 1, []),
ok.
scan_f(<<Size:32,Tail/binary>>, FSz, Acc) when Size =< FSz ->
case Tail of
<<BinTerm:Size/binary,Tail2/binary>> ->
scan_f(Tail2, FSz, [BinTerm | Acc]);
_ ->
{Size,Tail,Acc}
end.
%% From file_io_server.erl.
cafu(_Config) ->
error = cafu(<<42:32>>, -1, 0, {utf32,big}),
error = cafu(<<42:32>>, 10, 0, {utf32,big}),
error = cafu(<<42:32>>, -1, 0, {utf32,little}),
ok.
cafu(<<_/big-utf32,Rest/binary>>, N, Count, {utf32,big}) when N < 0 ->
cafu(Rest, -1, Count+1, {utf32,big});
cafu(<<_/big-utf32,Rest/binary>>, N, Count, {utf32,big}) ->
cafu(Rest, N-1, Count+1, {utf32,big});
cafu(<<_/little-utf32,Rest/binary>>, N, Count, {utf32,little}) when N < 0 ->
cafu(Rest, -1, Count+1, {utf32,little});
cafu(_, _, _, _) ->
error.
-record(rec_label, {bool}).
receive_label(_Config) ->
Pid = spawn_link(fun() -> do_receive_label(#rec_label{bool=true}) end),
Msg = {a,b,c},
Pid ! {self(),Msg},
receive
{ok,Msg} ->
unlink(Pid),
exit(Pid, die),
ok
end.
do_receive_label(Rec) ->
receive
{From,Message} when Rec#rec_label.bool ->
From ! {ok,Message},
do_receive_label(Rec)
end.
read_size_file_version(_Config) ->
ok = do_read_size_file_version({ok,<<42>>}),
{ok,7777} = do_read_size_file_version({ok,<<7777:32>>}),
ok.
do_read_size_file_version(E) ->
case E of
{ok,<<Version>>} when Version =:= 42 ->
ok;
{ok,<<MaxFiles:32>>} ->
{ok,MaxFiles}
end.
-record(s, { a, b }).
-record(k, { v }).
not_used(_Config) ->
[] = not_used_p(any, #s{b=true}, #k{}, ignored),
#k{v=42} = not_used_p(any, #s{b=false}, #k{v=42}, ignored),
#k{v=42} = not_used_p(any, #s{b=bad}, #k{v=42}, ignored),
ok.
not_used_p(_C, S, K, L) when is_record(K, k) ->
if ((S#s.b) and
(S#s.b)) ->
[];
true ->
id(L),
id(K#k.v),
id(K)
end.
is_used_fr(Config) ->
1 = is_used_fr(self(), self()),
1 = is_used_fr(self(), other),
receive 1 -> ok end,
receive 1 -> ok end,
receive 1 -> ok end,
receive 1 -> ok end,
ok.
is_used_fr(X, Y) ->
%% beam_utils:is_used({fr,R}, Code) would crash.
_ = 0 / (X ! 1),
_ = case Y of
X -> ok;
_ -> error
end,
X ! 1.
%% The identity function.
id(I) -> I.
