summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMicael Karlberg <bmk@erlang.org>2022-11-28 09:57:11 +0100
committerMicael Karlberg <bmk@erlang.org>2022-11-28 09:57:11 +0100
commit2c3cb0efbf16a09bcce92fa6a485a1ef19e254fb (patch)
treed7f810b55c0256f8c3a4a2bc6a4e043849963800
parent6ee03c7c0d15967425746f7a1fac849c87decc66 (diff)
downloaderlang-2c3cb0efbf16a09bcce92fa6a485a1ef19e254fb.tar.gz
[kernel|test|gen-tcp-misc] Tweaked bidirectional_traffic
-rw-r--r--lib/kernel/test/gen_tcp_misc_SUITE.erl12
1 files changed, 7 insertions, 5 deletions
diff --git a/lib/kernel/test/gen_tcp_misc_SUITE.erl b/lib/kernel/test/gen_tcp_misc_SUITE.erl
index 049acb9e07..1db7db9b2a 100644
--- a/lib/kernel/test/gen_tcp_misc_SUITE.erl
+++ b/lib/kernel/test/gen_tcp_misc_SUITE.erl
@@ -7348,8 +7348,7 @@ delay_send_error2(Sock, N) ->
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
--define(ACTIVE_N, 20).
--define(MAX_WORKERS, 40).
+-define(MAX_WORKERS, 30).
%% 30-second test for gen_tcp in {active, N} mode,
%% ensuring it does not get stuck.
@@ -7363,11 +7362,11 @@ bidirectional_traffic(Config) when is_list(Config) ->
(NumWorkers0 =< 10) ->
{NumWorkers0, 20};
(NumWorkers0 =< 20) ->
- {NumWorkers0, 15};
+ {NumWorkers0, 18};
(NumWorkers0 =< ?MAX_WORKERS) ->
- {NumWorkers0, 10};
+ {NumWorkers0, 15};
true ->
- {?MAX_WORKERS, 10}
+ {?MAX_WORKERS, 15}
end,
?P("pre ->"
"~n Number Of Online Schedulers: ~w"
@@ -7495,6 +7494,9 @@ send_recv_loop(Socket, Payload, Control, ActiveN) ->
case gen_tcp:send(Socket, Payload) of
ok ->
Sender();
+ {error, closed} ->
+ ?P("[~w,sender] Socket closed", [Role]),
+ exit(normal);
{error, Reason} ->
?P("[~w,sender] Send failed: "
"~n ~p", [Role, Reason]),