From 2dceec3057ff298cf6a7ff6af5a5a1b5f8b96e61 Mon Sep 17 00:00:00 2001
From: Micael Karlberg <bmk@erlang.org>
Date: Tue, 18 Dec 2018 15:21:43 +0100
Subject: [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
---
 erts/emulator/test/socket_test_ttest_tcp_server.erl | 21 +++++++++++++++------
 1 file changed, 15 insertions(+), 6 deletions(-)

(limited to 'erts/emulator/test/socket_test_ttest_tcp_server.erl')

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;
-- 
cgit v1.2.3