Merge branch 'raimo/uds-support/OTP-13643'

* raimo/uds-support/OTP-13643:
  Update test cases after daily builds
  Return eafnosupport when not supported
  Add AF_LOCAL test cases
  Handle 'undefined' in fdopen

1 files changed, 152 insertions, 5 deletions

diff --git a/lib/kernel/test/gen_udp_SUITE.erl b/lib/kernel/test/gen_udp_SUITE.erl
index 44539bf44c..db4e174374 100644
--- a/lib/kernel/test/gen_udp_SUITE.erl
+++ b/lib/kernel/test/gen_udp_SUITE.erl
@@ -35,7 +35,9 @@
 
 -export([send_to_closed/1, active_n/1,
 	 buffer_size/1, binary_passive_recv/1, bad_address/1,
-	 read_packets/1, open_fd/1, connect/1, implicit_inet6/1]).
+	 read_packets/1, open_fd/1, connect/1, implicit_inet6/1,
+	 local_basic/1, local_unbound/1,
+	 local_fdopen/1, local_fdopen_unbound/1, local_abstract/1]).
 
 suite() ->
     [{ct_hooks,[ts_install_cth]},
@@ -44,10 +46,13 @@ suite() ->
 all() -> 
     [send_to_closed, buffer_size, binary_passive_recv,
      bad_address, read_packets, open_fd, connect,
-     implicit_inet6, active_n].
+     implicit_inet6, active_n,
+     {group, local}].
 
 groups() -> 
-    [].
+    [{local, [],
+      [local_basic, local_unbound,
+       local_fdopen, local_fdopen_unbound, local_abstract]}].
 
 init_per_suite(Config) ->
     Config.
@@ -55,9 +60,19 @@ init_per_suite(Config) ->
 end_per_suite(_Config) ->
     ok.
 
+init_per_group(local, Config) ->
+    case gen_udp:open(0, [local]) of
+	{ok,S} ->
+	    ok = gen_udp:close(S),
+	    Config;
+	{error,eafnosupport} ->
+	    {skip, "AF_LOCAL not supported"}
+    end;
 init_per_group(_GroupName, Config) ->
     Config.
 
+end_per_group(local, _Config) ->
+    delete_local_filenames();
 end_per_group(_GroupName, Config) ->
     Config.
 
@@ -65,7 +80,7 @@ end_per_group(_GroupName, Config) ->
 init_per_testcase(_Case, Config) ->
     Config.
 
-end_per_testcase(_Case, Config) ->
+end_per_testcase(_Case, _Config) ->
     ok.
 
 %%-------------------------------------------------------------
@@ -550,6 +565,116 @@ active_n(Config) when is_list(Config) ->
     ok = gen_udp:close(S1),
     ok.
 
