diff options
author | John Högberg <[email protected]> | 2017-06-14 12:14:10 +0200 |
---|---|---|
committer | John Högberg <[email protected]> | 2017-06-14 12:14:10 +0200 |
commit | 02c0cf44437df3ed1ff8cdbb48b477b489977b85 (patch) | |
tree | 3d881b34b12ba49f322947d4e1a0ac7609efbfb4 /lib/kernel | |
parent | 635b35ef4d0403a9bbf149e076aed6fca84af383 (diff) | |
download | otp-02c0cf44437df3ed1ff8cdbb48b477b489977b85.tar.gz otp-02c0cf44437df3ed1ff8cdbb48b477b489977b85.tar.bz2 otp-02c0cf44437df3ed1ff8cdbb48b477b489977b85.zip |
Add a testcase for OTP-13939/ERL-193
Diffstat (limited to 'lib/kernel')
-rw-r--r-- | lib/kernel/test/gen_tcp_misc_SUITE.erl | 41 |
1 files changed, 40 insertions, 1 deletions
diff --git a/lib/kernel/test/gen_tcp_misc_SUITE.erl b/lib/kernel/test/gen_tcp_misc_SUITE.erl index 81c6dcd0fd..5e0ec911fb 100644 --- a/lib/kernel/test/gen_tcp_misc_SUITE.erl +++ b/lib/kernel/test/gen_tcp_misc_SUITE.erl @@ -51,7 +51,7 @@ several_accepts_in_one_go/1, accept_system_limit/1, active_once_closed/1, send_timeout/1, send_timeout_active/1, otp_7731/1, zombie_sockets/1, otp_7816/1, otp_8102/1, wrapping_oct/1, - otp_9389/1]). + otp_9389/1, otp_13939/1]). %% Internal exports. -export([sender/3, not_owner/1, passive_sockets_server/2, priority_server/1, @@ -3131,3 +3131,42 @@ oct_aloop(S,X,Times) -> end. ok({ok,V}) -> V. + +otp_13939(doc) -> + ["Check that writing to a remotely closed socket doesn't block forever " + "when exit_on_close is false."]; +otp_13939(suite) -> + []; +otp_13939(Config) when is_list(Config) -> + {Pid, Ref} = spawn_opt( + fun() -> + {ok, Listener} = gen_tcp:listen(0, [{exit_on_close, false}]), + {ok, Port} = inet:port(Listener), + + spawn_link( + fun() -> + {ok, Client} = gen_tcp:connect("localhost", Port, + [{active, false}]), + ok = gen_tcp:close(Client) + end), + + {ok, Accepted} = gen_tcp:accept(Listener), + + ok = gen_tcp:send(Accepted, <<0:(10*1024*1024*8)>>), + + %% The bug surfaces when there's a delay between the send + %% operations; inet:getstat is a red herring. + timer:sleep(100), + + {error, Code} = gen_tcp:send(Accepted, <<0:(10*1024*1024*8)>>), + ct:pal("gen_tcp:send returned ~p~n", [Code]) + end, [link, monitor]), + + receive + {'DOWN', Ref, process, Pid, normal} -> + ok + after 1000 -> + demonitor(Ref, [flush]), + exit(Pid, normal), + ct:fail("Server process blocked on send.") + end. |