From 6de8ee374ec1b1fba4acef1eef851c2634996fa2 Mon Sep 17 00:00:00 2001
From: Micael Karlberg <bmk@erlang.org>
Date: Mon, 29 Apr 2019 18:38:29 +0200
Subject: [esock|test] Add multi async recvmsg UDP test case

Add recvmsg test case testing the abort message received
when "another" process closes a socket. Multiple readers
for good measure.
---
 erts/emulator/test/socket_SUITE.erl | 33 ++++++++++++++++++++++++++++++++-
 1 file changed, 32 insertions(+), 1 deletion(-)

(limited to 'erts')

diff --git a/erts/emulator/test/socket_SUITE.erl b/erts/emulator/test/socket_SUITE.erl
index 1dfd541f27..079ed76f41 100644
--- a/erts/emulator/test/socket_SUITE.erl
+++ b/erts/emulator/test/socket_SUITE.erl
@@ -92,6 +92,7 @@
          api_a_recv_cancel_tcp4/1,
          api_a_recvmsg_cancel_tcp4/1,
          api_a_mrecvfrom_cancel_udp4/1,
+         api_a_mrecvmsg_cancel_udp4/1,
 
 
          %% *** API Options ***
@@ -685,7 +686,8 @@ api_async_cases() ->
      api_a_accept_cancel_tcp4,
      api_a_recv_cancel_tcp4,
      api_a_recvmsg_cancel_tcp4,
-     api_a_mrecvfrom_cancel_udp4
+     api_a_mrecvfrom_cancel_udp4,
+     api_a_mrecvmsg_cancel_udp4
     ].
 
 api_options_cases() ->
@@ -4604,6 +4606,35 @@ api_a_mrecvfrom_cancel_udp4(_Config) when is_list(_Config) ->
 
 
 
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+
+%% Basically we make multiple async (Timeout = nowait) call to recvmsg
+%% (from *several* processes), wait some time and then cancel.
+%% This should result in abort messages to the 'other' processes.
+%%
+api_a_mrecvmsg_cancel_udp4(suite) ->
+    [];
+api_a_mrecvmsg_cancel_udp4(doc) ->
+    [];
+api_a_mrecvmsg_cancel_udp4(_Config) when is_list(_Config) ->
+    ?TT(?SECS(20)),
+    tc_try(api_a_mrecvmsg_cancel_udp4,
+           fun() ->
+                   Recv = fun(Sock) ->
+                                  case socket:recvmsg(Sock, nowait) of
+                                      {ok, _} = OK ->
+                                          OK;
+                                      {error, _} = ERROR ->
+                                          ERROR
+                                  end
+                          end,
+                   InitState = #{domain => inet,
+                                 recv   => Recv},
+                   ok = api_a_mrecv_cancel_udp(InitState)
+           end).
+
+
+
 %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
 
 api_a_mrecv_cancel_udp(InitState) ->
-- 
cgit v1.2.3