+
+local_basic(_Config) ->
+    SFile = local_filename(server),
+    SAddr = {local,bin_filename(SFile)},
+    CFile = local_filename(client),
+    CAddr = {local,bin_filename(CFile)},
+    _ = file:delete(SFile),
+    _ = file:delete(CFile),
+    %%
+    S = ok(gen_udp:open(0, [{ifaddr,{local,SFile}},{active,false}])),
+    C = ok(gen_udp:open(0, [{ifaddr,{local,CFile}},{active,false}])),
+    SAddr = ok(inet:sockname(S)),
+    CAddr = ok(inet:sockname(C)),
+    local_handshake(S, SAddr, C, CAddr),
+    ok = gen_udp:close(S),
+    ok = gen_udp:close(C),
+    %%
+    ok = file:delete(SFile),
+    ok = file:delete(CFile),
+    ok.
+
+local_unbound(_Config) ->
+    SFile = local_filename(server),
+    SAddr = {local,bin_filename(SFile)},
+    _ = file:delete(SFile),
+    %%
+    S = ok(gen_udp:open(0, [{ifaddr,SAddr},{active,false}])),
+    C = ok(gen_udp:open(0, [local,{active,false}])),
+    SAddr = ok(inet:sockname(S)),
+    local_handshake(S, SAddr, C, undefined),
+    ok = gen_udp:close(S),
+    ok = gen_udp:close(C),
+    %%
+    ok = file:delete(SFile),
+    ok.
+
+local_fdopen(_Config) ->
+    SFile = local_filename(server),
+    SAddr = {local,bin_filename(SFile)},
+    CFile = local_filename(client),
+    CAddr = {local,bin_filename(CFile)},
+    _ = file:delete(SFile),
+    _ = file:delete(CFile),
+    %%
+    S0 = ok(gen_udp:open(0, [{ifaddr,SAddr},{active,false}])),
+    C = ok(gen_udp:open(0, [{ifaddr,{local,CFile}},{active,false}])),
+    SAddr = ok(inet:sockname(S0)),
+    CAddr = ok(inet:sockname(C)),
+    Fd = ok(prim_inet:getfd(S0)),
+    S = ok(gen_udp:open(0, [{fd,Fd},local,{active,false}])),
+    SAddr = ok(inet:sockname(S)),
+    local_handshake(S, SAddr, C, CAddr),
+    ok = gen_udp:close(S),
+    ok = gen_udp:close(S0),
+    ok = gen_udp:close(C),
+    %%
+    ok = file:delete(SFile),
+    ok = file:delete(CFile),
+    ok.
+
+local_fdopen_unbound(_Config) ->
+    SFile = local_filename(server),
+    SAddr = {local,bin_filename(SFile)},
+    _ = file:delete(SFile),
+    %%
+    S = ok(gen_udp:open(0, [{ifaddr,SAddr},{active,false}])),
+    C0 = ok(gen_udp:open(0, [local,{active,false}])),
+    SAddr = ok(inet:sockname(S)),
+    Fd = ok(prim_inet:getfd(C0)),
+    C = ok(gen_udp:open(0, [{fd,Fd},local,{active,false}])),
+    local_handshake(S, SAddr, C, undefined),
+    ok = gen_udp:close(S),
+    ok = gen_udp:close(C),
+    ok = gen_udp:close(C0),
+    %%
+    ok = file:delete(SFile),
+    ok.
+
+local_abstract(_Config) ->
+    case os:type() of
+	{unix,linux} ->
+	    S = ok(gen_udp:open(0, [{ifaddr,{local,<<>>}},{active,false}])),
+	    C = ok(gen_udp:open(0, [{ifaddr,{local,<<>>}},{active,false}])),
+	    {local,_} = SAddr = ok(inet:sockname(S)),
+	    {local,_} = CAddr = ok(inet:sockname(C)),
+	    local_handshake(S, SAddr, C, CAddr),
+	    ok = gen_udp:close(S),
+	    ok = gen_udp:close(C),
+	    ok;
+	_ ->
+	    {skip,"AF_LOCAL Abstract Addresses only supported on Linux"}
+    end.
+
+
+local_handshake(S, SAddr, C, CAddr) ->
+    SData = "9876543210",
+    CData = "0123456789",
+    ok = gen_udp:send(C, SAddr, 0, CData),
+    case ok(gen_tcp:recv(S, 112)) of
+	{{unspec,<<>>}, 0, CData} when CAddr =:= undefined ->
+	    ok;
+	{{local,<<>>}, 0, CData} when CAddr =:= undefined ->
+	    ok;
+	{CAddr, 0, CData} when CAddr =/= undefined ->
+	    ok = gen_udp:send(S, CAddr, 0, SData),
+	    {SAddr, 0, SData} = ok(gen_tcp:recv(C, 112)),
+	    ok
+
+    end.
+
 %%
 %% Utils
 %%
@@ -630,4 +755,26 @@ implicit_inet6(S1, Active, Addr) ->
     {Addr,P2,"pong"} = ok(gen_udp:recv(S1, 1024)),
     ok = gen_udp:close(S2).
 
-ok({ok,V}) -> V.
+ok({ok,V}) -> V;
+ok(NotOk) ->
+    try throw(not_ok)
+    catch
+	Thrown ->
+	    erlang:raise(
+	      error, {Thrown, NotOk}, tl(erlang:get_stacktrace()))
+    end.
+
+
+local_filename(Tag) ->
+    "/tmp/" ?MODULE_STRING "_" ++ os:getpid() ++ "_" ++ atom_to_list(Tag).
+
+bin_filename(String) ->
+    unicode:characters_to_binary(String, file:native_name_encoding()).
+
+delete_local_filenames() ->
+    _ =
+	[file:delete(F) ||
+	    F <-
+		filelib:wildcard(
+		  "/tmp/" ?MODULE_STRING "_" ++ os:getpid() ++ "_*")],
+    ok.