aboutsummaryrefslogtreecommitdiffstats
path: root/erts/emulator/test/socket_test_ttest_tcp_server.erl
diff options
context:
space:
mode:
authorMicael Karlberg <[email protected]>2018-12-18 15:21:43 +0100
committerMicael Karlberg <[email protected]>2018-12-18 15:21:43 +0100
commit2dceec3057ff298cf6a7ff6af5a5a1b5f8b96e61 (patch)
tree97e29bec7a7e1de40190feff672f239035cbfb49 /erts/emulator/test/socket_test_ttest_tcp_server.erl
parent6781913e975e93a4a29d14e14794aae4526de9f7 (diff)
downloadotp-2dceec3057ff298cf6a7ff6af5a5a1b5f8b96e61.tar.gz
otp-2dceec3057ff298cf6a7ff6af5a5a1b5f8b96e61.tar.bz2
otp-2dceec3057ff298cf6a7ff6af5a5a1b5f8b96e61.zip
[socket-nif|test] Add more ttest (gen_tcp) test cases
Added a number of ttest test cases with transport gen_tcp. Server with transport = gen_tcp, active = false and client using transport = gen_tcp (and active = false, once and true). Also "fixed" the gen_tcp socket buffer size (default size was way to small for the "large" messages). OTP-14831
Diffstat (limited to 'erts/emulator/test/socket_test_ttest_tcp_server.erl')
-rw-r--r--erts/emulator/test/socket_test_ttest_tcp_server.erl21
1 files changed, 15 insertions, 6 deletions
diff --git a/erts/emulator/test/socket_test_ttest_tcp_server.erl b/erts/emulator/test/socket_test_ttest_tcp_server.erl
index 257bb18592..15f65d56b6 100644
--- a/erts/emulator/test/socket_test_ttest_tcp_server.erl
+++ b/erts/emulator/test/socket_test_ttest_tcp_server.erl
@@ -349,11 +349,12 @@ handler_loop(State) ->
handler_loop( handler_handle_message( handler_recv_message(State) ) ).
%% When passive, we read *one* request and then attempt to reply to it.
-handler_recv_message(#{mod := Mod,
- sock := Sock,
- active := false,
- mcnt := MCnt,
- bcnt := BCnt} = State) ->
+handler_recv_message(#{mod := Mod,
+ sock := Sock,
+ active := false,
+ mcnt := MCnt,
+ bcnt := BCnt,
+ last_reply := LID} = State) ->
case handler_recv_message2(Mod, Sock) of
{ok, {MsgSz, ID, Body}} ->
handler_send_reply(Mod, Sock, ID, Body),
@@ -363,6 +364,10 @@ handler_recv_message(#{mod := Mod,
{error, closed} ->
handler_done(State);
{error, timeout} ->
+ ?I("timeout when: "
+ "~n MCnt: ~p"
+ "~n BCnt: ~p"
+ "~n LID: ~p", [MCnt, BCnt, LID]),
State
end;
@@ -403,6 +408,11 @@ handler_recv_message(#{mod := Mod,
end;
{error, timeout} ->
+ ?I("timeout when: "
+ "~n MCnt: ~p"
+ "~n BCnt: ~p"
+ "~n LID: ~p"
+ "~n size(Acc): ~p", [MCnt, BCnt, LID, size(Acc)]),
State
end.
@@ -443,7 +453,6 @@ handler_recv_message2(Mod, Sock) ->
exit({recv, body, ID, SZ, BReason})
end;
{error, timeout} = ERROR ->
- ?I("timeout"),
ERROR;
{error, closed} = ERROR ->
ERROR;