aboutsummaryrefslogtreecommitdiffstats
path: root/erts/emulator/test/socket_test_evaluator.erl
diff options
context:
space:
mode:
authorMicael Karlberg <[email protected]>2018-10-29 14:58:53 +0100
committerMicael Karlberg <[email protected]>2018-10-29 14:58:53 +0100
commitf8ce6043ff330a34644f03f5589c33ad7e57bfab (patch)
treec6c9d6a084c156231d4082c4d0fc0edfce88ec89 /erts/emulator/test/socket_test_evaluator.erl
parent944c0714c9342c4b72fc4433448058db4cb7861f (diff)
downloadotp-f8ce6043ff330a34644f03f5589c33ad7e57bfab.tar.gz
otp-f8ce6043ff330a34644f03f5589c33ad7e57bfab.tar.bz2
otp-f8ce6043ff330a34644f03f5589c33ad7e57bfab.zip
[socket-nif|test] All test cases now using evaluator module
All test cases has been updated using the new evaluator module (and their macros). OTP-14831
Diffstat (limited to 'erts/emulator/test/socket_test_evaluator.erl')
-rw-r--r--erts/emulator/test/socket_test_evaluator.erl68
1 files changed, 32 insertions, 36 deletions
diff --git a/erts/emulator/test/socket_test_evaluator.erl b/erts/emulator/test/socket_test_evaluator.erl
index 8498ef6a0c..bad8c92dec 100644
--- a/erts/emulator/test/socket_test_evaluator.erl
+++ b/erts/emulator/test/socket_test_evaluator.erl
@@ -44,6 +44,12 @@
await_termination/1, await_termination/2
]).
+%% Utility functions
+-export([
+ iprint/2, % Info printouts
+ eprint/2 % Error printouts
+ ]).
+
-export_type([
ev/0,
initial_evaluator_state/0,
@@ -110,22 +116,22 @@ loop(_ID, [], FinalState) ->
exit(FinalState);
loop(ID, [#{desc := Desc,
cmd := Cmd}|Cmds], State) when is_function(Cmd, 1) ->
- i("evaluate command ~2w: ~s", [ID, Desc]),
+ iprint("evaluate command ~2w: ~s", [ID, Desc]),
try Cmd(State) of
ok ->
loop(ID + 1, Cmds, State);
{ok, NewState} ->
loop(ID + 1, Cmds, NewState);
{error, Reason} ->
- e("command ~w failed: "
- "~n Reason: ~p", [ID, Reason]),
+ eprint("command ~w failed: "
+ "~n Reason: ~p", [ID, Reason]),
exit({command_failed, ID, Reason, State})
catch
C:E:S ->
- e("command ~w crashed: "
- "~n Class: ~p"
- "~n Error: ~p"
- "~n Call Stack: ~p", [ID, C, E, S]),
+ eprint("command ~w crashed: "
+ "~n Class: ~p"
+ "~n Error: ~p"
+ "~n Call Stack: ~p", [ID, C, E, S]),
exit({command_crashed, ID, {C,E,S}, State})
end.
@@ -147,28 +153,22 @@ await_finish(Evs, Fails) ->
{'DOWN', _MRef, process, Pid, normal} ->
case lists:keysearch(Pid, #ev.pid, Evs) of
{value, #ev{name = Name}} ->
-
-
- i("evaluator '~s' (~p) success", [Name, Pid]),
-
-
-
-
+ iprint("evaluator '~s' (~p) success", [Name, Pid]),
NewEvs = lists:keydelete(Pid, #ev.pid, Evs),
await_finish(NewEvs, Fails);
false ->
- i("unknown process ~p died (normal)", [Pid]),
+ iprint("unknown process ~p died (normal)", [Pid]),
await_finish(Evs, Fails)
end;
{'DOWN', _MRef, process, Pid, Reason} ->
case lists:keysearch(Pid, #ev.pid, Evs) of
{value, #ev{name = Name}} ->
- i("evaluator '~s' (~p) failed", [Name, Pid]),
+ iprint("evaluator '~s' (~p) failed", [Name, Pid]),
NewEvs = lists:keydelete(Pid, #ev.pid, Evs),
await_finish(NewEvs, [{Pid, Reason}|Fails]);
false ->
- i("unknown process ~p died: "
- "~n ~p", [Pid, Reason]),
+ iprint("unknown process ~p died: "
+ "~n ~p", [Pid, Reason]),
await_finish(Evs, Fails)
end
end.
@@ -412,25 +412,25 @@ await(ExpPid, Name, Announcement, Slogan, OtherPids)
{Announcement, Pid, Slogan, Extra} when (Pid =:= ExpPid) ->
{ok, Extra};
{'DOWN', _, process, Pid, Reason} when (Pid =:= ExpPid) ->
- e("Unexpected DOWN regarding ~w ~p: "
- "~n ~p", [Name, Pid, Reason]),
+ eprint("Unexpected DOWN regarding ~w ~p: "
+ "~n ~p", [Name, Pid, Reason]),
{error, {unexpected_exit, Name}};
{'DOWN', _, process, OtherPid, Reason} ->
case check_down(OtherPid, Reason, OtherPids) of
ok ->
- i("DOWN from unknown process ~p: "
- "~n ~p", [OtherPid, Reason]),
+ iprint("DOWN from unknown process ~p: "
+ "~n ~p", [OtherPid, Reason]),
await(ExpPid, Name, Announcement, Slogan, OtherPids);
{error, _} = ERROR ->
ERROR
end
after infinity -> % For easy debugging, just change to some valid time (5000)
- i("await -> timeout for msg from ~p (~w): "
- "~n Announcement: ~p"
- "~n Slogan: ~p"
- "~nwhen"
- "~n Messages: ~p",
- [ExpPid, Name, Announcement, Slogan, pi(messages)]),
+ iprint("await -> timeout for msg from ~p (~w): "
+ "~n Announcement: ~p"
+ "~n Slogan: ~p"
+ "~nwhen"
+ "~n Messages: ~p",
+ [ExpPid, Name, Announcement, Slogan, pi(messages)]),
await(ExpPid, Name, Announcement, Slogan, OtherPids)
end.
@@ -444,8 +444,8 @@ pi(Pid, Item) ->
check_down(Pid, DownReason, Pids) ->
case lists:keymember(Pid, 1, Pids) of
{value, {_, Name}} ->
- e("Unexpected DOWN regarding ~w ~p: "
- "~n ~p", [Name, Pid, DownReason]),
+ eprint("Unexpected DOWN regarding ~w ~p: "
+ "~n ~p", [Name, Pid, DownReason]),
{error, {unexpected_exit, Name}};
false ->
ok
@@ -458,14 +458,10 @@ f(F, A) ->
lists:flatten(io_lib:format(F, A)).
-%% i(F) ->
-%% i(F, []).
-i(F, A) ->
+iprint(F, A) ->
print("", F, A).
-%% e(F) ->
-%% e(F, []).
-e(F, A) ->
+eprint(F, A) ->
print("<ERROR> ", F, A).
print(Prefix, F, A) ->